createRemoteEnvironment does not work with print()
jar path corrected for createRemoteEnvironment
flink-tests commented out in pom.xml
objects in org.apache.flink.test.exampleScalaPrograms package failed for compile
flink-tests commented out in pom.xml
MulticastGroupByTest chaining still occurs with remoteEnvironment
chaining turned off
MulticastChainedMapDriverTest works properly
MulticastGroupByTest not every message arrive
chaining turned off
multicast examples cleaning
MulticastMapTest is the cleaned version of MulticastChainedMapDriverTest
commenting out some SYSO in RegularPactTask
multicast examples cleaning
MulticastGroupByTest error found
KeySelector only gets blocked messages
unblocking in handler should be done in RecordReader
MulticastGroupByTest error found
MulticastGroupByTest runs properly
group by of Multicast DataSet-s works
KeySelector invoked from MulticastMessage
MulticastGroupByTest runs properly