Re: Flink Job Exception

2017-02-16 Thread Aljoscha Krettek
Hi Govindarajan, the Jira issue that you linked to and which Till is currently fixing will only fix the obvious type mismatch in the Akka messages. There is also an underlying problem that causes this message to be sent in the first place. In the case of the user who originally created the Jira iss

Re: Flink Job Exception

2017-02-16 Thread Till Rohrmann
Hi Govindarajan, there is a pending PR for this issue. I think I can merge it today. Cheers, Till On Thu, Feb 16, 2017 at 12:50 AM, Govindarajan Srinivasaraghavan < govindragh...@gmail.com> wrote: > Hi All, > > I'm trying to run a streaming job with flink 1.2 version and there are 3 > task mana

Flink Job Exception

2017-02-15 Thread Govindarajan Srinivasaraghavan
Hi All, I'm trying to run a streaming job with flink 1.2 version and there are 3 task managers with 12 task slots. Irrespective of the parallelism that I give it always fails with the below error and I found a JIRA link corresponding to this issue. Can I know by when this will be resolved since I'