Re: Exception while running Flink jobs (1.0.0)

2016-10-12 Thread Flavio Pompermaier
Ok, thanks for the update Ufuk! Let me know if you need test or anything! Best, Flavio On Wed, Oct 12, 2016 at 11:26 AM, Ufuk Celebi wrote: > No, sorry. I was waiting for Tarandeep's feedback before looking into > it further. I will do it over the next days in any case. > > On

Re: Exception while running Flink jobs (1.0.0)

2016-10-12 Thread Ufuk Celebi
No, sorry. I was waiting for Tarandeep's feedback before looking into it further. I will do it over the next days in any case. On Wed, Oct 12, 2016 at 10:49 AM, Flavio Pompermaier wrote: > Hi Ufuk, > any news on this? > > On Thu, Oct 6, 2016 at 1:30 PM, Ufuk Celebi

Re: Exception while running Flink jobs (1.0.0)

2016-10-12 Thread Flavio Pompermaier
Hi Ufuk, any news on this? On Thu, Oct 6, 2016 at 1:30 PM, Ufuk Celebi wrote: > I guess that this is caused by a bug in the checksum calculation. Let > me check that. > > On Thu, Oct 6, 2016 at 1:24 PM, Flavio Pompermaier > wrote: > > I've ran the job

Re: Exception while running Flink jobs (1.0.0)

2016-10-04 Thread Stephan Ewen
It would be great to know if this only occurs in setups where Netty in involved (more than one TaskManager and, and at least one shuffle/rebalance) or also in one-taskmanager setups (which have local channels only). Stephan On Tue, Oct 4, 2016 at 11:49 AM, Till Rohrmann

Re: Exception while running Flink jobs (1.0.0)

2016-10-03 Thread Flavio Pompermaier
I think you're running into the same exception I face sometimes..I've opened a jira for it [1]. Could you please try to apply that patch and see if things get better? https://issues.apache.org/jira/plugins/servlet/mobile#issue/FLINK-4719 Best, Flavio On 3 Oct 2016 22:09, "Tarandeep Singh"

Re: Exception while running Flink jobs (1.0.0)

2016-10-03 Thread Tarandeep Singh
Now, when I ran it again (with lower task slots per machine) I got a different error- org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Job execution failed. at org.apache.flink.client.program.Client.runBlocking(Client.java:381) at

Exception while running Flink jobs (1.0.0)

2016-10-03 Thread Tarandeep Singh
Hi, I am using flink-1.0.0 and running ETL (batch) jobs on it for quite some time (few months) without any problem. Starting this morning, I have been getting errors like these- "Received an event in channel 3 while still having data from a record. This indicates broken serialization logic. If