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