取消订阅

取消订阅

[jira] [Created] (FLINK-30691) Sql Client supports to specify endpoint address

Shengkai Fang created FLINK-30691: - Summary: Sql Client supports to specify endpoint address Key: FLINK-30691 URL: https://issues.apache.org/jira/browse/FLINK-30691 Project: Flink Issue Type:

[jira] [Created] (FLINK-30692) Introduce embedded session manager to support REMOVE JAR

Shengkai Fang created FLINK-30692: - Summary: Introduce embedded session manager to support REMOVE JAR Key: FLINK-30692 URL: https://issues.apache.org/jira/browse/FLINK-30692 Project: Flink Is

[jira] [Created] (FLINK-30693) Introduce RowFormat to SQL Gateway for result fetching

yuzelin created FLINK-30693: --- Summary: Introduce RowFormat to SQL Gateway for result fetching Key: FLINK-30693 URL: https://issues.apache.org/jira/browse/FLINK-30693 Project: Flink Issue Type: Sub-

Re: [DISCUSS] FLIP-274 : Introduce metric group for OperatorCoordinator

Hi, @ches...@apache.org , Do you have time to help to review this FLIP again after the modification? Looking forward to your reply. This FLIP will add a new configuration for the OperatorCoordinatorMetricGroup scope format. It provides an internal implementation and is added as a component to the

[jira] [Created] (FLINK-30694) Translate "Joins" page of "Querys" into Chinese

chenhaiyang created FLINK-30694: --- Summary: Translate "Joins" page of "Querys" into Chinese Key: FLINK-30694 URL: https://issues.apache.org/jira/browse/FLINK-30694 Project: Flink Issue Type: Su

Re: [ANNOUNCE] Performance Daily Monitoring Moved from Ververica to Apache Flink Slack Channel

Hi devs, Flink benchmarks are periodically executed on http://codespeed.dak8s.net:8080 to monitor Flink performance. In late Oct'22, a new slack channel #flink-dev-benchmarks was created for notifications of performance regressions. It helped us find 2 build failures[1,2] and 5 performance regress

[Discuss] Checkout the CURRENT_SNAPSHOT_VERSION branch of the flink-benchmarks repo during each major release

Hi all, More than two years ago, we migrated the flink-benchmarks repo under apache project[1]. And we planned to make the flink-benchmarks repo could align with different versions of Flink. However, I somehow forget to make this done finally[2]. Thus, we still cannot build the master branch of

[jira] [Created] (FLINK-30695) Support to set parallelism for compact operator according to the number of files in AQE.

luoyuxia created FLINK-30695: Summary: Support to set parallelism for compact operator according to the number of files in AQE. Key: FLINK-30695 URL: https://issues.apache.org/jira/browse/FLINK-30695 Proj

Re: [DISCUSS] Enabling dynamic partition discovery by default in Kafka source

Thanks for the input Becket! I reorganized this proposal into FLIP-288 [1]. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-288%3A+Enable+Dynamic+Partition+Discovery+by+Default+in+Kafka+Source Best, Qingsheng On Sun, Jan 15, 2023 at 9:18 AM Becket Qin wrote: > Thanks for the propos

Re: [DISCUSS] FLIP-285: Refactoring the leader election code base in Flink

Thanks Matthias for updating the FLIP. Given that we do not touch the dedicated ConfigMap for the checkpoint, this FLIP will not affect the LAST_STATE recovery for the Flink Kubernetes Operator. # LeaderContender#initiateLeaderElection Could we simply execute *leaderElectionService.register(conte