dev  

Messages by Thread

• [jira] [Created] (FLINK-38394) Upgrade Flink CDC to Flink 2 Mohsen Rezaei (Jira)
• [jira] [Created] (FLINK-38393) Pipeline transform schema consistency check should be loosen for unreachable rules Xiqian Yu (Jira)
• [DISCUSS] Regression in V2 Sink for Flink 1.19.3 / Flink 1.20.2 Maximilian Michels
  • Re: [DISCUSS] Regression in V2 Sink for Flink 1.19.3 / Flink 1.20.2 Maximilian Michels
  • Re: [DISCUSS] Regression in V2 Sink for Flink 1.19.3 / Flink 1.20.2 Maximilian Michels
• [jira] [Created] (FLINK-38378) Use ValidationException in CatalogManager in case of user error Sergey Nuyanzin (Jira)
• [VOTE] Apache Flink CDC Release 3.5.0, release candidate #1 Yanquan Lv
  • RE: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #1 wulin
  • Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #1 Yanquan Lv
• [jira] [Created] (FLINK-38392) StreamPandasConversionTests failing Samrat Deb (Jira)
• [jira] [Created] (FLINK-38391) Error creating shaded jar: Problem shading JAR Unsupported class file major version 69 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38390) Compiliation of flink-core and flink-table-planner fails because of annotation processors Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38389) Add .show(), .head() and .tail() method to PyFlink Table API Zander Matheson (Jira)
• [jira] [Created] (FLINK-38388) FLIP-541 Umbrella Issue Zander Matheson (Jira)
• [jira] [Created] (FLINK-38379) Adjust visitMultiJoin in RelTimeIndicatorConverter to use fields and not rows Gustavo de Morais (Jira)
• [VOTE] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Ramin Gharib
  • Re: [VOTE] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Hao Li
  • Re: [VOTE] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Ramin Gharib
  • Re: [VOTE] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Arvid Heise
  • Re: [VOTE] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Mate Czagany
  • Re: [VOTE] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Yuepeng Pan
  • RE: [VOTE] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables David Radley
  • Re: [VOTE] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Jacky Lau
  • Re: [VOTE] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Sergey Nuyanzin
  • Re: [VOTE] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Timo Walther
  • Re: [VOTE] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Ron Liu
  • Re: [VOTE] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Lincoln Lee
• [jira] [Created] (FLINK-38382) Confluent Schema Registry to support primitive types nicolas paris (Jira)
• [jira] [Created] (FLINK-38387) Bump spotless Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38385) Bump byte-buddy to 1.17.6 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38386) Cannot attach type annotations @org.checkerframework.checker.nullness.qual.Nullable Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38376) AsyncStateStreamingJoinOperator should not OOM due to collecting all matching records in memory Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38380) MySQL cdc may skip data in the GTID disordered scenario even after GTID merged Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38384) Bump lombok to 1.18.40 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38383) Automatically republish Flink Kubernetes Operator image when base image receives security patches Jaydeep Karia (Jira)
• [jira] [Created] (FLINK-38381) Autoscaler does not enumerate partitions across kafka clusters Maximilian Michels (Jira)
• [VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Maximilian Michels
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Maximilian Michels
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Mate Czagany
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Gabor Somogyi
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Maximilian Michels
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Márton Balassi
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.13.0, release candidate #1 Ferenc Csaky
• [DISCUSS] Release Flink CDC version 3.5.0 Yanquan Lv
  • Re: [DISCUSS] Release Flink CDC version 3.5.0 Leonard Xu
  • Re:Re: [DISCUSS] Release Flink CDC version 3.5.0 欧阳武林
  • Re: [DISCUSS] Release Flink CDC version 3.5.0 Xiqian YU
• [jira] [Created] (FLINK-38377) SQL Job Submission in the Flink Kubernetes Operator via SQL Gateway yuanfenghu (Jira)
• [jira] [Created] (FLINK-38368) Potential Feedback Loop Involving a Heavy User Defined Aggregation Task Shangshu Qian (Jira)
• [jira] [Created] (FLINK-38375) Flink Resouce leak on Flink k8s xiaolong3817 (Jira)
• Flink Pulsar connector abandoned Fabrizzio Chávez Tejada
  • Re: Flink Pulsar connector abandoned Martijn Visser
  • Re: Flink Pulsar connector abandoned Ferenc Csaky
• [jira] [Created] (FLINK-38332) Upgrade pemja to 0.6.1 Xuannan Su (Jira)
• [jira] [Created] (FLINK-38374) Add Artifact keyword as an option to create function syntax Zander Matheson (Jira)
• [jira] [Created] (FLINK-38338) Introduce the abstraction to describe a rescale event. RocMarshal (Jira)
• [jira] [Created] (FLINK-38335) SplitEnumeratorContext supports fixed delay async call. Hongshun Wang (Jira)
• [DISCUSS] Build and distribute flink-shaded-netty-tcnative-static Mate Czagany
  • Re: [DISCUSS] Build and distribute flink-shaded-netty-tcnative-static Ferenc Csaky
• [jira] [Created] (FLINK-38370) CommitterOperator does not checkpoint all pending committables Maximilian Michels (Jira)
• [jira] [Created] (FLINK-38373) Support dynamic index generation with field value suffix Liu (Jira)
• [jira] [Created] (FLINK-38372) Introduces whitelist to the flink-metrics-prometheus Liu (Jira)
• [jira] [Created] (FLINK-38371) Add `sink.retry-on-conflicts` option to Elasticsearch Sink Liu (Jira)
• [SUMMARY] Flink 2.2 Release Sync 09/17/2025 Hang Ruan
• [jira] [Created] (FLINK-38369) RestClientTest failed in test_cron_hadoop313 core Ruan Hang (Jira)
• [jira] [Created] (FLINK-38367) Potential Feedback Loop Between IterationHeadTask and SynchronizationSinkTask Shangshu Qian (Jira)
• [jira] [Created] (FLINK-38364) Converter from `ProcessingTimeoutTrigger` with any nested timer to the async version Zakelly Lan (Jira)
• [jira] [Created] (FLINK-38365) ClassCastException while different operations with MATERIALIZED TABLE Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38363) WindowedStream.trigger supports trigger with async state Zakelly Lan (Jira)
• [jira] [Created] (FLINK-38362) Reduce the time cost in checkpoint when writing many tables to StarRocks sink Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38361) ChangelogRecoverySwitchStateBackendITCase failed in test_ci tests Ruan Hang (Jira)
• [jira] [Created] (FLINK-38360) HadoopRecoverableWriterTest failed in test_cron_adaptive_scheduler connect Ruan Hang (Jira)
• [jira] [Created] (FLINK-38359) Avoid writing Record with update before/delete rowKind to Paimon append only table. Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38358) Ignore trailing spaces in table capturing rules Yanquan Lv (Jira)
• [VOTE] FLIP-544 SinkUpsertMaterializer V2 Roman Khachatryan
  • Re: [VOTE] FLIP-544 SinkUpsertMaterializer V2 Rui Fan
  • Re: [VOTE] FLIP-544 SinkUpsertMaterializer V2 Efrat Levitan
  • Re: [VOTE] FLIP-544 SinkUpsertMaterializer V2 Lincoln Lee
  • Re: [VOTE] FLIP-544 SinkUpsertMaterializer V2 Martijn Visser
  • Re: [VOTE] FLIP-544 SinkUpsertMaterializer V2 Ramin Gharib
  • Re: [VOTE] FLIP-544 SinkUpsertMaterializer V2 Zakelly Lan
  • Re: [VOTE] FLIP-544 SinkUpsertMaterializer V2 Ferenc Csaky
  • Re: [VOTE] FLIP-544 SinkUpsertMaterializer V2 Piotr Nowojski
  • Re: [VOTE] FLIP-544 SinkUpsertMaterializer V2 Roman Khachatryan
• [jira] [Created] (FLINK-38357) ResultSubpartitionRecoveredStateHandler.getSubpartition ArrayIndexOutOfBoundException 0 Xinglong Wang (Jira)
• Flink Kubernetes operator 1.13.0 release planning Gyula Fóra
  • Re: Flink Kubernetes operator 1.13.0 release planning Ferenc Csaky
  • Re: Flink Kubernetes operator 1.13.0 release planning Gyula Fóra
  • Re: Flink Kubernetes operator 1.13.0 release planning Ryan van Huuksloot
• [jira] [Created] (FLINK-38356) Regenerating files for WATERMARK_ASSIGNER_PUSHDOWN_METADATA hangs Dawid Wysakowicz (Jira)
• [RESULT][VOTE] FLIP-546: Introduce CREATE OR ALTER for Materialized Tables Ramin Gharib
• [jira] [Created] (FLINK-38355) [FLIP-546] Introduce CREATE OR ALTER Syntax for Materialized Tables Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38354) ClassCastException occurs when submitting a task to flink cdc hunter (Jira)
• [jira] [Created] (FLINK-38353) FLIP-483: Add support for children Spans Piotr Nowojski (Jira)
• [DISCUSS] FLIP-548: Introduce Tool and Agent in Flink SQL Hao Li
• [jira] [Created] (FLINK-38352) Expose timestamp used in DefaultWatermarkGenerator Timo Walther (Jira)
• [DISCUSSION] use https://dlcdn.apache.org/ instead of https://archive.apache.org Etienne Chauchot
  • Re: [DISCUSSION] use https://dlcdn.apache.org/ instead of https://archive.apache.org Leonard Xu
  • Re: [DISCUSSION] use https://dlcdn.apache.org/ instead of https://archive.apache.org Poorvank Bhatia
  • Re: [DISCUSSION] use https://dlcdn.apache.org/ instead of https://archive.apache.org Etienne Chauchot
• [jira] [Created] (FLINK-38351) Docker images support OpenJDK melin (Jira)
• [jira] [Created] (FLINK-38336) Unexpected data copy during failover for ForSt statebackend Zakelly Lan (Jira)
• [RESULT][VOTE] FLIP-495: Support AdaptiveScheduler record and query the rescale history Yuepeng Pan
• 2025/09/11 CHI Eastern time zone workgroup meeting minutes David Radley
• [jira] [Created] (FLINK-38340) Introduce the rescale timeline related abstraction for performing rescale operations RocMarshal (Jira)
• [jira] [Created] (FLINK-38350) Update Hadoop Library to 3.4.2 Paul Ashley (Jira)
• [jira] [Created] (FLINK-38349) Bugs caused by floating-point operations Huny (Jira)
• [DISCUSS] Pipeline Testing Framework for Flink Jobs Poorvank Bhatia
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Őrhidi Mátyás
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Samrat Deb
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Poorvank Bhatia
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Etienne Chauchot
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Gustavo de Morais
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Poorvank Bhatia
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Poorvank Bhatia
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Gyula Fora
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Ferenc Csaky
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Poorvank Bhatia
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Ferenc Csaky
  • Re: [DISCUSS] Pipeline Testing Framework for Flink Jobs Poorvank Bhatia
• [DISCUSS] FLIP-547: Support checkpoint during recovery Rui Fan
  • Re: [DISCUSS] FLIP-547: Support checkpoint during recovery Gabor Somogyi
  • Re: [DISCUSS] FLIP-547: Support checkpoint during recovery Roman Khachatryan
  • Re: [DISCUSS] FLIP-547: Support checkpoint during recovery Rui Fan
  • Re: [DISCUSS] FLIP-547: Support checkpoint during recovery Gabor Somogyi
  • Re: [DISCUSS] FLIP-547: Support checkpoint during recovery Zakelly Lan
  • Re: [DISCUSS] FLIP-547: Support checkpoint during recovery Rui Fan
  • Re: [DISCUSS] FLIP-547: Support checkpoint during recovery Piotr Nowojski
• [jira] [Created] (FLINK-38348) Fix flushing issue for append write with buffer sort and bounded source Shuo Cheng (Jira)
• [jira] [Created] (FLINK-38347) Checkpoint file-merging manager may delete the directory unexpectedly when some RPC messages lost Zakelly Lan (Jira)
• [jira] [Created] (FLINK-38346) JSON_QUERY returns ARRAY<STRING> dylanhz (Jira)
• [DISCUSS] Flink 1.20.3 release Xuannan Su
  • Re: [DISCUSS] Flink 1.20.3 release Gabor Somogyi
  • Re: [DISCUSS] Flink 1.20.3 release Zakelly Lan
  • Re: [DISCUSS] Flink 1.20.3 release Xintong Song
  • Re: [DISCUSS] Flink 1.20.3 release Ferenc Csaky
  • Re: [DISCUSS] Flink 1.20.3 release Zakelly Lan
  • Re: [DISCUSS] Flink 1.20.3 release Maximilian Michels
  • Re: [DISCUSS] Flink 1.20.3 release Yuepeng Pan
  • Re: [DISCUSS] Flink 1.20.3 release Martijn Visser
  • Re: [DISCUSS] Flink 1.20.3 release Xuannan Su
  • Re: [DISCUSS] Flink 1.20.3 release Yuepeng Pan
  • Re: [DISCUSS] Flink 1.20.3 release Maximilian Michels
  • Re: [DISCUSS] Flink 1.20.3 release Martijn Visser
• [jira] [Created] (FLINK-38345) HybridSource checkpoint recovery results in NPE if addSource depends on previousEnumerator from SourceSwitchContext Matt Cuento (Jira)
• [jira] [Created] (FLINK-38343) Support store rescale history by ExecutionGraphInfoStore and query the rescale history with statistics. RocMarshal (Jira)
• [jira] [Created] (FLINK-38342) Support record rescale information RocMarshal (Jira)
• [jira] [Created] (FLINK-38339) Adjust the statistics-related classes for reusing in the statistical calculations of the rescale history RocMarshal (Jira)
• [jira] [Created] (FLINK-38337) Chinese translation for document PR Scott Fauerbach (Jira)
• Flink Kubernetes Operator: New release with Flink 2.1 support Tom Cooper
  • Re: Flink Kubernetes Operator: New release with Flink 2.1 support Gyula Fóra
• SplitEnumeratorContext supports fixed delay async call. Hongshun Wang
  • Re: SplitEnumeratorContext supports fixed delay async call. Leonard Xu
• [jira] [Created] (FLINK-38334) MySQL CDC source may get stuck in the INITIAL_ASSIGNING state Sergei Morozov (Jira)
• [jira] [Created] (FLINK-38333) UMBRELLA: FLIP-495: Support AdaptiveScheduler record and query the rescale history RocMarshal (Jira)
• [jira] [Created] (FLINK-38331) Support displaying the hash keys on edges in web ui yisha zhou (Jira)
• Subject: Feature Request: Support for Resetting Progress of a Specific Table in YAML-based CDC L W
• [jira] [Created] (FLINK-38318) Add python autoformatter to pyflink Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38329) Add labels to PRs showing the targeted version david radley (Jira)
• [jira] [Created] (FLINK-38327) NPE during recovery from file-merged checkpoint after FO Zakelly Lan (Jira)
• Flip-532 initial contribution for flink http connector. David Radley
• [jira] [Created] (FLINK-38330) Updating state-size in status increases the number of 409's to K8s vikasap (Jira)
• [jira] [Created] (FLINK-38328) Community review acting strangely messages in PRs should adding and removing labels david radley (Jira)
• 2025/09/04 CHI Western time zone workgroup meeting minutes David Radley
• [jira] [Created] (FLINK-38326) Kubernetes support oAuthToken authentication melin (Jira)
• [jira] [Created] (FLINK-38322) Update to Kafka Client 4.1.0 Thomas Cooper (Jira)
• [jira] [Created] (FLINK-38321) Optimize the timer registration logic n window early/late firing scenarios Jacky Lau (Jira)
• [jira] [Created] (FLINK-38325) Checkpoints are hanging and timing out frequently Lucas Borges (Jira)
• [jira] [Created] (FLINK-38324) Job fails to restore keyed state backend when using Forst state backend on S3 Lucas Borges (Jira)
• [jira] [Created] (FLINK-38323) Global Scale Factor Mode Salva (Jira)
• [RESULT][VOTE] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Yuepeng Pan
• [jira] [Created] (FLINK-38320) Upgrade Pekko to 1.2.0 Mate Czagany (Jira)
• [jira] [Created] (FLINK-38319) TO_TIMESTAMP_LTZ only accepts literal values in PyFlink Dian Fu (Jira)
• [RESULT][VOTE] FLIP-535: Introduce RateLimiter to Source Yanquan Lv
• [jira] [Created] (FLINK-38317) PushCalcPastChangelogNormalizeRule fails in case of partial push down and trimmed fields Sergey Nuyanzin (Jira)
• Slack Invitation Expired Arnav Kulkarni
  • Re: Slack Invitation Expired Natea Eshetu Beshada
• [jira] [Created] (FLINK-38316) Clarify on some of the names in the source Marton Greber (Jira)
• [SUMMARY] Flink 2.2 Release Sync 09/03/2025 Hang Ruan
• [jira] [Created] (FLINK-38315) Performance regression since August 21 Ruan Hang (Jira)
• [jira] [Created] (FLINK-38309) Add Basic Authentication Support to OpenTelemetry HTTP Metrics Reporter Kumar Mallikarjuna (Jira)
• Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Matthias Pohl
  • Re: [DISCUSS] FLIP-487: Show history of rescales in Web UI for AdaptiveScheduler Yuepeng Pan
• [jira] [Created] (FLINK-38312) Add support for SHOW CREATE MATERIALIZED TABLES Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38310) Binary keys in a FinishedSnapshotSplitInfo are incorrectly compared and hashed Sergei Morozov (Jira)
• [RESULT][VOTE] FLIP-542: Make materialized table DDL consistent with regular tables Sergey Nuyanzin
• [jira] [Created] (FLINK-38314) Flink dashboard incorrectly shows units for RocksDB `live-sst-files-size` metric for timer state Aleksandr Iushmanov (Jira)
• [jira] [Created] (FLINK-38313) Add support for DISTRIBUTION in MATERIALIZED TABLES Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38311) FLIP-542: Make materialized table DDL consistent with regular tables Sergey Nuyanzin (Jira)
• [Discuss] Pre/Post Scaling Hooks during Autoscaling Diljeet Singh
• Re: [VOTE] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Becket Qin
  • Re: [VOTE] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Wei Zhong
  • Re: [VOTE] FLIP-490: Enhanced Job History Retention Policies for HistoryServer Rui Fan

• Earlier messages
• Later messages