Re: Flink job getting killed

2020-04-06 Thread Fabian Hueske
Hi Giriraj, This looks like the deserialization of a String failed. Can you isolate the problem to a pair of sending and receiving tasks? Best, Fabian Am So., 5. Apr. 2020 um 20:18 Uhr schrieb Giriraj Chauhan < graj.chau...@gmail.com>: > Hi, > > We are submitting a flink(1.9.1) job for data

Flink job getting killed

2020-04-05 Thread Giriraj Chauhan
Hi, We are submitting a flink(1.9.1) job for data processing. It runs fine and processes data for sometime i.e. ~30 mins and later it throws following exception and job gets killed. 2020-04-02 14:15:43,371 INFO org.apache.flink.runtime.taskmanager.Task - Sink: Unnamed (2/4)