It’s standard 1.3.2 on Java 7. We don’t use custom flink builds, just pull down
whats in maven.
From: Stephan Ewen [mailto:se...@apache.org]
Sent: Friday, May 11, 2018 2:27 PM
To: user@flink.apache.org
Cc: Chan, Regina [Tech]; Newport, Billy [Tech]; Fabian Hueske
Subject: Re: Lost JobManager
s no collect() explicitly from me. It has a cogroup operator before
>> writing to DataSink.
>>
>>
>>
>>
>>
>> *From:* Fabian Hueske [mailto:fhue...@gmail.com]
>> *Sent:* Monday, May 07, 2018 6:31 AM
>> *To:* Chan, Regina [Tech]
>> *Cc:* user@fl
ue...@gmail.com]
> *Sent:* Monday, May 07, 2018 6:31 AM
> *To:* Chan, Regina [Tech]
> *Cc:* user@flink.apache.org; Newport, Billy [Tech]
> *Subject:* Re: Lost JobManager
>
>
>
> Hi Regina,
>
> I see from the logs that you are using the DataSet API.
>
> Are you try
There’s no collect() explicitly from me. It has a cogroup operator before
writing to DataSink.
From: Fabian Hueske [mailto:fhue...@gmail.com]
Sent: Monday, May 07, 2018 6:31 AM
To: Chan, Regina [Tech]
Cc: user@flink.apache.org; Newport, Billy [Tech]
Subject: Re: Lost JobManager
Hi Regina,
I
Hi Regina,
I see from the logs that you are using the DataSet API.
Are you trying to fetch a large result to your client using the collect()
method?
Best, Fabian
2018-05-02 0:38 GMT+02:00 Chan, Regina :
> Hi,
>
>
>
> I’m running a single TM with the following params -yn 1 -ys 2 -yjm 36864
> -yt
