Re: Cannot deploy Flink on YARN

2017-09-25 Thread Emily McMahon
What's in the container log for the container that failed? On Sep 11, 2017 2:17 AM, "Sridhar Chellappa" wrote: I am trying to start Flink(Version 1.3.0) on YARN (Hadoop 2.8.1) by issuing the following command: ~/flink-1.3.0/bin/yarn-session.sh -s 4 -n 10 -jm 4096 -tm 4096-d I am seeing a flurr

Re: Rest API cancel-with-savepoint: 404s when passing path as target-directory

2017-09-19 Thread Emily McMahon
int to s3:///savepoint-bucket/my-awesome-job > > -Eron > > On Tue, Sep 19, 2017 at 1:54 PM, Fabian Hueske wrote: > >> Hi Emily, >> >> thanks for reaching out. >> I'm not familiar with the details of the Rest API but Ufuk (in CC) might >> be able

Rest API cancel-with-savepoint: 404s when passing path as target-directory

2017-09-19 Thread Emily McMahon
I've tried every combination I can think of to pass an s3 path as the target directory (url encode, include trailing slash, etc) I can successfully pass a local path as the target directory (ie /jobs/$jobID/cancel-with-savepoint/target-directory/tmp) so I don't think there's a problem with the job

Default chaining & uid

2017-08-28 Thread Emily McMahon
Does setting uid affect the default chaining (ie if I have two maps in a row and set uid on both)? This makes me think there's no effect All operators that are part of a chain should be assigned an ID as > described in the