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

Reply via email to