dev  

Messages by Thread

• [RESULT][VOTE] Release 2.1.1, release candidate #1 Gabor Somogyi
• [jira] [Created] (FLINK-38576) Align commonJoinKey in MultiJoin for logical and physical rules Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38575) Checkpoint Race Condition in KuduSourceEnumerator Marton Greber (Jira)
• [jira] [Created] (FLINK-38574) Avoid reusing re-uploaded sst files when checkpoint notification is delayed Zakelly Lan (Jira)
• Permission to add FLIP document 柳尘
  • Re: Permission to add FLIP document Ferenc Csaky
  • Re: Permission to add FLIP document 柳尘
  • Re: Permission to add FLIP document Ferenc Csaky
  • Re: Permission to add FLIP document Ferenc Csaky
• [jira] [Created] (FLINK-38573) Add support for array datatype Marton Greber (Jira)
• [jira] [Created] (FLINK-38572) Support controlling randomness and format of Chat Model Function Yunfeng Zhou (Jira)
• [jira] [Created] (FLINK-38571) Index is lost in CTAS and RTAS Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38570) FLIP-554: Pipeline Testing Framework for Flink Poorvank Bhatia (Jira)
• [jira] [Created] (FLINK-38569) ReadingMetadataSpec should not be created if there are no metadataKeys to be read Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38568) Performance bottleneck in BinlogSplitReader with large number of snapshot splits yuanfenghu (Jira)
• [jira] [Created] (FLINK-38567) ForSt state backend error with GROUP BY and async state execution Mohsen Rezaei (Jira)
• [jira] [Created] (FLINK-38566) Support CEP DSL xingyuan cheng (Jira)
• [jira] [Created] (FLINK-38565) Reduce chain of TRY_CAST if source and target types are same Sergey Nuyanzin (Jira)
• [RESULT] [VOTE] FLIP-554: Pipeline Testing Framework For Flink Poorvank Bhatia
• [jira] [Created] (FLINK-38564) FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment. Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38563) Add documentation for async function in Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38562) Support thread mode of async function in Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38561) Add retry support for async function in Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38560) Support ordered mode of async function in Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38559) Support unorder mode of async function in Python DataStream API Dian Fu (Jira)
• [jira] [Created] (FLINK-38558) Checkpoint rescale and restore fails with RocksDB Heap timer Yangze Guo (Jira)
• [jira] [Created] (FLINK-38557) Upgrade Presto to resolve multiple vulnerabilities Avi Sanwal (Jira)
• [jira] [Created] (FLINK-38556) Filter & Project can exists between source and deltajoin Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38555) Optimize performance of `RecordUtils.compareObjects()` method by avoiding unnecessary `toString()` calls for temporal types (LocalDateTime, LocalDate, Instant, etc.). yuanfenghu (Jira)
• [jira] [Created] (FLINK-38554) Adjust FlinkMultiJoin self cost to be more accurate Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38553) Identity casts of ROW types are not detected Timo Walther (Jira)
• [jira] [Created] (FLINK-38552) FlinkStateSnapshot does not work if operator's namespace not in watchNamespaces Maksim Aniskov (Jira)
• [jira] [Created] (FLINK-38551) Extend MultiJoin tests based on current join tests Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38550) Flink CDC source connector for mongodb repeatedly failing in streaming mode with error code 286 Sachin Mittal (Jira)
• [jira] [Created] (FLINK-38549) Support limiting context window size for Model Functions Yunfeng Zhou (Jira)
• [RESULT][VOTE] FLIP-537: Enumerator Maintains Global Splits Distribution for Balanced assignment. Hongshun Wang
• [jira] [Created] (FLINK-38548) Blue/Green Deployments Prem Santosh (Jira)
• [jira] [Created] (FLINK-38547) Upgrade protobuf-java from 3.x to 4.32.1 with compatibility patch for parquet-protobuf Khaled Hammouda (Jira)
• FW: Releasing the Flink HTTP connector David Radley
• Open ai very old dependancy David Radley
  • FW: Open ai very old dependancy David Radley
  • Re: FW: Open ai very old dependancy Shengkai Fang
  • Re: FW: Open ai very old dependancy Shengkai Fang
• [SUMMARY] Flink 2.2 Release Sync 10/22/2025 Hang Ruan
• [jira] [Created] (FLINK-38546) Improve error message for table discovery failure due to MySQL permission JunboWang (Jira)
• [jira] [Created] (FLINK-38545) Update Pulsar connector to Flink 1.20 Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-38544) Filtering record before processing with spilling strategy Rui Fan (Jira)
• [jira] [Created] (FLINK-38543) Change the overall UC restore process, JM and task initialization Rui Fan (Jira)
• [jira] [Created] (FLINK-38542) Recover output buffers of upstream task on downstream task side directly Rui Fan (Jira)
• [jira] [Created] (FLINK-38541) Introducing config option: execution.checkpointing.unaligned.allow-on-recovery Rui Fan (Jira)
• [jira] [Created] (FLINK-38540) Fix potential CME error in TransformExpressionCompiler Xiqian Yu (Jira)
• [RESULT][VOTE] FLIP-549: Support Application Management Yi Zhang
• [jira] [Created] (FLINK-38539) IndexOutOfBoundsException in AbstractSliceSyncStateWindowAggProcessor Robert Metzger (Jira)
• [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Poorvank Bhatia
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Samrat Deb
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink ctrlaltdilj
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Gyula Fora
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Ferenc Csaky
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Őrhidi Mátyás
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Gabor Somogyi
  • RE: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink ctrlaltdilj
  • RE: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink ctrlaltdilj
  • Re: [VOTE] FLIP-554 : Pipeline Testing Framework for Flink Poorvank Bhatia
• [jira] [Created] (FLINK-38538) Flink Autoscaler: Need Option to Autoscale Based Primarily (or Solely) on Busy Metric, Not Output Ratio Varun (Jira)
• [jira] [Created] (FLINK-38537) Fix the bug in StatsSummaryDto#equals method RocMarshal (Jira)
• [jira] [Created] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core Ruan Hang (Jira)
• [jira] [Created] (FLINK-38535) CheckpointIntervalDuringBacklogITCase failed in test_cron_adaptive_scheduler tests Ruan Hang (Jira)
• [jira] [Created] (FLINK-38534) LocalRecoveryTest failed in test_cron_azure core Ruan Hang (Jira)
• [jira] [Created] (FLINK-38533) SqlClientITCase failed for image confluentinc/cp-kafka:7.2.2 startup Ruan Hang (Jira)
• [jira] [Created] (FLINK-38532) FLIP-551: Make FRESHNESS Optional for Materialized Tables Ramin Gharib (Jira)
• [jira] [Created] (FLINK-38531) MySQL CDC BinlogOffset compareTo method cannot work correctly when gtidSet is same sherhomhuang (Jira)
• [jira] [Created] (FLINK-38460) Improve test coverage for SinkUpsertMaterializer Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38459) SinkUpsertMaterializer V2 (FLIP-544) Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38466) Bump derby version to 10.17.1.0 Siddharth R (Jira)
• [jira] [Created] (FLINK-38490) Update japicmp configuration post 1.20.2 Xuannan Su (Jira)
• [jira] [Created] (FLINK-38503) ServiceLoader#hasNext fails with ClassNotFoundException Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38444) Join calculates upsert keys with null keys for left join Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38489) ChangelogNormalize may generate changelog mode without D Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-38410) Log test id on failure for RestoreTestBase and SemanticTestBase suites Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-38515) [flink-avro-confluent-registry] Implement OAuth2 mechanism for the Schema Registry authentication Sonya Parau (Jira)
• [RESULT] [VOTE] Release 1.20.3, release candidate #1 Xuannan Su
• [DISCUSS] FLIP-XXX: Add ARTIFACT keyword option in CREATE FUNCTION's USING JAR clause Zander Matheson
  • Re: [DISCUSS] FLIP-XXX: Add ARTIFACT keyword option in CREATE FUNCTION's USING JAR clause Martijn Visser
  • Re: [DISCUSS] FLIP-XXX: Add ARTIFACT keyword option in CREATE FUNCTION's USING JAR clause Zander Matheson
• [jira] [Created] (FLINK-38461) Introduce SinkUpsertMaterializerV2 Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38491) flink-cdc connector-iceberg compaction parallelism error ChaoFang (Jira)
• [jira] [Created] (FLINK-38456) support hive connector for flink 2.x Jihoon Lee (Jira)
• [jira] [Created] (FLINK-38526) Pemja convert sql ARRAY object to Tuple Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38528) Introduce async vector search operator Shengkai Fang (Jira)
• [VOTE] Release 2.1.1, release candidate #1 Gabor Somogyi
  • Re: [VOTE] Release 2.1.1, release candidate #1 Zakelly Lan
  • Re: [VOTE] Release 2.1.1, release candidate #1 Rui Fan
  • Re: [VOTE] Release 2.1.1, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release 2.1.1, release candidate #1 Han Yin
  • Re: [VOTE] Release 2.1.1, release candidate #1 Leonard Xu
  • Re: [VOTE] Release 2.1.1, release candidate #1 Yuan Mei
  • Re: [VOTE] Release 2.1.1, release candidate #1 Hang Ruan
  • Re: [VOTE] Release 2.1.1, release candidate #1 Hongshun Wang
  • Re: [VOTE] Release 2.1.1, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release 2.1.1, release candidate #1 Gabor Somogyi
• [jira] [Created] (FLINK-38462) Introduce state backend type identifier Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38498) JDBC Connector Data Type Mapping lacks: Mysql Timestamp and Postgres Timestamp_tz Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38435) Refactor codegen and runner for MLPredict and LookupJoin Shengkai Fang (Jira)
• [jira] [Created] (FLINK-38453) KafkaEnumerator doesn't restore offsets of owned split Arvid Heise (Jira)
• [jira] [Created] (FLINK-38501) Tests crashed for Flink Runtime in test_cron_azure core Ruan Hang (Jira)
• [jira] [Created] (FLINK-38502) A number of Hadoop related tests failing with UnsupportedOperationException: getSubject is not supported Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38475) Fix community review CI script Ferenc Csaky (Jira)
• [jira] [Created] (FLINK-38530) create python version of Dynamic Kafka Source Bowen Li (Jira)
• [jira] [Created] (FLINK-38457) Add AWS Glue Catalog Support melin (Jira)
• [jira] [Created] (FLINK-38492) Support Kubernetes Pod Template in SQL Gateway Application Mode Deployment yuanfenghu (Jira)
• [jira] [Created] (FLINK-38521) Update Kubernetes Operator to Java Operator SDK v5.1.4 Jira
• [jira] [Created] (FLINK-38479) Problems after upgrading the operator from 1.12.1 to 1.13.0 fallenup (Jira)
• [DISCUSS] Flink 2.1.1 release Gabor Somogyi
  • Re: [DISCUSS] Flink 2.1.1 release Gyula Fora
  • Re: [DISCUSS] Flink 2.1.1 release Zakelly Lan
  • Re: [DISCUSS] Flink 2.1.1 release Ferenc Csaky
  • Re: [DISCUSS] Flink 2.1.1 release Ron Liu
• [Discussion] JDBC Connector SplitReader pass ResultSet with cursor at the first row clara xiong
• [jira] [Created] (FLINK-38416) Wrong constructor argument order for NestedMapConstraint Ryan Murray (Jira)
• [jira] [Created] (FLINK-38478) There may be a risk of data loss when two jobs write to the same Paimon table concurrently Yanquan Lv (Jira)
• [jira] [Created] (FLINK-38472) can not install apache-flink with python3.13 pemja==0.5.3 cannot be built nicolas debeissat (Jira)
• [jira] [Created] (FLINK-38451) KafkaCommitter logs ERRORs unnecessarily during cancellation Arvid Heise (Jira)
• [jira] [Created] (FLINK-38468) Performance drops when the coalesce parameter includes functions Jie Cheng (Jira)
• [jira] [Created] (FLINK-38424) Support to parse VECTOR_SEARCH table function Shengkai Fang (Jira)
• [SUMMARY] Flink 2.2 Release Sync 10/01/2025 Hang Ruan
• [jira] [Created] (FLINK-38484) community review github action stopped working david radley (Jira)
• [jira] [Created] (FLINK-38500) PyFlink jobs using the thread mode cannot run consecutively on a session cluster on MacOS Biao Geng (Jira)
• [jira] [Created] (FLINK-38519) Custom Message Keys with PyFlink Kafka Sink Sebastian YEPES FERNANDEZ (Jira)
• [VOTE] Release 2.0.1, release candidate #1 Zakelly Lan
  • Re: [VOTE] Release 2.0.1, release candidate #1 Gabor Somogyi
  • Re: [VOTE] Release 2.0.1, release candidate #1 Mate Czagany
  • Re: [VOTE] Release 2.0.1, release candidate #1 Rui Fan
  • Re: [VOTE] Release 2.0.1, release candidate #1 Han Yin
  • Re: [VOTE] Release 2.0.1, release candidate #1 Leonard Xu
  • Re: [VOTE] Release 2.0.1, release candidate #1 Yuan Mei
  • Re: [VOTE] Release 2.0.1, release candidate #1 Hongshun Wang
  • Re: [VOTE] Release 2.0.1, release candidate #1 Hang Ruan
  • Re: [VOTE] Release 2.0.1, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release 2.0.1, release candidate #1 Zakelly Lan
• Request to review FLIP-490 contribution Yuepeng Pan
  • Re: Request to review FLIP-490 contribution Yuepeng Pan
• [jira] [Created] (FLINK-38437) Bump Java Operator SDK version to 5.1.3 in Flink Kubernetes Operator Jira
• [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ramin Gharib
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Lincoln Lee
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Timo Walther
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Ron Liu
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Timo Walther
  • Re: [DISCUSS] FLIP-550: Add similar support for CREATE/ALTER operations for MATERIALIZED TABLEs as for TABLEs Sergey Nuyanzin
• [ANNOUNCE] Apache Flink 1.20.3 released Xuannan Su
• [jira] [Created] (FLINK-38509) Dynamic Credentials in Flink for Google Cloud Storage Royston Tauro (Jira)
• [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Yanquan Lv
  • Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Xiqian YU
  • Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Hongshun Wang
  • Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Leonard Xu
  • Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Ron Liu
  • Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Lincoln Lee
  • Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Yanquan Lv
  • Re: [VOTE] Apache Flink CDC Release 3.5.0, release candidate #3 Yanquan Lv
• [jira] [Created] (FLINK-38452) MongoDB CDC connector could not read from collections named with dots Xiqian Yu (Jira)
• [jira] [Created] (FLINK-38474) Add java25-target profile Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38414) Add Vitess Pipeline Connector with Parallel Shard Reading Support Poorvank Bhatia (Jira)
• Community review git action failing David Radley
• [jira] [Created] (FLINK-38522) flink-connector-mysql-cdc fails when using StartupOptions.timestamp() for Database connections which require SSL. John Watson (Jira)
• [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Xuannan Su
  • Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Yunfeng Zhou
  • Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Xintong Song
  • Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Alan Zhang
  • RE: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 wenjin
  • Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Zhu Zhu
  • Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Dian Fu
  • Re: [VOTE] Apache Flink Agents Release 0.1.0, release candidate #1 Xuannan Su
• [jira] [Created] (FLINK-38493) Port Calcite's fix for LITERAL is lost while validation Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-38464) Introduce OrderedMultiSetState (view) Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-38486) Harden shutdown of DefaultExpressionEvaluator Arvid Heise (Jira)
• [jira] [Created] (FLINK-38445) Create test plans to validate upsert keys Gustavo de Morais (Jira)
• Community Health Initiative update David Radley
  • Re: Community Health Initiative update Robert Metzger
  • Re: Community Health Initiative update Pedro Mázala
  • Re: Community Health Initiative update Xeno Amess
• [jira] [Created] (FLINK-38512) Postgres YAML CDC support database name with middlescore Hongshun Wang (Jira)
• JIRA account unigogyk
• RE: FLINK-30975 - Flink Filesystem support for AWS SDK V2 ctrlaltdilj
  • FLINK-30975 - Flink Filesystem support for AWS SDK V2 ctrlaltdilj
• [jira] [Created] (FLINK-38496) Icerberg yaml sink need extra hadoop jar Hongshun Wang (Jira)
• [jira] [Created] (FLINK-38494) Add Chinese docs david radley (Jira)
• [jira] [Created] (FLINK-38524) Can not use python udtf with literal input Shengkai Fang (Jira)
• [DISCUSS] FLIP-553 Robust OTel gRPC metric exporter Aleksandr Iushmanov

• Earlier messages
• Later messages