> > > >
> > > > On Thu, Jan 19, 2017 at 7:26 PM, Dave Marion
> > > > mailto:dlmar...@comcast.net > wrote:
> > > >
> > > > > > > > >
> > > > > Notice
tors.
> > >
> > > Stephan
> > >
> > >
> > > On Thu, Jan 19, 2017 at 7:26 PM, Dave Marion
> > > mailto:dlmar...@comcast.net > wrote:
> > >
> > > > > > >
> > > > Noticed I didn't cc the
to add a patch that the JobManager tolerates these kinds of
> issues in the accumulators.
>
> Stephan
>
>
> On Thu, Jan 19, 2017 at 7:26 PM, Dave Marion wrote:
>
>> Noticed I didn't cc the user list.
>>
>> -- Original Message --
>> From: Dave
cast.net >
> To: Ted Yu mailto:yuzhih...@gmail.com >
> Date: January 19, 2017 at 12:13 PM
> Subject: Re: NPE in JobManager
>
>
> That might take some time. Here is a hand typed top N lines. If
> that is not enough let me
;
> On Thu, Jan 19, 2017 at 7:26 PM, Dave Marion wrote:
>
>> Noticed I didn't cc the user list.
>>
>> -- Original Message --
>> From: Dave Marion
>> To: Ted Yu
>> Date: January 19, 2017 at 12:13 PM
>> Subject: Re: NPE in JobManag
an 19, 2017 at 7:26 PM, Dave Marion wrote:
> Noticed I didn't cc the user list.
>
> -- Original Message --
> From: Dave Marion
> To: Ted Yu
> Date: January 19, 2017 at 12:13 PM
> Subject: Re: NPE in JobManager
>
> That might take some time. Here is
Noticed I didn't cc the user list.
Original Message --
From: Dave Marion
To: Ted Yu
Date: January 19, 2017 at 12:13 PM
Subject: Re: NPE in JobManager
That might take some time. Here is a hand typed top N lines. If that is not
enough let me know and I will start the pr
Can you pastebin the complete stack trace for the NPE ?
Thanks
On Thu, Jan 19, 2017 at 8:57 AM, Dave Marion wrote:
> I'm running flink-1.1.4-bin-hadoop27-scala_2.11 and I'm running into an
> issue where after some period of time (measured in 1 - 3 hours) the
> JobManager gets an NPE and shuts i
I'm running flink-1.1.4-bin-hadoop27-scala_2.11 and I'm running into an issue
where after some period of time (measured in 1 - 3 hours) the JobManager gets
an NPE and shuts itself down. The failure is at
JobManager$$updateAccumulators$1.apply(JobManager.scala:1790). I'm using a
custom accumulat
