[jira] [Created] (FLINK-11544) Add option manually set job ID for job submissions via REST API

Ufuk Celebi created FLINK-11544: --- Summary: Add option manually set job ID for job submissions via REST API Key: FLINK-11544 URL: https://issues.apache.org/jira/browse/FLINK-11544 Project: Flink

Re: [VOTE] Release flink-shaded 6.0, release candidate 1

+1, - Checked signature and hashes - Built locally from RC tgz - verified new Netty version working using the maven repo -> https://travis-ci.org/apache/flink/builds/489628017 On 06/02/2019 13:59, Chesnay Schepler wrote: > Hi everyone, > Please review and vote on the release candidate #1 for the

[jira] [Created] (FLINK-11546) Add option to manually set job ID in CLI

Ufuk Celebi created FLINK-11546: --- Summary: Add option to manually set job ID in CLI Key: FLINK-11546 URL: https://issues.apache.org/jira/browse/FLINK-11546 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11545) Add option to manually set job ID in StandaloneJobClusterEntryPoint

Ufuk Celebi created FLINK-11545: --- Summary: Add option to manually set job ID in StandaloneJobClusterEntryPoint Key: FLINK-11545 URL: https://issues.apache.org/jira/browse/FLINK-11545 Project: Flink

[jira] [Created] (FLINK-11547) JsonMappingException in DynamoDBStreamsSchema

Devin Thomson created FLINK-11547: - Summary: JsonMappingException in DynamoDBStreamsSchema Key: FLINK-11547 URL: https://issues.apache.org/jira/browse/FLINK-11547 Project: Flink Issue Type: B

[jira] [Created] (FLINK-11548) Check and port ClusterShutdownITCase to new code base if necessary

Gary Yao created FLINK-11548: Summary: Check and port ClusterShutdownITCase to new code base if necessary Key: FLINK-11548 URL: https://issues.apache.org/jira/browse/FLINK-11548 Project: Flink I

[jira] [Created] (FLINK-11549) Check and port ResourceManagerITCase to new code base if necessary

Gary Yao created FLINK-11549: Summary: Check and port ResourceManagerITCase to new code base if necessary Key: FLINK-11549 URL: https://issues.apache.org/jira/browse/FLINK-11549 Project: Flink I

Re: [DISCUSS] Releasing Flink 1.7.2

+1 to start the release next week, we've accumulated a nice set of changes and it's been more than a month since 1.7.1 came out. On 05.02.2019 16:32, Tzu-Li (Gordon) Tai wrote: Hi Flink devs, What do you think about releasing Flink 1.7.2 soon? We already have some critical fixes in the releas

[jira] [Created] (FLINK-11550) Port ManualExactlyOnceTest

Chesnay Schepler created FLINK-11550: Summary: Port ManualExactlyOnceTest Key: FLINK-11550 URL: https://issues.apache.org/jira/browse/FLINK-11550 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11551) Allow RpcEndpoints to execute asynchronous stop operations

Till Rohrmann created FLINK-11551: - Summary: Allow RpcEndpoints to execute asynchronous stop operations Key: FLINK-11551 URL: https://issues.apache.org/jira/browse/FLINK-11551 Project: Flink

[jira] [Created] (FLINK-11552) Akka association issues in 1.7.x

William Cummings created FLINK-11552: Summary: Akka association issues in 1.7.x Key: FLINK-11552 URL: https://issues.apache.org/jira/browse/FLINK-11552 Project: Flink Issue Type: Bug

Re: Ratelimiting in the Flink Kafka connector

Apologies for the delay in responding here. The idea of making the Ratelimiter config/creation logic generic across connectors makes sense to me. In the approach that we used and tested internally, we essentially created a Guava RateLimiter