[jira] [Created] (FLINK-12784) Support retention policy for InfluxDB metrics reporter

Mans Singh created FLINK-12784: -- Summary: Support retention policy for InfluxDB metrics reporter Key: FLINK-12784 URL: https://issues.apache.org/jira/browse/FLINK-12784 Project: Flink Issue Type

Join to Flink Community

Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is yuetongshu Regards, Jasper Yue

Re: [DISCUSS] Releasing Flink 1.8.1

Hi all, I am here to quickly update the progress of the issue that needs to be tracked(going well): [Blocker] - FLINK-12297 Work by @ Aitozi Being reviewed by @Aljoscha Krettek ! - FLINK-11107

Re: [DISCUSS] FLIP-33: Standardize connector metrics

Hi Piotr, Thanks for the comments. Yes, you are right. Users will have to look at other metrics to decide whether the pipeline is healthy or not in the first place before they can use the time-based metric to fix the bottleneck. I agree that once we have FLIP-27 ready, some of the metrics can jus

I want to contribute to Apache Flink

Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is nanoleak.

[jira] [Created] (FLINK-12785) RocksDB savepoint recovery can use a lot of unmanaged memory

Mike Kaplinskiy created FLINK-12785: --- Summary: RocksDB savepoint recovery can use a lot of unmanaged memory Key: FLINK-12785 URL: https://issues.apache.org/jira/browse/FLINK-12785 Project: Flink

[jira] [Created] (FLINK-12786) Implement local aggregation in Flink

vinoyang created FLINK-12786: Summary: Implement local aggregation in Flink Key: FLINK-12786 URL: https://issues.apache.org/jira/browse/FLINK-12786 Project: Flink Issue Type: New Feature

Re: [DISCUSS] Support Local Aggregation in Flink

Hi all, Thanks for all the feedback and comments. Since the thread of this feature has been presented about one week in the dev mailing list and has got much support from the community, I have created a new JIRA feature issue[1] to track it and I will split subtasks soon. We can move further dis

[jira] [Created] (FLINK-12787) Allow to specify directory in option -pyfs

Dian Fu created FLINK-12787: --- Summary: Allow to specify directory in option -pyfs Key: FLINK-12787 URL: https://issues.apache.org/jira/browse/FLINK-12787 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12788) Add support to run a Python job-specific cluster on Kubernetes

Dian Fu created FLINK-12788: --- Summary: Add support to run a Python job-specific cluster on Kubernetes Key: FLINK-12788 URL: https://issues.apache.org/jira/browse/FLINK-12788 Project: Flink Issue T

[jira] [Created] (FLINK-12789) Fix java docs in UserDefinedAggregateFunction

Hequn Cheng created FLINK-12789: --- Summary: Fix java docs in UserDefinedAggregateFunction Key: FLINK-12789 URL: https://issues.apache.org/jira/browse/FLINK-12789 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12790) Implement KeyScope enum to distinguish LocalKeyBy and general keyBy

vinoyang created FLINK-12790: Summary: Implement KeyScope enum to distinguish LocalKeyBy and general keyBy Key: FLINK-12790 URL: https://issues.apache.org/jira/browse/FLINK-12790 Project: Flink

[jira] [Created] (FLINK-12791) Introduce LocalKeyedStateHandle interface and implement LocalKeyedKeyGroupsStateHandle / LocalKeyedIncrementalKeyedStateHandle

vinoyang created FLINK-12791: Summary: Introduce LocalKeyedStateHandle interface and implement LocalKeyedKeyGroupsStateHandle / LocalKeyedIncrementalKeyedStateHandle Key: FLINK-12791 URL: https://issues.apache.org/jir

[jira] [Created] (FLINK-12792) Support states mergence for local aggregation

vinoyang created FLINK-12792: Summary: Support states mergence for local aggregation Key: FLINK-12792 URL: https://issues.apache.org/jira/browse/FLINK-12792 Project: Flink Issue Type: Sub-task