Re: Correct way to reference Hadoop dependencies in Flink 1.4.0

Hi, You probably need to set core-site.xml and set the Hadoop conf path in flink-conf.yaml core-site.xml: fs.s3.impl org.apache.hadoop.fs.s3a.S3AFileSystem fs.s3.buffer.dir /tmp I’ve had similar issue when I tried to upgrade to Flink 1.4.2 . On Thu, Mar 15, 2018 at 9:39 AM Aljoscha

Re: Flip 6 mesos support

Hi Shuyi, best if you look at the other e2e tests in the flink-end-to-end-tests module. For example the Kafka e2e test under flink/flink-end-to-end-tests/test-scripts/test_streaming_kafka010.sh. Cheers, Till On Fri, Mar 16, 2018 at 10:20 PM, Shuyi Chen wrote: > Hi Till, > > For FLINK-8562, the

[jira] [Created] (FLINK-9016) Unregister jobs from JobMetricGroup after termination

Till Rohrmann created FLINK-9016: Summary: Unregister jobs from JobMetricGroup after termination Key: FLINK-9016 URL: https://issues.apache.org/jira/browse/FLINK-9016 Project: Flink Issue Typ