My flat map function is catching & logging the exception. The try block happens
to encompass the call to Collector#collect().
I will move the call to collect outside of the try. That should silence the log
message.
On 9/30/16, 3:51 AM, "Ufuk Celebi" wrote:
>On Thu, Sep 29, 2016 at 9:29 PM,
On Thu, Sep 29, 2016 at 9:29 PM, Shannon Carey wrote:
> It looks like Flink is disabling the objects that the FlatMap collector
> relies on before disabling the operator itself. Is that expected/normal? Is
> there anything I should change in my FlatMap function or job code to account
> for it?
He
When I cancel a job, I get many exceptions that look like this:
java.lang.RuntimeException: Could not forward element to next operator
at
org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:376)
at
org.apache.flink.streaming.runtime.tasks.Opera
