dev@flink.apache.org

sunjincheng created FLINK-7464: -- Summary: Add useful build-in Aggregate function into TabalAPI&SQL Key: FLINK-7464 URL: https://issues.apache.org/jira/browse/FLINK-7464 Project: Flink Issue Type

dev@flink.apache.org

sunjincheng created FLINK-7465: -- Summary: Add build-in BloomFilterCount on TableAPI&SQL Key: FLINK-7465 URL: https://issues.apache.org/jira/browse/FLINK-7465 Project: Flink Issue Type: Sub-task

Re: [POLL] Dropping savepoint format compatibility for 1.1.x in the Flink 1.4.0 release

One more comment about the consequences of this PR, as pointed out in the comments on Github: this will also break direct compatibility for the CEP library between Flink 1.2 and 1.4. There is still a way to migrate via Flink 1.3: Flink 1.1/2 -> savepoint -> Flink 1.3 -> savepoint -> Flink 1.4.

Re: Looking for a Mentor

Hey everyone, I am still looking for any chance to have a mentor to help me contribute to flink Regards Sumit On Mon, 14 Aug 2017 at 5:05 PM, Sumit Sarin wrote: > Hi everyone, > My name is Sumit Sarin and I am new to contributing to open source. I > am from India (Time zone : GMT+5:30). I have w

[jira] [Created] (FLINK-7466) Add a flink connector for Apache RocketMQ

yukon created FLINK-7466: Summary: Add a flink connector for Apache RocketMQ Key: FLINK-7466 URL: https://issues.apache.org/jira/browse/FLINK-7466 Project: Flink Issue Type: New Feature R

[jira] [Created] (FLINK-7467) a slow client on the BlobServer may block writing operations

Nico Kruber created FLINK-7467: -- Summary: a slow client on the BlobServer may block writing operations Key: FLINK-7467 URL: https://issues.apache.org/jira/browse/FLINK-7467 Project: Flink Issue

Re: Looking for a Mentor

Hello Sumit, it's great that you want to contribute to Flink! As a first step, please make sure to go through the How to Contribute guide. While it is rather large and dry at times it gives a good overview over the contribution process and guide

Re: [POLL] Dropping savepoint format compatibility for 1.1.x in the Flink 1.4.0 release

There’s an argument for delaying this change to 1.5 since the feature freeze is two weeks away. There is little time to realize benefits from removing this code. "The reason for that is that there is a lot of code mapping between the completely different legacy format (1.1.x, not re-scalable) a

Re: [POLL] Dropping savepoint format compatibility for 1.1.x in the Flink 1.4.0 release

I think we are still doing changes for which this is relevant. Also I cannot really see a benefit in delaying this because the whole discussion will apply in exactly the same way to 1.5. > Am 17.08.2017 um 13:29 schrieb Greg Hogan : > > There’s an argument for delaying this change to 1.5 since

[jira] [Created] (FLINK-7468) Implement Netty sender backlog logic for credit-based

zhijiang created FLINK-7468: --- Summary: Implement Netty sender backlog logic for credit-based Key: FLINK-7468 URL: https://issues.apache.org/jira/browse/FLINK-7468 Project: Flink Issue Type: Sub-tas

Re: [POLL] Dropping savepoint format compatibility for 1.1.x in the Flink 1.4.0 release

@Greg - One benefit I can clearly see is the following: If we keep that old 1.1-style state code, than we want to guarantee its correctness in the face of the changes that have been made (consolidate state code to be per-operator rather than per-task in the runtime as well) and the changes that ar

[jira] [Created] (FLINK-7469) Handle slot requests occuring before RM registration completes

Eron Wright created FLINK-7469: --- Summary: Handle slot requests occuring before RM registration completes Key: FLINK-7469 URL: https://issues.apache.org/jira/browse/FLINK-7469 Project: Flink I

[jira] [Created] (FLINK-7470) Acquire RM leadership before registering with Mesos

Eron Wright created FLINK-7470: --- Summary: Acquire RM leadership before registering with Mesos Key: FLINK-7470 URL: https://issues.apache.org/jira/browse/FLINK-7470 Project: Flink Issue Type: S

[jira] [Created] (FLINK-7471) Improve bounded OVER support non-retract method AGG

sunjincheng created FLINK-7471: -- Summary: Improve bounded OVER support non-retract method AGG Key: FLINK-7471 URL: https://issues.apache.org/jira/browse/FLINK-7471 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-7472) Release task managers gracefully

Eron Wright created FLINK-7472: --- Summary: Release task managers gracefully Key: FLINK-7472 URL: https://issues.apache.org/jira/browse/FLINK-7472 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7473) Possible Leak in GlobalWindows

Steve Jerman created FLINK-7473: --- Summary: Possible Leak in GlobalWindows Key: FLINK-7473 URL: https://issues.apache.org/jira/browse/FLINK-7473 Project: Flink Issue Type: Bug Componen

[jira] [Created] (FLINK-7474) Flink supports consuming data from and sink data to Azure eventhubs

Joe created FLINK-7474: -- Summary: Flink supports consuming data from and sink data to Azure eventhubs Key: FLINK-7474 URL: https://issues.apache.org/jira/browse/FLINK-7474 Project: Flink Issue Type: N

[jira] [Created] (FLINK-7475) ListState support update

yf created FLINK-7475: - Summary: ListState support update Key: FLINK-7475 URL: https://issues.apache.org/jira/browse/FLINK-7475 Project: Flink Issue Type: Improvement Components: Core