Hi Ufuk,
> On Apr 28, 2016, at 1:32am, Ufuk Celebi wrote:
>
> Hey Ken!
>
> That should not happen. Can you check the web interface for two things:
>
> - How many available slots are advertized on the landing page
> (localhost:8081) when you submit your job?
I’m running this on YARN, so I don’
> On Apr 28, 2016, at 1:32am, Aljoscha Krettek wrote:
>
> Hi,
> is this a streaming or batch job?
Batch.
> If it is a batch job, are you using either collect() or print() on a DataSet?
Definitely not a print(). Don’t know about collect(), since the job is created
via the Cascading-Flink plan
Hey Ken!
That should not happen. Can you check the web interface for two things:
- How many available slots are advertized on the landing page
(localhost:8081) when you submit your job?
- Can you check the actual parallelism of the submitted job (it should
appear as a FAILED job in the web fronte
Hi,
is this a streaming or batch job? If it is a batch job, are you using
either collect() or print() on a DataSet?
Cheers,
Aljoscha
On Thu, 28 Apr 2016 at 00:52 Ken Krugler
wrote:
> Hi all,
>
> In trying out different settings for performance, I run into a job failure
> case that puzzles me.
>