Could you share a full stacktrace with us? Could you check the stack
trace also in the task managers logs?
As a side note, make sure you are using the same version of all Flink
dependencies.
Best,
Dawid
On 17/03/2021 06:26, soumoks wrote:
> Hi,
>
> We have upgraded an application originally wri
Hi,
We have upgraded an application originally written for Flink 1.9.1 with
Scala 2.11 to Flink 1.11.2 with Scala 2.12.7 and we are seeing the following
error at runtime.
2021-03-16 20:37:08
java.lang.RuntimeException
at
org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWrit
