Re: Job Manager Configuration

2017-11-21 Thread Joshua Griffith
ything special for the akka configurations. From: Joshua Griffith [mailto:jgriff...@campuslabs.com] Sent: Thursday, November 16, 2017 2:57 PM To: Chan, Regina [Tech] Cc: user@flink.apache.org<mailto:user@flink.apache.org> Subject: Re: Job Manager Configuration I have an IO-dominated batch

RE: Job Manager Configuration

2017-11-18 Thread Chan, Regina
To: Chan, Regina [Tech] Cc: user@flink.apache.org Subject: Re: Job Manager Configuration I have an IO-dominated batch job with 471 distinct tasks (3786 tasks with parallelism) running on 8 nodes with 12 GiB of memory and 4 CPUs each. I haven’t had any problems adding additional tasks except for 1

Re: Job Manager Configuration

2017-11-16 Thread Joshua Griffith
.apache.org<mailto:user@flink.apache.org>' Subject: Job Manager Configuration Flink Users, I have about 300 parallel flows in one job each with 2 inputs, 3 operators, and 1 sink which makes for a large job. I keep getting the below timeout exception but I’ve already set it to a 30 minu

Re: Job Manager Configuration

2017-11-09 Thread Till Rohrmann
; across the TaskManagers. > > > > I’ll get you the logs shortly. > > > > *From:* Till Rohrmann [mailto:trohrm...@apache.org] > *Sent:* Wednesday, November 08, 2017 10:17 AM > *To:* Chan, Regina [Tech] > *Cc:* Chesnay Schepler; user@flink.apache.org > > *Subjec

RE: Job Manager Configuration

2017-11-08 Thread Chan, Regina
euing up and running when it has the resources to. From: Chesnay Schepler [mailto:ches...@apache.org<mailto:ches...@apache.org>] Sent: Wednesday, November 01, 2017 7:09 AM To: user@flink.apache.org<mailto:user@flink.apache.org> Subject: Re: Job Manager Configuration AFAIK there is no t

Re: Job Manager Configuration

2017-11-08 Thread Till Rohrmann
? I only gave it 10 >> TaskManagers with 2 slots. I’m perfectly fine with it queuing up and >> running when it has the resources to. >> >> >> >> >> >> >> >> *From:* Chesnay Schepler [mailto:ches...@apache.org] >> *Sent:* Wednesday, November 01,

Re: Job Manager Configuration

2017-11-07 Thread Till Rohrmann
ve it 10 > TaskManagers with 2 slots. I’m perfectly fine with it queuing up and > running when it has the resources to. > > > > > > > > *From:* Chesnay Schepler [mailto:ches...@apache.org] > *Sent:* Wednesday, November 01, 2017 7:09 AM > *To:* user@flink.apache.o

RE: Job Manager Configuration

2017-11-02 Thread Chan, Regina
e.org Subject: Re: Job Manager Configuration AFAIK there is no theoretical limit on the size of the plan, it just depends on the available resources. The job submissions times out since it takes too long to deploy all the operators that the job defines. With 300 flows, each with 6 operators y

RE: Job Manager Configuration

2017-11-02 Thread Newport, Billy
The user code for all the flows is common though so is there an inefficiency here in terms of copying this code for every operator? From: Chesnay Schepler [mailto:ches...@apache.org] Sent: Wednesday, November 01, 2017 7:09 AM To: user@flink.apache.org Subject: Re: Job Manager Configuration

Re: Job Manager Configuration

2017-11-01 Thread Chesnay Schepler
egina *From:*Chan, Regina [Tech] *Sent:* Monday, October 30, 2017 3:22 PM *To:* 'user@flink.apache.org' *Subject:* Job Manager Configuration Flink Users, I have about 300 parallel flows in one job each with 2 inputs, 3 operators, and 1 sink which makes for a large job. I keep getting the

RE: Job Manager Configuration

2017-10-31 Thread Chan, Regina
From: Chan, Regina [Tech] Sent: Monday, October 30, 2017 3:22 PM To: 'user@flink.apache.org' Subject: Job Manager Configuration Flink Users, I have about 300 parallel flows in one job each with 2 inputs, 3 operators, and 1 sink which makes for a large job. I keep getting the below timeout

Job Manager Configuration

2017-10-30 Thread Chan, Regina
Flink Users, I have about 300 parallel flows in one job each with 2 inputs, 3 operators, and 1 sink which makes for a large job. I keep getting the below timeout exception but I've already set it to a 30 minute time out with a 6GB heap on the JobManager? Is there a heuristic to better configure