dev  

Messages by Date

• 2025/02/03 Re: Flink Operator 1.11 release planning Maximilian Michels
• 2025/02/03 Re: [VOTE] Release 1.19.2, release candidate #1 Maximilian Michels
• 2025/02/03 Re: [VOTE] Release 1.19.2, release candidate #1 Alexander Fedulov
• 2025/02/03 [RESULT][VOTE] FLIP-502: QueryOperation SQL Serialization customization Dawid Wysakowicz
• 2025/02/03 Re: [VOTE] FLIP-502: QueryOperation SQL Serialization customization Dawid Wysakowicz
• 2025/02/02 Re: [VOTE] Release 1.19.2, release candidate #1 Sergey Nuyanzin
• 2025/02/02 [VOTE] Release flink-connector-hive, release candidate #2 Sergey Nuyanzin
• 2025/02/02 Re: [VOTE] Release flink-connector-hive, release candidate #1 Sergey Nuyanzin
• 2025/02/02 [jira] [Created] (FLINK-37245) RowData#createFieldGetter can resurrect null values for non-null fields Maximilian Michels (Jira)
• 2025/02/01 Re: Flink Operator 1.11 release planning Peter Huang
• 2025/02/01 Re: Flink Operator 1.11 release planning Sharath
• 2025/02/01 Re: Flink Operator 1.11 release planning ConradJam
• 2025/02/01 [jira] [Created] (FLINK-37244) ScyllaDB support in Cassandra connector. Maxim Korolyov (Jira)
• 2025/01/31 [jira] [Created] (FLINK-37243) Ensure that async callbacks happen on known thread Alan Sheinberg (Jira)
• 2025/01/31 [jira] [Created] (FLINK-37242) Enable setting custom labels for flink-operator-webhook-service thanh tung dao (Jira)
• 2025/01/31 [RESULT][VOTE] FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg
• 2025/01/31 Re: [VOTE] Release 1.20.1, release candidate #1 Ferenc Csaky
• 2025/01/31 [jira] [Created] (FLINK-37241) Remove Mockito dependency from StateBackendTestBase Jira
• 2025/01/31 Re: Flink Operator 1.11 release planning Tom Cooper
• 2025/01/31 Re: Flink Operator 1.11 release planning Ferenc Csaky
• 2025/01/31 Flink Operator 1.11 release planning Gyula Fóra
• 2025/01/30 Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Venkatakrishnan Sowrirajan
• 2025/01/30 Re: [VOTE] Release 1.20.1, release candidate #1 Yanquan Lv
• 2025/01/30 [jira] [Created] (FLINK-37240) Changing column nullability throws StateMigrationException in a SQL pipeline with a JOIN Eric Xiao (Jira)
• 2025/01/30 Re: [VOTE] Release 1.19.2, release candidate #1 Ferenc Csaky
• 2025/01/30 Minutes for 9th Community Health Initiative (CHI) Eastern time zone. David Radley
• 2025/01/30 Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Yanquan Lv
• 2025/01/30 [jira] [Created] (FLINK-37239) Improve documentation for multiple built-in functions Gustavo de Morais (Jira)
• 2025/01/29 Re: [VOTE] Release 1.19.2, release candidate #1 Yanquan Lv
• 2025/01/29 [jira] [Created] (FLINK-37238) Flink Web UI does not take scaled parallelism into account when showing job graph Sai Sharath Dandi (Jira)
• 2025/01/29 Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison
• 2025/01/29 Re: [VOTE] FLIP-498: AsyncTableFunction for async table function support Venkatakrishnan Sowrirajan
• 2025/01/29 Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Xingcan Cui
• 2025/01/29 [jira] [Created] (FLINK-37237) Enforce SQL PRIMARY KEY definition for Kudu tables and remove table option Ferenc Csaky (Jira)
• 2025/01/29 [jira] [Created] (FLINK-37236) Make Flink operator compatible with 2.0 preview Gyula Fora (Jira)
• 2025/01/29 [VOTE] Release 1.20.1, release candidate #1 Alexander Fedulov
• 2025/01/29 Re: [VOTE] FLIP-498: AsyncTableFunction for async table function support Martijn Visser
• 2025/01/29 Re: [VOTE] FLIP-502: QueryOperation SQL Serialization customization Martijn Visser
• 2025/01/28 [jira] [Created] (FLINK-37235) Add e2e test for flink-connector-elasticsearch8 Yanquan Lv (Jira)
• 2025/01/28 [jira] [Created] (FLINK-37234) Add timeout for test case to avoid Infinite waiting Yanquan Lv (Jira)
• 2025/01/28 Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation Alan Sheinberg
• 2025/01/28 [VOTE] Release 1.19.2, release candidate #1 Alexander Fedulov
• 2025/01/28 [jira] [Created] (FLINK-37233) Flink-CDC Documentation change request 911432 (Jira)
• 2025/01/28 Re: [VOTE] FLIP-498: AsyncTableFunction for async table function support Timo Walther
• 2025/01/28 Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation Fabian Hüske
• 2025/01/28 Re: [VOTE] FLIP-502: QueryOperation SQL Serialization customization Fabian Hüske
• 2025/01/28 Re: [VOTE] FLIP-498: AsyncTableFunction for async table function support Fabian Hüske
• 2025/01/28 [jira] [Created] (FLINK-37232) FLIP-272 breaks some synchronization assumption on the AdaptiveScheduler's side Matthias Pohl (Jira)
• 2025/01/27 Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Yanquan Lv
• 2025/01/27 Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Venkatakrishnan Sowrirajan
• 2025/01/27 Re: [VOTE] FLIP-498: AsyncTableFunction for async table function support Natea Eshetu Beshada
• 2025/01/27 Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation Alan Sheinberg
• 2025/01/27 [VOTE] FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg
• 2025/01/27 Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg
• 2025/01/27 [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang
• 2025/01/27 Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
• 2025/01/27 [jira] [Created] (FLINK-37231) Add doc for newly added source metric statistics Yanquan Lv (Jira)
• 2025/01/27 Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Venkatakrishnan Sowrirajan
• 2025/01/27 [jira] [Created] (FLINK-37230) Consolidate Kudu connector table options Ferenc Csaky (Jira)
• 2025/01/27 Re: [DISCUSS] Flink 1.18.2 release & grace period for EOL versions Matthias Pohl
• 2025/01/26 [jira] [Created] (FLINK-37229) Add DELETING/DELETED lifecycle states Gyula Fora (Jira)
• 2025/01/26 [jira] [Created] (FLINK-37228) kubernetes HA fails both on flink 1.19.1 and flink 1.20 sigalit (Jira)
• 2025/01/26 [jira] [Created] (FLINK-37227) Support Reuse Multiple Table Sinks in Planner xiangyu feng (Jira)
• 2025/01/25 Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Xingcan Cui
• 2025/01/25 [jira] [Created] (FLINK-37226) Replace deprecated methods in the DataStream API introduction doc Zhanghao Chen (Jira)
• 2025/01/25 [jira] [Created] (FLINK-37225) Remove remaining test resources of Gelly Zhanghao Chen (Jira)
• 2025/01/25 Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
• 2025/01/24 [jira] [Created] (FLINK-37224) Add the missing content of MongoDB CDC to the Chinese document. Yanquan Lv (Jira)
• 2025/01/24 [jira] [Created] (FLINK-37223) Add the missing content of MySQL CDC to the Chinese document. Yanquan Lv (Jira)
• 2025/01/24 Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison
• 2025/01/24 Minutes for 8th Community Health Initiative (CHI) Western time zone. David Radley
• 2025/01/24 [jira] [Created] (FLINK-37222) Table planner exception when sql client submit job Zakelly Lan (Jira)
• 2025/01/24 Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Gyula Fóra
• 2025/01/24 Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Eric Xiao
• 2025/01/24 [jira] [Created] (FLINK-37221) Apply FLIP-406 to Kubernetes Operator Ben Brandt (Jira)
• 2025/01/24 [jira] [Created] (FLINK-37220) GuavaRateLimiter creates an ExecutorService without shutting it down properly leaking threads Matthias Pohl (Jira)
• 2025/01/24 [jira] [Created] (FLINK-37219) Support value state in PTFs Timo Walther (Jira)
• 2025/01/24 Re: [VOTE] FLIP-502: QueryOperation SQL Serialization customization Timo Walther
• 2025/01/23 [jira] [Created] (FLINK-37218) Avoid repeatedly reading the broadcast buffer from the sort-merge shuffle data file while accumulating small buffers from multiple sub-partitions. Junrui Lee (Jira)
• 2025/01/23 [jira] [Created] (FLINK-37217) In `MySqlErrorHandler` TableNotFoundException Unable to obtain table correctly yuanfenghu (Jira)
• 2025/01/23 Re: [VOTE] FLIP-502: QueryOperation SQL Serialization customization Sergey Nuyanzin
• 2025/01/23 [jira] [Created] (FLINK-37216) Default MAX_BATCH_SIZE_IN_BYTES is less than MAX_RECORD_SIZE_IN_BYTES in ElasticsearchDataSinkOptions qinghuan wang (Jira)
• 2025/01/23 [jira] [Created] (FLINK-37215) SlotAllocationException throwing can be moved from TaskExecutor#allocateSlot to TaskSlotTableImpl#allocateSlot Matthias Pohl (Jira)
• 2025/01/23 [jira] [Created] (FLINK-37214) Migrate TaskSlotTableImplTest from using the test thread as the main thread Matthias Pohl (Jira)
• 2025/01/23 [jira] [Created] (FLINK-37213) Improve performance of unbounded OVER aggregations Piotr Nowojski (Jira)
• 2025/01/23 [jira] [Created] (FLINK-37212) hbase connector "Unable to load exception received from server:org.apache.hadoop.hbase.NotServingRegionException" jonasjc (Jira)
• 2025/01/23 [jira] [Created] (FLINK-37211) Fix field resolution for PARTITION BY/ORDER BY Timo Walther (Jira)
• 2025/01/23 [VOTE] FLIP-502: QueryOperation SQL Serialization customization Dawid Wysakowicz
• 2025/01/23 Re: [DISCUSS] FLIP-502: QueryOperation SQL Serialization customization Dawid Wysakowicz
• 2025/01/23 [jira] [Created] (FLINK-37210) Add flink-cdc-release-3.3.0 module to flink-cdc-migration-tests. Yanquan Lv (Jira)
• 2025/01/23 [jira] [Created] (FLINK-37209) Add Embedding AI Model for Qwen Yanquan Lv (Jira)
• 2025/01/22 [jira] [Created] (FLINK-37208) Properly notify a new key is selected for async state operators Zakelly Lan (Jira)
• 2025/01/22 [jira] [Created] (FLINK-37207) Distributed cache set in the DataStream API does not work if a job use both the Table API & DataStream API Dian Fu (Jira)
• 2025/01/22 [jira] [Created] (FLINK-37206) Initialization issue of batching timer service in async state operators Zakelly Lan (Jira)
• 2025/01/22 [jira] [Created] (FLINK-37205) Correct the state cache behavior during bump beam version Dian Fu (Jira)
• 2025/01/22 [jira] [Created] (FLINK-37204) Add missing StarRocks connector options for 1.2.10. ChaomingZhang (Jira)
• 2025/01/22 Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Venkatakrishnan Sowrirajan
• 2025/01/22 Re: [Discuss] Flink CDC 3.4 Kick Off Ferenc Csaky
• 2025/01/22 [jira] [Created] (FLINK-37203) Support AltertableCommentEvent and AlterColumnCommentEvent. Yanquan Lv (Jira)
• 2025/01/22 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Márton Balassi
• 2025/01/22 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Maximilian Michels
• 2025/01/22 Re: [jira] [Created] (FLINK-37202) Introduce TDengine connector David Radley
• 2025/01/22 [jira] [Created] (FLINK-37202) Introduce TDengine connector kevinmen (Jira)
• 2025/01/22 [jira] [Created] (FLINK-37201) FlinkCDC Pipeline transform arithmetic functions support parameters of null and more numerical types. Wenkai Qi (Jira)
• 2025/01/22 [jira] [Created] (FLINK-37200) Add e2e test for ElasticSearch Sink. Yanquan Lv (Jira)
• 2025/01/22 [jira] [Created] (FLINK-37199) Update document in quickly start to guide user to add checkpoint configuration Yanquan Lv (Jira)
• 2025/01/22 [jira] [Created] (FLINK-37198) AvroToRowDataConverters factory omits legacyTimestampMapping option for nested Row. Juliusz Nadberezny (Jira)
• 2025/01/22 Re: [Discuss] Flink CDC 3.4 Kick Off Leonard Xu
• 2025/01/22 [jira] [Created] (FLINK-37197) Release flink-connector-mongodb v2.0.0 for Flink 1.20 Jiabao Sun (Jira)
• 2025/01/21 Re: [Discuss] Flink CDC 3.4 Kick Off ConradJam
• 2025/01/21 [Discuss] Flink CDC 3.4 Kick Off Yanquan Lv
• 2025/01/21 [SUMMARY] Flink 2.0 Release Sync 01/22/2015 Xintong Song
• 2025/01/21 [ANNOUNCE] Release 2.0.0, release candidate #0 Xintong Song
• 2025/01/21 Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
• 2025/01/21 [jira] [Created] (FLINK-37196) Build documentation github action can't work Weijie Guo (Jira)
• 2025/01/21 [jira] [Created] (FLINK-37195) TimestampAdd / TimestampDiff series function not available in cluster yux (Jira)
• 2025/01/21 [jira] [Created] (FLINK-37194) WatermarkITCase.testAlignedWatermarkBlockUpstream failed Weijie Guo (Jira)
• 2025/01/21 Re: [ANNOUNCE] Apache Flink CDC 3.3.0 released Leonard Xu
• 2025/01/21 Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Venkatakrishnan Sowrirajan
• 2025/01/21 [jira] [Created] (FLINK-37193) Ingress recreated after perform a change to CRD Jira
• 2025/01/21 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Ferenc Csaky
• 2025/01/21 [jira] [Created] (FLINK-37192) [pyflink] Replace deprecated avro-python3 with avro Mina Asham (Jira)
• 2025/01/21 [jira] [Created] (FLINK-37191) MySQL 'Compile and test' stage timeout after 90 minutes Leonard Xu (Jira)
• 2025/01/21 [jira] [Created] (FLINK-37190) Make Kudu `FlushMode` configurable in Flink SQL Ferenc Csaky (Jira)
• 2025/01/21 [ANNOUNCE] Apache Flink CDC 3.3.0 released Hang Ruan
• 2025/01/21 [jira] [Created] (FLINK-37189) Incorrect version string of maven-enforcer-plugin requireJavaVersion xuhuang (Jira)
• 2025/01/20 [RESULT] [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 Hang Ruan
• 2025/01/20 [jira] [Created] (FLINK-37188) Cross-team verification for FLINK-37133 "Submitting Refresh Job of Materialized Table to Yarn/K8s" Feng Jin (Jira)
• 2025/01/20 [jira] [Created] (FLINK-37187) Add doc for Submitting Refresh Job of Materialized Table to Yarn/K8s Feng Jin (Jira)
• 2025/01/20 Re: [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 weijie guo
• 2025/01/20 Re: [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 Xingbo Huang
• 2025/01/20 Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
• 2025/01/20 [jira] [Created] (FLINK-37186) Cross-team verification for "FLIP-480: Support to deploy SQL script in application mode" Shengkai Fang (Jira)
• 2025/01/20 Re: [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 Leonard Xu
• 2025/01/20 [jira] [Created] (FLINK-37185) NoClassDefFoundError raised from ORC tests Weijie Guo (Jira)
• 2025/01/20 [KINDELY REMINDER] Flink 2.0 Release Sync 01/22/2025 Xintong Song
• 2025/01/20 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) gyula . fora
• 2025/01/20 [jira] [Created] (FLINK-37184) Support ZStandard compressed input in new File API Joery (Jira)
• 2025/01/20 [jira] [Created] (FLINK-37183) Usrlib symlinks are not followed Joery (Jira)
• 2025/01/20 [jira] [Created] (FLINK-37182) PartitionedFileWriteReadTest should remove partition files after test finishes. Ao Li (Jira)
• 2025/01/20 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) He Pin
• 2025/01/20 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Tom Cooper
• 2025/01/20 RE: Plans for JDBC connector for 1.20? David Radley
• 2025/01/20 [jira] [Created] (FLINK-37181) Failed to validate Maven wrapper SHA-256 on MacOS with mvnw Gabor Somogyi (Jira)
• 2025/01/20 [jira] [Created] (FLINK-37180) Implement StreamOperator for PTF Timo Walther (Jira)
• 2025/01/20 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Ferenc Csaky
• 2025/01/20 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Alexander Fedulov
• 2025/01/20 [jira] [Created] (FLINK-37179) [ArgoCD] App Out Of sync after update to v1.6.0 Jira
• 2025/01/20 [ANNOUNCE] Flink 2.0 feature freeze Xintong Song
• 2025/01/20 [jira] [Created] (FLINK-37178) Improve documentation for BTRIM, TRANSLATE3, ELT and PERCENTILE Gustavo de Morais (Jira)
• 2025/01/20 [jira] [Created] (FLINK-37177) Update chinese documentation of json function Gustavo de Morais (Jira)
• 2025/01/20 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Ferenc Csaky
• 2025/01/20 [jira] [Created] (FLINK-37176) setup_hugo.sh doesn't work on macbook Gustavo de Morais (Jira)
• 2025/01/20 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) ConradJam
• 2025/01/20 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Alexis Sarda-Espinosa
• 2025/01/20 Re: StreamingFilSink with FlinkRunner Taher Koitawala
• 2025/01/20 [jira] [Created] (FLINK-37175) Support JSON built-in function for JSON_OBJECT Gustavo de Morais (Jira)
• 2025/01/19 [jira] [Created] (FLINK-37174) SqlClientTest#testPrintAllModeHelp and #testPrintEmbeddedModeHelp failed xuyang (Jira)
• 2025/01/19 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) He Pin
• 2025/01/19 [jira] [Created] (FLINK-37173) Failed to pass license check in JDK11 build Weijie Guo (Jira)
• 2025/01/19 [jira] [Created] (FLINK-37172) Add logs in all existing async state ops to check if they are under async state when running xuyang (Jira)
• 2025/01/19 Re: [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 Xiqian YU
• 2025/01/19 Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
• 2025/01/19 [jira] [Created] (FLINK-37171) Clear all remaining deprecated methods under public APIs in table modules xuyang (Jira)
• 2025/01/19 [jira] [Created] (FLINK-37170) Disable 1.18 CI Matthias Pohl (Jira)
• 2025/01/19 [jira] [Created] (FLINK-37169) Broken links to connector JARs in documentation xxchan (Jira)
• 2025/01/18 Re: [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 Yanquan Lv
• 2025/01/18 [jira] [Created] (FLINK-37168) TimerRegistrationAction in unregisteredTimers is not cleaned up properly after the timers are registered Shuyi Chen (Jira)
• 2025/01/18 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Alexander Fedulov
• 2025/01/17 [VOTE] Apache Flink CDC Release 3.3.0, release candidate #1 Hang Ruan
• 2025/01/17 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) He Pin
• 2025/01/17 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Maximilian Michels
• 2025/01/17 [jira] [Created] (FLINK-37166) FlinkConfigManager version prefix logic not safe Gyula Fora (Jira)
• 2025/01/17 [jira] [Created] (FLINK-37167) Fix operand reordering in SqlValidatorImpl for tableCharacteristics Timo Walther (Jira)
• 2025/01/17 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Samrat Deb
• 2025/01/17 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Luke Chen
• 2025/01/17 Re: Memory leak in pekko's Netty 4 transport. He Pin
• 2025/01/17 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) He Pin
• 2025/01/17 RE: Stale PR Action running but the labels are missing David Radley
• 2025/01/17 Re: Stale PR Action running but the labels are missing Tom Cooper
• 2025/01/17 [jira] [Created] (FLINK-37165) The starrocks connector is found to be missing some options. sukang (Jira)
• 2025/01/17 [jira] [Created] (FLINK-37164) Speed up state v2 synchronous methods execution Zakelly Lan (Jira)
• 2025/01/17 Re: [DISCUSS] Release Flink CDC version 3.3.0 Yanquan Lv
• 2025/01/17 Re: [DISCUSS] Release Flink CDC version 3.3.0 Leonard Xu
• 2025/01/17 [jira] [Created] (FLINK-37163) Add documents for recently merged PRs in FlinkCDC 3.3 Yanquan Lv (Jira)
• 2025/01/16 [jira] [Created] (FLINK-37162) Add Data Sources Documentation Yanquan Lv (Jira)
• 2025/01/16 [DISCUSS] Release Flink CDC version 3.3.0 Hang Ruan
• 2025/01/16 Re:Re: [DISCUSSION] flink-connector-hive first release of externalized connector Xuyang
• 2025/01/16 [jira] [Created] (FLINK-37161) Cross-team verification for "Adaptive skewed join optimization for batch jobs" Junrui Lee (Jira)
• 2025/01/16 [jira] [Created] (FLINK-37160) Cross-team verification for "Adaptive broadcast join for batch jobs" Junrui Lee (Jira)
• 2025/01/16 [jira] [Created] (FLINK-37159) MemoryManagerConcurrentModReleaseTest.testConcurrentModificationWhileReleasing timeout in AZP Weijie Guo (Jira)
• 2025/01/16 [jira] [Created] (FLINK-37158) Introduce ForSt to existing ITCases Yanfei Lei (Jira)
• 2025/01/16 Re: Stale PR Action running but the labels are missing Rui Fan
• 2025/01/16 [jira] [Created] (FLINK-37157) Enable daily benchmark for Java 21 Zakelly Lan (Jira)
• 2025/01/16 [jira] [Created] (FLINK-37156) A Flink pipeline supports collecting data once and writing it to multiple sinks. cheng qian (Jira)
• 2025/01/16 [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison
• 2025/01/16 Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Venkatakrishnan Sowrirajan
• 2025/01/16 [jira] [Created] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Allison Chang (Jira)
• 2025/01/16 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Ferenc Csaky
• 2025/01/16 Re: Upgrade to Netty 4.x (1.19.2, 1.20.1 releases) Tom Cooper

• Earlier messages
• Later messages