Merge branch 'development'

RMLio · Mar 16, 2020 · 56a770b · 56a770b
2 parents f421ff5 + e0a930a
commit 56a770b
Showing 1 changed file with 1 addition and 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
@@ -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
     }
   }