Cluster Memory Error

2017-06-02 Thread Will Walters
Hello, I am attempting to use the Flink runner to execute a data pipeline on a Hadoop cluster. The pipeline is created successfully in Flink, but when it attempts to execute the tasks, I receive a 'Size of total memory must be positive' error, despite having plenty of memory. Here's the log arou

Re: Cluster Memory Error

2017-06-06 Thread Aljoscha Krettek
Hi Will, You you please share some details regarding how you start your cluster and how you submit the program? Best, Aljoscha > On 3. Jun 2017, at 00:26, Will Walters wrote: > > Hello, > > I am attempting to use the Flink runner to execute a data pipeline on a > Hadoop cluster. The pipeline