[jira] [Created] (FLINK-8075) Redundant clone() in Configuration ctor

Ted Yu created FLINK-8075: - Summary: Redundant clone() in Configuration ctor Key: FLINK-8075 URL: https://issues.apache.org/jira/browse/FLINK-8075 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8076) Upgrade KinesisProducer to 0.10.6 to set properties approperiately

Bowen Li created FLINK-8076: --- Summary: Upgrade KinesisProducer to 0.10.6 to set properties approperiately Key: FLINK-8076 URL: https://issues.apache.org/jira/browse/FLINK-8076 Project: Flink

[jira] [Created] (FLINK-8071) Akka shading sometimes produces invalid code

Chesnay Schepler created FLINK-8071: --- Summary: Akka shading sometimes produces invalid code Key: FLINK-8071 URL: https://issues.apache.org/jira/browse/FLINK-8071 Project: Flink Issue Type:

Re: Submitting jobs via maven coordinates?

Hi Ron, as far as I know, nobody has really accomplished that. It is an interesting idea and I would suggest to file a JIRA for it. Would it be enough to add support for arbitrary URLs (flink script) when submitting a job to Flink? Alternatively I think a wrapper script could do the trick but I'm

Re: Submitting jobs via maven coordinates?

I have seen no official script but what you describe should be easily down with a build tool such as Gradle. The advantage would be that a build tool is already tested and you do not have to maintain scripts for downloading etc. > On 14. Nov 2017, at 07:46, Ron Crocker

[jira] [Created] (FLINK-8067) User code ClassLoader not set before calling ProcessingTimeCallback

Gary Yao created FLINK-8067: --- Summary: User code ClassLoader not set before calling ProcessingTimeCallback Key: FLINK-8067 URL: https://issues.apache.org/jira/browse/FLINK-8067 Project: Flink

[jira] [Created] (FLINK-8068) Failed single-job Flink cluster on YARN shows as SUCCEEDED

Nico Kruber created FLINK-8068: -- Summary: Failed single-job Flink cluster on YARN shows as SUCCEEDED Key: FLINK-8068 URL: https://issues.apache.org/jira/browse/FLINK-8068 Project: Flink Issue

Re: The right approach to store intermediate value

Hi, You should use the State API [1] for this if you want your program to be fault-tolerant. Flink will checkpoint state and make sure that it is restored in case of failures. [1] https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/stream/state/state.html

[jira] [Created] (FLINK-8069) Support empty watermark strategy for TableSources

Timo Walther created FLINK-8069: --- Summary: Support empty watermark strategy for TableSources Key: FLINK-8069 URL: https://issues.apache.org/jira/browse/FLINK-8069 Project: Flink Issue Type:

[jira] [Created] (FLINK-8070) YarnTestBase should print prohibited string

Chesnay Schepler created FLINK-8070: --- Summary: YarnTestBase should print prohibited string Key: FLINK-8070 URL: https://issues.apache.org/jira/browse/FLINK-8070 Project: Flink Issue Type:

[jira] [Created] (FLINK-8072) Travis job mark as failed for no apparent reason

Chesnay Schepler created FLINK-8072: --- Summary: Travis job mark as failed for no apparent reason Key: FLINK-8072 URL: https://issues.apache.org/jira/browse/FLINK-8072 Project: Flink Issue

Re: Submitting jobs via maven coordinates?

I'll file the Jira and I might take a try at it as well. Ron On Tue, Nov 14, 2017 at 1:03 AM Jörn Franke wrote: > I have seen no official script but what you describe should be easily down > with a build tool such as Gradle. The advantage would be that a build tool > is

[jira] [Created] (FLINK-8073) Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint()

Kostas Kloudas created FLINK-8073: - Summary: Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint() Key: FLINK-8073 URL: https://issues.apache.org/jira/browse/FLINK-8073

[jira] [Created] (FLINK-8074) Launch Flink jobs using Maven coordinates

Ron Crocker created FLINK-8074: -- Summary: Launch Flink jobs using Maven coordinates Key: FLINK-8074 URL: https://issues.apache.org/jira/browse/FLINK-8074 Project: Flink Issue Type: Improvement

Re: Submitting jobs via maven coordinates?

https://issues.apache.org/jira/browse/FLINK-8074 Ron — Ron Crocker Principal Engineer & Architect ( ( •)) New Relic rcroc...@newrelic.com M: +1 630 363 8835 > On Nov 14, 2017, at 9:00 AM, Ron Crocker wrote: > > I'll