This sounds very much related to FLINK-10160 [1].
Would you mind upgrading your Flink version to 1.4.3 and try again?
Thanks,
Rong
[1] https://issues.apache.org/jira/browse/FLINK-10160
On Fri, Aug 17, 2018 at 4:20 PM Pankaj Chaudhary
wrote:
> Hi,
>
> I am on Flink 1.4.2 and as part of my opera
Hi,
I am on Flink 1.4.2 and as part of my operator logic (i.e. RichFlatMapFunction)
I am collecting the values in the Collector object.
But I am getting an error stating “Caused by:
org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException:
Could not forward element to next
