Re: Latency tracking together with broadcast state can cause job failure

2020-06-16 Thread Arvid Heise
t; 's kind remind. > > Best > Yun Tang > ------ > *From:* Robert Metzger > *Sent:* Tuesday, April 21, 2020 20:01 > *To:* Lasse Nedergaard > *Cc:* Yun Tang ; user > *Subject:* Re: Latency tracking together with broadcast state can cause > job fai

Re: Latency tracking together with broadcast state can cause job failure

2020-04-22 Thread Lasse Nedergaard
k at this problem. > > Really thank you for reporting this bug. > > [1] https://issues.apache.org/jira/browse/FLINK-17322 > > Best > Yun Tang > From: Yun Tang > Sent: Wednesday, April 22, 2020 1:43 > To: Lasse Nedergaard > Cc: user > Subject: Re: Latency tracki

Re: Latency tracking together with broadcast state can cause job failure

2020-04-22 Thread Yun Tang
Nedergaard Cc: user Subject: Re: Latency tracking together with broadcast state can cause job failure Hi Lasse Really sorry for missing your reply. I'll run your project and find the root cause in my day time. And thanks for @Robert Metzger<mailto:rmetz...@apache.org> 's kind remind. Be

Re: Latency tracking together with broadcast state can cause job failure

2020-04-21 Thread Yun Tang
20:01 To: Lasse Nedergaard Cc: Yun Tang ; user Subject: Re: Latency tracking together with broadcast state can cause job failure Hey Lasse, has the problem been resolved? (I'm also responding to this to make sure the thread gets attention again :) ) Best, Robert On Wed, Apr 1, 2020 at 10:03 PM

Re: Latency tracking together with broadcast state can cause job failure

2020-04-21 Thread Robert Metzger
> *Sent:* Tuesday, March 31, 2020 19:10 > *To:* user > *Subject:* Latency tracking together with broadcast state can cause job > failure > > Hi > > We have in both Flink 1.9.2 and 1.10 struggled with random deserialze and > Index out of range exception in one of our j

Re: Latency tracking together with broadcast state can cause job failure

2020-04-01 Thread Lasse Nedergaard
Nedergaard Sent: Tuesday, March 31, 2020 19:10 To: user Subject: Latency tracking together with broadcast state can cause job failure   Hi We have in both Flink 1.9.2 and 1.10 struggled with random deserialze and Index out of range exception in one of our job. We also get out of memory exceptions

Re: Latency tracking together with broadcast state can cause job failure

2020-04-01 Thread Yun Tang
Subject: Latency tracking together with broadcast state can cause job failure Hi We have in both Flink 1.9.2 and 1.10 struggled with random deserialze and Index out of range exception in one of our job. We also get out of memory exceptions. We have now identified it as a latency tracking together

Latency tracking together with broadcast state can cause job failure

2020-03-31 Thread Lasse Nedergaard
Hi We have in both Flink 1.9.2 and 1.10 struggled with random deserialze and Index out of range exception in one of our job. We also get out of memory exceptions. We have now identified it as a latency tracking together with broadcast state Causing the problem. When we do integration testing