Here is the strange behavior.
Below code works in one box but not in the other. I had it working in my
laptop the whole of yesterday, but strangely today it doesnt work in my
desktop.
Can anyone please let me know what the issue is.
public static void main(String[] args) throws Exception {
Here is my code snippet but I find the union operator not workable.
DataStream msgDataStream1 = env.addSource((new
SocketSource(hostName1,port,'\n',-1))).filter(new
MessageFilter()).setParallelism(1);
DataStream msgDataStream2 = env.addSource((new
SocketSource(hostName2,port,'\n',-1))).filter(ne
