Hi All, We are currently working with Flink 1.7.2 version and we are get the below given exception when doing a split on a split.
SplitStream<String>splitStream=stream1.split(new SomeSplitLogic()); DataStream select1=splitStream.select("1"); DataStream select2=splitStream.select("2"); select2.split(new AnotherSplitLogic()).select("3"); Basically the exception is recommending to use SideOutput, however the only way I see to get a side output is by using a process function. Can someone suggest a better way of doing this? Exception : Caused by: java.lang.IllegalStateException: Consecutive multiple splits are not supported. Splits are deprecated. Please use side-outputs Regards, Taher Koitawala GS Lab Pune +91 8407979163