From e0a930a6b9db50be5d26f6c6c16d3a51727b800d Mon Sep 17 00:00:00 2001 From: Gerald Haesendonck Date: Mon, 16 Mar 2020 12:53:06 +0100 Subject: [PATCH] Remove the parallelism = 1 for socket input stream again. --- src/main/scala/io/rml/framework/flink/source/StreamUtil.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/scala/io/rml/framework/flink/source/StreamUtil.scala b/src/main/scala/io/rml/framework/flink/source/StreamUtil.scala index 6f0b0488..78c56012 100644 --- a/src/main/scala/io/rml/framework/flink/source/StreamUtil.scala +++ b/src/main/scala/io/rml/framework/flink/source/StreamUtil.scala @@ -44,7 +44,7 @@ object StreamUtil { */ - case TCPSocketStream.TYPE.PULL => new DataStream[String](env.getJavaEnv.socketTextStream(tCPSocketStream.hostName, tCPSocketStream.port, delimiter).setParallelism(1)) + case TCPSocketStream.TYPE.PULL => new DataStream[String](env.getJavaEnv.socketTextStream(tCPSocketStream.hostName, tCPSocketStream.port, delimiter)) case TCPSocketStream.TYPE.PUSH => env.addSource(new TcpReceiverSource(tCPSocketStream.port)).setParallelism(1) // to avoid library to setup multiple instances } }