Proposal - Change shard discovery in Flink Kinesis Connector to use ListShards

Based on the discussion at here , I want to propose using the latest ListShards API instead of the DescribeStreams on AWS to overcome the rate limits currently imposed on

[jira] [Created] (FLINK-8817) Decrement numPendingContainerRequests only when request container successfully

Sihua Zhou created FLINK-8817: - Summary: Decrement numPendingContainerRequests only when request container successfully Key: FLINK-8817 URL: https://issues.apache.org/jira/browse/FLINK-8817 Project:

[VOTE] Release 1.4.2, release candidate #2

Hi everyone,  Please review and vote on release candidate #2 for Flink 1.4.2, as follows:   [ ] +1, Approve the release   [ ] -1, Do not approve the release (please provide specific comments)  The complete staging area is available for your review, which includes:   * JIRA release notes [1],   *

[jira] [Created] (FLINK-8815) EventTime won't work as reduce

benwang li created FLINK-8815: - Summary: EventTime won't work as reduce Key: FLINK-8815 URL: https://issues.apache.org/jira/browse/FLINK-8815 Project: Flink Issue Type: Bug Components:

Re: [DISCUS] Flink SQL Client dependency management

Hi Timo, Thanks for the initiating the SQL client effort. I agree with Xingcan's points, adding to it (1) most of the user for SQL client would very likely to have little Maven / build tool knowledge and (2) most likely the build script would grow much complex in the future that makes it

[jira] [Created] (FLINK-8814) Control over the extension of part files created by BucketingSink

Jelmer Kuperus created FLINK-8814: - Summary: Control over the extension of part files created by BucketingSink Key: FLINK-8814 URL: https://issues.apache.org/jira/browse/FLINK-8814 Project: Flink

[jira] [Created] (FLINK-8813) AutoParallellismITCase fails with Flip6

Chesnay Schepler created FLINK-8813: --- Summary: AutoParallellismITCase fails with Flip6 Key: FLINK-8813 URL: https://issues.apache.org/jira/browse/FLINK-8813 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8812) Possible resource leak in Flip6

Chesnay Schepler created FLINK-8812: --- Summary: Possible resource leak in Flip6 Key: FLINK-8812 URL: https://issues.apache.org/jira/browse/FLINK-8812 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8811) Add MiniClusterClient to allow fast MiniCluster operations

Till Rohrmann created FLINK-8811: Summary: Add MiniClusterClient to allow fast MiniCluster operations Key: FLINK-8811 URL: https://issues.apache.org/jira/browse/FLINK-8811 Project: Flink

[jira] [Created] (FLINK-8810) Move end-to-end test scripts to end-to-end module

Aljoscha Krettek created FLINK-8810: --- Summary: Move end-to-end test scripts to end-to-end module Key: FLINK-8810 URL: https://issues.apache.org/jira/browse/FLINK-8810 Project: Flink Issue

[jira] [Created] (FLINK-8809) Decrease maximum value of DirectMemory

Kirill A. Korinskiy created FLINK-8809: -- Summary: Decrease maximum value of DirectMemory Key: FLINK-8809 URL: https://issues.apache.org/jira/browse/FLINK-8809 Project: Flink Issue Type:

[jira] [Created] (FLINK-8808) Enable RestClusterClient to submit jobs to local Dispatchers

Till Rohrmann created FLINK-8808: Summary: Enable RestClusterClient to submit jobs to local Dispatchers Key: FLINK-8808 URL: https://issues.apache.org/jira/browse/FLINK-8808 Project: Flink

Re: [VOTE] Release 1.4.2, release candidate #2

I agree. It also seems like we are likely to have FLINK-8451 merged now. I'll open a new RC to include FLINK-8451 and FLINK-8798. 不含病毒。www.avast.com

[jira] [Created] (FLINK-8807) ZookeeperCompleted checkpoint store can get stuck in infinite loop

Aljoscha Krettek created FLINK-8807: --- Summary: ZookeeperCompleted checkpoint store can get stuck in infinite loop Key: FLINK-8807 URL: https://issues.apache.org/jira/browse/FLINK-8807 Project:

[jira] [Created] (FLINK-8806) Failure in UnionInputGate getNextBufferOrEvent()

Stephan Ewen created FLINK-8806: --- Summary: Failure in UnionInputGate getNextBufferOrEvent() Key: FLINK-8806 URL: https://issues.apache.org/jira/browse/FLINK-8806 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8805) Optimize EventSerializer.isEvent method

Piotr Nowojski created FLINK-8805: - Summary: Optimize EventSerializer.isEvent method Key: FLINK-8805 URL: https://issues.apache.org/jira/browse/FLINK-8805 Project: Flink Issue Type:

[jira] [Created] (FLINK-8804) Bump flink-shaded dependency to 3.0

Chesnay Schepler created FLINK-8804: --- Summary: Bump flink-shaded dependency to 3.0 Key: FLINK-8804 URL: https://issues.apache.org/jira/browse/FLINK-8804 Project: Flink Issue Type:

[jira] [Created] (FLINK-8803) Mini Cluster Shutdown with HA unstable, causing test failures

Stephan Ewen created FLINK-8803: --- Summary: Mini Cluster Shutdown with HA unstable, causing test failures Key: FLINK-8803 URL: https://issues.apache.org/jira/browse/FLINK-8803 Project: Flink

[jira] [Created] (FLINK-8802) Concurrent serialization without duplicating serializers in state server.

Kostas Kloudas created FLINK-8802: - Summary: Concurrent serialization without duplicating serializers in state server. Key: FLINK-8802 URL: https://issues.apache.org/jira/browse/FLINK-8802 Project:

[RESULT][VOTE] Release flink-shaded 3.0, release candidate #2

The vote time (+ 3-4 days) has passed. We have collected 3 +1 votes (all binding) and no 0 or -1 votes. +1 votes: - Aljoscha - Timo - Chesnay As such RC2 will be released as flink-shaded 3.0. On 28.02.2018 10:12, Timo Walther wrote: +1 I verified the included commits. The changes look good

Re: [VOTE] Release flink-shaded 3.0, release candidate #2

+1 I verified the included commits. The changes look good to me. Am 2/20/18 um 4:32 PM schrieb Aljoscha Krettek: +1 - verified hashes and signatures - verified that we didn't add dependencies with incompatible licenses On 19. Feb 2018, at 14:40, Chesnay Schepler