dev  

Messages by Thread

• • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Sharath
  • RE: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Nic Townsend
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Lajith Koova
  • FW: Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink David Radley
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Tom Cooper
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Mark Nuttall
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Ferenc Csaky
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Anu K T
  • [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink David Radley
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Gyula Fóra
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Sebastien Pereira
  • RE: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Ammu P
  • RE: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Mehdi Deboub
  • RE: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Mehdi Deboub
  • Re: [VOTE] FLIP-532: Donate GetInData HTTP Connector to Flink Leonard Xu
• [RESULT][VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Xintong Song
• [jira] [Created] (FLINK-37910) FLIP-516: Add StreamExecMultiJoin exec node Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37909) Flink CDC source connector for mongodb repeatedly failing in streaming mode with ChangeStreamHistoryLost error Sachin Mittal (Jira)
• [jira] [Created] (FLINK-37908) KinesisStreamsSource connector de/registration strategy fails on automated restarts Jonathan Du (Jira)
• [jira] [Created] (FLINK-37907) Allow to access memberExecNodes in BatchExecMultipleInput Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37906) Bump kafka version to 4.0 for release-2.0 doc Weijie Guo (Jira)
• [jira] [Created] (FLINK-37905) Transform will throw exceptions when handling chinese characters Ruan Hang (Jira)
• 2025/06/05 CHI Eastern time zone workgroup meeting minutes David Radley
• [jira] [Created] (FLINK-37904) Support state ttl for async ML_PREDICT Shengkai Fang (Jira)
• [jira] [Created] (FLINK-37903) Support runtime config for ML_PREDICT Shengkai Fang (Jira)
• [jira] [Created] (FLINK-37901) Support to serde ExecNode for ML_PREDICT Shengkai Fang (Jira)
• [jira] [Created] (FLINK-37902) Support batch execution for ML_PREDICT Shengkai Fang (Jira)
• [jira] [Created] (FLINK-37900) Support configurable jitter in rocksdb checkpoint file uploader Zhenqiu Huang (Jira)
• Flink CDC for mongoDB, need to understand MongoDBStreamFetchTask better Sachin Mittal
• [jira] [Created] (FLINK-37899) Unstable JoinRestoreTest Shengkai Fang (Jira)
• Waiting on approval to Jira account Jonathan Du
• [jira] [Created] (FLINK-37897) Support converting a regular join to a delta join for the simplest pattern in planner Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-37898) Implement delta join operator Xuyang Zhong (Jira)
• [jira] [Created] (FLINK-37896) Introduce a new trait derived from sink to source that verifies whether the downstream node can accept redundant data generated by a delta join. Xuyang Zhong (Jira)
• [DISCUSS] FLIP-533: Cassandra Sink V2 Poorvank Bhatia
  • Re: [DISCUSS] FLIP-533: Cassandra Sink V2 Jeffrey Rodriguez
  • Re: [DISCUSS] FLIP-533: Cassandra Sink V2 Etienne Chauchot
  • Re: [DISCUSS] FLIP-533: Cassandra Sink V2 Poorvank Bhatia
  • Re: [DISCUSS] FLIP-533: Cassandra Sink V2 Etienne Chauchot
  • Re: [DISCUSS] FLIP-533: Cassandra Sink V2 Poorvank Bhatia
  • Re: [DISCUSS] FLIP-533: Cassandra Sink V2 Poorvank Bhatia
• [jira] [Created] (FLINK-37895) "Failed to fetch job exceptions from REST API for jobId" errors for session jobs Jira
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.12.0 released Gabor Somogyi
• [jira] [Created] (FLINK-37892) SplitFetcherManagerTest#testCloseBlockingWaitingForFetcherShutdown azure cron ci failed dalongliu (Jira)
• [jira] [Created] (FLINK-37893) Rest Port Name should be made configurable Mayur Dhingra (Jira)
• [jira] [Created] (FLINK-37894) Introduce new Join Operator with Async State API Wang Qilong (Jira)
• [SUMMARY] Flink 2.1 Release Sync 06/04/2025 Ron Liu
  • Re: [SUMMARY] Flink 2.1 Release Sync 06/04/2025 Hao Li
  • Re: [SUMMARY] Flink 2.1 Release Sync 06/04/2025 Ron Liu
• Call for Presentations: Current New Orleans, October 29-30, 2025 Robert Metzger
• [jira] [Created] (FLINK-37891) SQL Server CDC mistakenly document scan.startup.mode=initial-only as supported Sergei Morozov (Jira)
• [jira] [Created] (FLINK-37889) FLIP-516: Add new FlinkLogicalMultiJoin rule Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37890) FLIP-516: Extend FlinkLogicalMultiJoin to check for common join key Gustavo de Morais (Jira)
• Missing required TM metrics when truing to use the autoscaler David Radley
• Request a permission Zhe Wang
  • Re: Request a permission Gustavo de Morais
  • Re: Request a permission Zhe Wang
• [jira] [Created] (FLINK-37888) Flink CDC data format conversion error when writing to Iceberg r0y4d3v (Jira)
• [jira] [Created] (FLINK-37887) Watched namespaces not picked up automatically by the operator Igor Milavec (Jira)
• [HELP] Failing ArchitectureTest on master (CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API) Gabor Somogyi
• [jira] [Created] (FLINK-37886) Introduce the ITCase to check whether unaligned checkpoint works well for jobs with sink writer and committer Rui Fan (Jira)
• [KINDLY REMINDER] Flink 2.1 Release Sync 06/04/2025 Ron Liu
• [jira] [Created] (FLINK-37885) Update Flink Operator to Java Operator Version 5.1.1 Jira
• [jira] [Created] (FLINK-37884) ArchitectureTest ConnectorRules.CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API fails on master Gabor Somogyi (Jira)
• [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.12.0, release candidate #1 Gabor Somogyi
• [DISCUSS] Proposal: Modernizing Cassandra Sink with Sink V2 & Async Support Poorvank Bhatia
  • Re: [DISCUSS] Proposal: Modernizing Cassandra Sink with Sink V2 & Async Support Leonard Xu
  • Re: [DISCUSS] Proposal: Modernizing Cassandra Sink with Sink V2 & Async Support gyula . fora
  • Re: [DISCUSS] Proposal: Modernizing Cassandra Sink with Sink V2 & Async Support Maximilian Michels
  • Re: [DISCUSS] Proposal: Modernizing Cassandra Sink with Sink V2 & Async Support Etienne Chauchot
• [jira] [Created] (FLINK-37883) Flink-ci-mirror stopped running for commits after 27th of May Sergey Nuyanzin (Jira)
• [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Xintong Song
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Jing Ge
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Robert Metzger
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Martijn Visser
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Yuan Mei
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Mingge Deng
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Jiaming Xu
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Hao Li
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Yash Anand
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Yuepeng Pan
  • RE: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project David Radley
  • RE: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Ferenc Csaky
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Gustavo de Morais
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Yun Tang
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Feng Jin
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Jiangang Liu
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Hangxiang Yu
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Letao Jiang
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Xingbo Huang
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Guowei Ma
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Zakelly Lan
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Nishita Pattanayak
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Leonard Xu
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Xintong Song
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project pranav tiwari
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project weijie guo
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Sharath
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Dian Fu
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Jark Wu
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Rui Fan
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Lincoln Lee
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Swapnal Varma
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Xintong Song
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Qingsheng Ren
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Becket Qin
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Zhu Zhu
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Ron Liu
  • Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project Xintong Song
  • RE: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project wenjin
• [jira] [Created] (FLINK-37882) Add tests for queries where LITERAL_AGG will appear after upgrade to Calcite 1.35 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37881) Drop gosu in favour of Dockerfile's USER Avi Sanwal (Jira)
• [RESULT][VOTE] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API Hao Li
• [jira] [Created] (FLINK-37880) build_wheels_on_macos fails every time Sergey Nuyanzin (Jira)
• [VOTE] Release 1.20.2, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release 1.20.2, release candidate #1 Ferenc Csaky
• [jira] [Created] (FLINK-37876) Introduce key ordered component in runtime Shuai Xu (Jira)
• [DISCUSS] FLIP-532: Donate GetInData HTTP Connector to Flink David Radley
  • Re: [DISCUSS] FLIP-532: Donate GetInData HTTP Connector to Flink David Radley
• 2025/05/29 CHI Western time zone workgroup meeting minutes David Radley
• [jira] [Created] (FLINK-37879) transform concat function don't support utf-8 and cast don't support STRING Xin Gong (Jira)
• [jira] [Created] (FLINK-37878) Extract handling of processors in PlannerBase into PlannerBase#applyProcessors and make it public Sergey Nuyanzin (Jira)
• [VOTE] Release 1.19.3, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release 1.19.3, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release 1.19.3, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release 1.19.3, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release 1.19.3, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release 1.19.3, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release 1.19.3, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release 1.19.3, release candidate #1 Sergey Nuyanzin
  • Re: [VOTE] Release 1.19.3, release candidate #1 Ferenc Csaky
  • Re: [VOTE] Release 1.19.3, release candidate #1 Ferenc Csaky
• [jira] [Created] (FLINK-37874) FLIP-519: Introduce async lookup key ordered mode Shuai Xu (Jira)
• [jira] [Created] (FLINK-37877) Add the key ordered operator in table runtime Shuai Xu (Jira)
• [jira] [Created] (FLINK-37875) Introduce the option and the support of planner Shuai Xu (Jira)
• [jira] [Created] (FLINK-37873) 【Hbase-connector】Enable buffer flush, specify a non-existent table when writing data to hbase, the Flink task displays successful Xin Chen (Jira)
• [jira] [Created] (FLINK-37872) Autoscaler computes negative true processing rate Sai Sharath Dandi (Jira)
• [jira] [Created] (FLINK-37871) Remove FlinkRelMdUtil#getJoinDistinctRowCount Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37870) Unaligned checkpoint is disabled unexpectedly Rui Fan (Jira)
• [jira] [Created] (FLINK-37869) Bouned job can't be cleanup by the Flink Kuberenetes Operator junzhong qin (Jira)
• [jira] [Created] (FLINK-37868) Respect the `maxTransferBytes` when using path copying in ForSt Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37867) ForSt StateBackend fail to clean up files of the half-uploaded checkpoint when using path copying Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37866) Migrate glue schema registry e2e test to use aws-kinesis-streams connector Daren Wong (Jira)
• [VOTE] Apache Flink Kubernetes Operator Release 1.12.0, release candidate #1 Gabor Somogyi
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.0, release candidate #1 Robert Metzger
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.0, release candidate #1 Gyula Fóra
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.0, release candidate #1 Ufuk Celebi
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.0, release candidate #1 Maximilian Michels
  • Re: [VOTE] Apache Flink Kubernetes Operator Release 1.12.0, release candidate #1 Daren Wong
• Bug: Race condition in Flink Kinesis EFO de/registration on restart Jonathan Du
  • Re: Bug: Race condition in Flink Kinesis EFO de/registration on restart Jonathan Du
• [jira] [Created] (FLINK-37865) Add documentation for AsyncTableFunction Alan Sheinberg (Jira)
• Need invite link for the Flink community on Slack Siva Ram Gujju
  • Re: Need invite link for the Flink community on Slack Yanquan Lv
  • Re: Need invite link for the Flink community on Slack Siva Ram Gujju
  • Re: Need invite link for the Flink community on Slack Leonard Xu
• [jira] [Created] (FLINK-37864) Extend DynamicKafkaSource to allow for cluster-specific OffsetsInitializer Joey Pereira (Jira)
• [jira] [Created] (FLINK-37863) DynamicKafkaSource support in PyFlink Joey Pereira (Jira)
• [jira] [Created] (FLINK-37862) Implement data type improvements for StructuredType Timo Walther (Jira)
• [DISCUSS] Decouple PyFlink wheel package build from Azure Ferenc Csaky
  • Re: [DISCUSS] Decouple PyFlink wheel package build from Azure Gabor Somogyi
  • Re: [DISCUSS] Decouple PyFlink wheel package build from Azure Dian Fu
  • Re: [DISCUSS] Decouple PyFlink wheel package build from Azure Ferenc Csaky
• [jira] [Created] (FLINK-37861) FLIP-520: Simplify StructuredType handling Timo Walther (Jira)
• [jira] [Created] (FLINK-37860) [paimon-connector]Fix Committer.createContext not passing OperatorStateStore correctly MOBIN (Jira)
• Requesting invite to Slack group Jonathan Du
• [jira] [Created] (FLINK-37859) [umbrella] FLIP-516: Streaming Multi-Way Join Optimization dalongliu (Jira)
• [RESULT][VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
• [DISCUSSION] FLIP Process - Handling similar FLIPs and dormant FLIPs Becket Qin
  • Re: [DISCUSSION] FLIP Process - Handling similar FLIPs and dormant FLIPs Weiqing Yang
  • Re: [DISCUSSION] FLIP Process - Handling similar FLIPs and dormant FLIPs Becket Qin
  • Re: [DISCUSSION] FLIP Process - Handling similar FLIPs and dormant FLIPs Weiqing Yang
  • Re: [DISCUSSION] FLIP Process - Handling similar FLIPs and dormant FLIPs Becket Qin
  • Re: [DISCUSSION] FLIP Process - Handling similar FLIPs and dormant FLIPs Weiqing Yang
• [jira] [Created] (FLINK-37857) Add a DSV2 sink implementation to tests which can collect data Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-37858) Migrate state processor API from source v1 to source v2 API Gabor Somogyi (Jira)
• Code review request: GCS integration tests and library upgrade Chris Nauroth
• Subject: [PR][FLINK-37125] Looking for committer review/merge for PR #26037 Sehaj Sandhu
• [jira] [Created] (FLINK-37856) Sink option hints are not present in compiled plan Arvid Heise (Jira)
• [DISCUSS] Update Kubernetes operator minimum JDK runtime to 17 Gyula Fóra
  • Re: [DISCUSS] Update Kubernetes operator minimum JDK runtime to 17 Ryan van Huuksloot
  • Re: [DISCUSS] Update Kubernetes operator minimum JDK runtime to 17 Robert Metzger
• [jira] [Created] (FLINK-37855) Reduce the time cost in MySqlSchemaUtils#listTables Yanquan Lv (Jira)
• [Discuss] Flink CDC 3.4 Kick Off, [Discuss] Flink CDC 3.5 Kick Off Yanquan Lv
  • Re: [Discuss] Flink CDC 3.4 Kick Off, [Discuss] Flink CDC 3.5 Kick Off Yanquan Lv
  • Re: [Discuss] Flink CDC 3.4 Kick Off, [Discuss] Flink CDC 3.5 Kick Off Xiqian YU
  • [DISCUSS] Flink CDC 3.5 Kick Off Leonard Xu
  • Re:[Discuss] Flink CDC 3.4 Kick Off, [Discuss] Flink CDC 3.5 Kick Off MOBIN
  • Re: [Discuss] Flink CDC 3.4 Kick Off, [Discuss] Flink CDC 3.5 Kick Off wang junbo
• [jira] [Created] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds Jacky Lau (Jira)
• [jira] [Created] (FLINK-37853) FLIP-530: Dynamic job configuration Roman Khachatryan (Jira)
• [jira] [Created] (FLINK-37852) SQL Server CDC cannot capture changes from tables with special characters Sergei Morozov (Jira)
• [DISCUSS] Deprecating/dropping support for Python 3.8 Mika Naylor
  • Re: [DISCUSS] Deprecating/dropping support for Python 3.8 Xingbo Huang
  • Re: [DISCUSS] Deprecating/dropping support for Python 3.8 Dian Fu
  • Re: [DISCUSS] Deprecating/dropping support for Python 3.8 Gabor Somogyi
  • Re: [DISCUSS] Deprecating/dropping support for Python 3.8 Ferenc Csaky
  • Re: [DISCUSS] Deprecating/dropping support for Python 3.8 Mika Naylor
  • RE: [DISCUSS] Deprecating/dropping support for Python 3.8 Cole Bailey
• Getting "sun.rmi.registry is not visible" exception while running main method of CliFrontend.java class of flink-clients package pranav tiwari

• Earlier messages
• Later messages