dev  

Messages by Date

• 2025/01/12 [jira] [Created] (FLINK-37104) Code simplification and cleaning related to Flink CDC YAML Transform Wenkai Qi (Jira)
• 2025/01/12 [jira] [Created] (FLINK-37103) The argument lists of the method FactoryUtil.createDynamicTableSink are inconsistent. zhuanshenbsj1 (Jira)
• 2025/01/12 Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
• 2025/01/11 [jira] [Created] (FLINK-37102) ClassNotFoundException for ParquetColumnarRowInputFormat Krish Narukulla (Jira)
• 2025/01/11 [jira] [Created] (FLINK-37101) Remove internal set methods in SerializerConfig Zhanghao Chen (Jira)
• 2025/01/11 Re: [VOTE] FLIP-496: SQL connector for keyed state data Ferenc Csaky
• 2025/01/11 [RESULT][VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xu Huang
• 2025/01/11 Re: [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API Xu Huang
• 2025/01/11 Re: [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API Xu Huang
• 2025/01/10 Re: PR introducing V1 and V2 state migration issue Alexander Fedulov
• 2025/01/10 Community Health Initiative (CHI) 9th of January minutes David Radley
• 2025/01/10 [jira] [Created] (FLINK-37100) Fix test_netty_shuffle_memory_control.sh in CI for JDK11+ Ferenc Csaky (Jira)
• 2025/01/10 [jira] [Created] (FLINK-37099) Document possible Netty4 configurations to setup Pekko properly in JDK11+ Ferenc Csaky (Jira)
• 2025/01/10 [jira] [Created] (FLINK-37098) Can not select time attribute from a view Dawid Wysakowicz (Jira)
• 2025/01/10 PR introducing V1 and V2 state migration issue David Radley
• 2025/01/10 Re: [VOTE] CHI: Stale PR cleanup Tom Cooper
• 2025/01/10 [jira] [Created] (FLINK-37097) Remove david radley (Jira)
• 2025/01/10 Flink v2 download name David Radley
• 2025/01/10 Re: [VOTE] FLIP-496: SQL connector for keyed state data Márton Balassi
• 2025/01/10 [jira] [Created] (FLINK-37096) If the MongoDB connector is implemented with DebeziumSourceFunction, the curve will appear in the full phase delay curve showing 55year sukang (Jira)
• 2025/01/10 Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Maximilian Michels
• 2025/01/10 [jira] [Created] (FLINK-37095) test case that used AI model may met quota not enough exception. Yanquan Lv (Jira)
• 2025/01/10 [jira] [Created] (FLINK-37094) Adapt the external Hive connector to the removal of deprecated APIs in table module in 2.0 xuyang (Jira)
• 2025/01/09 [jira] [Created] (FLINK-37093) The catalog that failed validation due to no type still exists in catalogStoreHolder Mingcan Wang (Jira)
• 2025/01/09 [jira] [Created] (FLINK-37092) Enable skewed join optimization in the TPC-DS e2e test. Junrui Lee (Jira)
• 2025/01/09 [jira] [Created] (FLINK-37091) Remove deprecated CatalogLock interface dalongliu (Jira)
• 2025/01/09 Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xintong Song
• 2025/01/09 [jira] [Created] (FLINK-37090) Introduce tpc-ds e2e case for adaptive broadcast join Junrui Lee (Jira)
• 2025/01/09 [jira] [Created] (FLINK-37089) Advanced scheduling for derived async state processing Zakelly Lan (Jira)
• 2025/01/09 Re: [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xintong Song
• 2025/01/09 [jira] [Created] (FLINK-37088) When the Flink application is running in k8s, the taskmanager log lacks a mount mapping to the host machine. Once the container is restarted, the log will disappear. It is necessary to have a log mount mapping to the host machine baimafeimayf (Jira)
• 2025/01/09 Re: [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API Junrui Lee
• 2025/01/09 Re: [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Junrui Lee
• 2025/01/09 RE: [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API wenjin
• 2025/01/09 [jira] [Created] (FLINK-37087) Add docs for alter materialized table as query dalongliu (Jira)
• 2025/01/09 [jira] [Created] (FLINK-37086) State leaks for JBBC state store after job is stopped Rui Fan (Jira)
• 2025/01/09 Re: [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Yuepeng Pan
• 2025/01/09 [jira] [Created] (FLINK-37085) AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery Weijie Guo (Jira)
• 2025/01/09 Re: [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 weijie guo
• 2025/01/09 Re: [VOTE] FLIP-496: SQL connector for keyed state data Zakelly Lan
• 2025/01/09 [jira] [Created] (FLINK-37084) NullPointerException occurs during handling timer of window in PyFlink Dian Fu (Jira)
• 2025/01/09 [VOTE] FLIP-496: SQL connector for keyed state data Gabor Somogyi
• 2025/01/09 Re: Full Checkpoint information in UI and API Gabor Somogyi
• 2025/01/09 RE: Does Flink operator 1.1.0 support Flink 1.20? David Radley
• 2025/01/09 [jira] [Created] (FLINK-37083) SqlYARNApplicationITCase.testDeployScriptViaSqlClient failed on AZP Weijie Guo (Jira)
• 2025/01/08 Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
• 2025/01/08 [jira] [Created] (FLINK-37082) Disable adaptive join optimization when enable batch job progress recovery xingbe (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37081) The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher zhang (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37080) Flink CDC Postgres when start with latest status in stream phase and add new table, it will be too slow hql0312 (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37079) ci fails at SqlYARNApplicationITCase.testDeployScriptViaSqlClient xuyang (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37078) Update jackson-mapper-asl dependency Anupam Aggarwal (Jira)
• 2025/01/08 Re: Does Flink operator 1.1.0 support Flink 1.20? Rui Fan
• 2025/01/08 [RESULT][VOTE] FLIP-493: Add K8S conditions to CRD's Status Lajith Koova
• 2025/01/08 Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status Lajith Koova
• 2025/01/08 Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status Yuepeng Pan
• 2025/01/08 Re: Memory leak in pekko's Netty 4 transport. Ferenc Csaky
• 2025/01/08 [DISCUSS] FLIP-502: QueryOperation SQL Serialization customization Dawid Wysakowicz
• 2025/01/08 Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status Alexander Fedulov
• 2025/01/08 Does Flink operator 1.1.0 support Flink 1.20? David Radley
• 2025/01/08 [jira] [Created] (FLINK-37077) CLONE - Upgrade Stateful Functions to Flink 1.16.1 Oleksandr Kazimirov (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37076) Support PTF skeleton in planner Timo Walther (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37075) Cross-team verification for FLINK-31836 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs" Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37074) Cross-team verification for FLINK-31362 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37072) Cross-team verification for FLIP-472 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37071) Cross-team verification for FLIP-398 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37070) Cross-team verification for FLIP-461 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37069) Cross-team verification for "Disaggregated State Management" Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37068) Cross-team verification for FLIP-473 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37067) Cross-team verification for “Introduce DataStream API V2” Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37066) Add Pre-check for Definition Query During Creation or Query Modification of Materialized Table Feng Jin (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37065) MySQL cdc can lose/skip data during recovering from the checkpoint Ihor Mielientiev (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37064) Validate Schema Column Name Conflicts in Definition Query During Materialized Table Creation or Alter Query Feng Jin (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37061) Cross-team verification for FLINK-32688 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37062) Cross-team verification for FLINK-36147 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37063) Cross-team verification for "Drop support for Java 8" Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37060) Cross-team verification for FLIP-398 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37059) Cross-team verification for FLINK-4602 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37058) Cross-team verification for FLINK-35573 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37055) Cross-team verification for "Introduce a clean configuration layer" Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37057) Cross-team verification for "Revisit all config option types and default values" Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37056) Cross-team verification for FLINK-23620 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37049) Cross-team verification for "Remove all Scala APIs" Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37054) Cross-team verification for FLINK-33750 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37053) Cross-team verification for FLINK-14068 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37052) Cross-team verification for FLINK-36245 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37051) Cross-team verification for FLINK-36369 Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37050) Cross-team verification for "Remove Sink V1 API in 2.0" Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37048) Cross-team verification for "Remove Deprecated methods/fields/classes in DataStream API" Xintong Song (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37047) Cross-team verification for "Remove DataSet API" Xintong Song (Jira)
• 2025/01/08 [SUMMARY] Flink 2.0 Release Sync 01/08/2025 Xintong Song
• 2025/01/08 [jira] [Created] (FLINK-37046) OceanBase CDC Support for DDL event handling, converted to Debezium JSON format. hzk (Jira)
• 2025/01/08 [jira] [Created] (FLINK-37045) Expose state v2 creation APIs to datastream user Zakelly Lan (Jira)
• 2025/01/08 Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status Rui Fan
• 2025/01/08 Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status Maximilian Michels
• 2025/01/07 [jira] [Created] (FLINK-37044) Support connectors and formats as plugins Karan Makhija (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37043) [Umbrella] Test Flink Release 2.0 Xintong Song (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37042) Unify option names using kebab-case in MaxComputeDataSinkOptions ChaomingZhang (Jira)
• 2025/01/07 Re: [VOTE] CHI: Stale PR cleanup Venkatakrishnan Sowrirajan
• 2025/01/07 [jira] [Created] (FLINK-37036) CLONE - [Release-1.20] Prepare RC0 release Xintong Song (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37041) CLONE - [Release-1.20] Verify that no exclusions were erroneously added to the japicmp plugin Xintong Song (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37031) Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown Weijie Guo (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37034) CLONE - [Release-1.20] Select executing Release Manager Xintong Song (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37037) CLONE - [Release-1.20] Review Release Notes in JIRA Xintong Song (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37038) CLONE - [Release-1.20] Cross team testing Xintong Song (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37040) CLONE - [Release-1.20] Review and update documentation Xintong Song (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37039) CLONE - [Release-1.20] Triage release-blocking issues in JIRA Xintong Song (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37035) CLONE - [Release-1.20] Create a release branch Xintong Song (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37033) CLONE - [Release-1.20] Create a new version in JIRA Xintong Song (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37032) Prepare Flink 2.0 Release Xintong Song (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37030) Support lazy initialization for state serializer in State V2 Zakelly Lan (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37029) Fix the materialized table docs of full mode cron expression dalongliu (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37028) Datastream Window operator with async state processing Zakelly Lan (Jira)
• 2025/01/07 Re: Full Checkpoint information in UI and API Ryan van Huuksloot
• 2025/01/07 Re: [VOTE] CHI: Stale PR cleanup Andrei Kaigorodov
• 2025/01/07 [jira] [Created] (FLINK-37027) Chinese document translation for additional TO_TIMESTAMP_LTZ() functions Yiyu Tian (Jira)
• 2025/01/07 Re: [VOTE] CHI: Stale PR cleanup Tom Cooper
• 2025/01/07 Re: [VOTE] CHI: Stale PR cleanup Sergey Nuyanzin
• 2025/01/07 [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API Xu Huang
• 2025/01/07 [jira] [Created] (FLINK-37026) Enable Stale PR Github Action Thomas Cooper (Jira)
• 2025/01/07 Re: CHI: Automatic Stale PR Cleanup Hong
• 2025/01/07 Re: [VOTE] CHI: Stale PR cleanup Hong
• 2025/01/07 Re: [VOTE] CHI: Stale PR cleanup Tom Cooper
• 2025/01/07 Re: CHI: Automatic Stale PR Cleanup Tom Cooper
• 2025/01/07 [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xu Huang
• 2025/01/07 Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
• 2025/01/07 [jira] [Created] (FLINK-37025) Periodic SQL watermarks can travel back in time Dawid Wysakowicz (Jira)
• 2025/01/07 Re: [VOTE] CHI: Stale PR cleanup Ahmed Hamdy
• 2025/01/07 [jira] [Created] (FLINK-37024) Task can be stuck in deploying state forever when canceling job/failover Zhanghao Chen (Jira)
• 2025/01/07 [jira] [Created] (FLINK-37023) JobManager rest API returns 500 error with CancellationException amjidc (Jira)
• 2025/01/07 Re: Full Checkpoint information in UI and API Zakelly Lan
• 2025/01/07 Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Timo Walther
• 2025/01/07 Re: Elastic Scaling in Apache Flink and minimum parallelism Rui Fan
• 2025/01/07 Elastic Scaling in Apache Flink and minimum parallelism Pavel Dmitriev
• 2025/01/07 [NOTICE] Flink 2.0 Release Sync 01/08/2025 Xintong Song
• 2025/01/06 [jira] [Created] (FLINK-37022) When will flink cdc support jdk21? Is there a support plan for jdk21 in the community? Hui Wang (Jira)
• 2025/01/06 Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
• 2025/01/06 Re:Re: Re:[DISSCUSS] Removing default error methods from the new public api stack in the table api when it implements both the new and deprecated public api stacks and the old stack is removed Xuyang
• 2025/01/06 [jira] [Created] (FLINK-37021) Implement fast rescaling for ForStKeyedStateBackend Yanfei Lei (Jira)
• 2025/01/06 [jira] [Created] (FLINK-37020) Remove CHARACTER_FILTER.filterCharacters function when notify dimension values. hiliuxg (Jira)
• 2025/01/06 Re: [VOTE] CHI: Stale PR cleanup Luke Chen
• 2025/01/06 Re: CHI: Automatic Stale PR Cleanup Rui Fan
• 2025/01/06 Query Regarding encryption support in RocksDB MUKUL GUPTA
• 2025/01/06 Re: Memory leak in pekko's Netty 4 transport. kerr
• 2025/01/06 Re:Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Xuyang
• 2025/01/06 Re: Blue/Green Deployments support for Flink Sergio Chong Loo
• 2025/01/06 Re: [VOTE] CHI: Stale PR cleanup Rui Fan
• 2025/01/06 Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Rui Fan
• 2025/01/06 Re: [VOTE] CHI: Stale PR cleanup Ron Liu
• 2025/01/06 Re: Plans for JDBC connector for 1.20? Xingcan Cui
• 2025/01/06 [jira] [Created] (FLINK-37019) Bump junit to 5.11 Sergey Nuyanzin (Jira)
• 2025/01/06 Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Xingcan Cui
• 2025/01/06 [jira] [Created] (FLINK-37018) Adaptive scheduler triggers multiple internal restarts for a single rescale event Sai Sharath Dandi (Jira)
• 2025/01/06 Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
• 2025/01/06 Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Maximilian Michels
• 2025/01/06 [DISCUSS] - Propagation of Startup Errors Luca Castelli
• 2025/01/06 RE: [VOTE] CHI: Stale PR cleanup David Radley
• 2025/01/06 Re: Memory leak in pekko's Netty 4 transport. PJ Fanning
• 2025/01/06 Re: [VOTE] CHI: Stale PR cleanup Gyula Fóra
• 2025/01/06 [VOTE] CHI: Stale PR cleanup Tom Cooper
• 2025/01/06 [jira] [Created] (FLINK-37017) Supports complex DataTypes in Flink CDC Leonard Xu (Jira)
• 2025/01/06 Re: Memory leak in pekko's Netty 4 transport. Alexander Fedulov
• 2025/01/06 [jira] [Created] (FLINK-37016) NPE when ClusterEntrypoing is shut down before initialization Chesnay Schepler (Jira)
• 2025/01/06 Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Anil Dasari
• 2025/01/06 [jira] [Created] (FLINK-37015) Revise serialization doc to reflect the 2.0 breaking changes properly Zhanghao Chen (Jira)
• 2025/01/06 [jira] [Created] (FLINK-37014) Examples are wrong in materialized table statment doc Mingcan Wang (Jira)
• 2025/01/06 Re: [DISCUSS] Flink 1.18.2 release & grace period for EOL versions Matthias Pohl
• 2025/01/06 Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
• 2025/01/06 Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
• 2025/01/06 [jira] [Created] (FLINK-37013) Job failed to restart on time liting liu (Jira)
• 2025/01/06 [jira] [Created] (FLINK-37012) Fix exception caused by MetadataColumns causing argument type mismatch MOBIN (Jira)
• 2025/01/06 [jira] [Created] (FLINK-37011) Improve get source field value by column name in PreTransformProcessor. ChaomingZhang (Jira)
• 2025/01/06 Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Fabian Paul
• 2025/01/06 Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Junrui Lee
• 2025/01/05 [jira] [Created] (FLINK-37010) Unify KeyedProcessFunction and the async one Zakelly Lan (Jira)
• 2025/01/05 Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
• 2025/01/05 Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
• 2025/01/05 [jira] [Created] (FLINK-37009) Migrate PruneAggregateCallRule Jacky Lau (Jira)
• 2025/01/05 Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xu Huang
• 2025/01/05 [jira] [Created] (FLINK-37008) Flink UI should show the type of checkpoint (full vs incremental) Ryan van Huuksloot (Jira)
• 2025/01/05 Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Junrui Lee
• 2025/01/05 Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xu Huang
• 2025/01/05 Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Matthias Pohl
• 2025/01/05 [jira] [Created] (FLINK-37007) FLIP-494: Add missing createTable/createView methods to TableEnvironment Sergey Nuyanzin (Jira)
• 2025/01/05 [RESULT][VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment Sergey Nuyanzin
• 2025/01/05 Re: Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment Sergey Nuyanzin
• 2025/01/05 Re: Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment Sergey Nuyanzin
• 2025/01/05 [jira] [Created] (FLINK-36934) Enrich numSubpartitions to TierMasterAgent#addPartitionAndGetShuffleDescriptor Weijie Guo (Jira)
• 2025/01/03 [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
• 2025/01/03 [jira] [Created] (FLINK-37006) Apply changes from FLINK-36277 to AdaptiveJoin Sergey Nuyanzin (Jira)
• 2025/01/03 [jira] [Created] (FLINK-37005) Make StreamExecDeduplicate ouput insert only where possible Piotr Nowojski (Jira)
• 2025/01/03 Re: [DISCUSS] Flink 1.18.2 release & grace period for EOL versions Rui Fan
• 2025/01/03 [jira] [Created] (FLINK-37004) Implement Multithreaded SourceReader Hong Liang Teoh (Jira)
• 2025/01/03 Re: [DISCUSS] Flink 1.18.2 release & grace period for EOL versions Robert Metzger
• 2025/01/03 Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Anil Dasari
• 2025/01/03 Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xu Huang
• 2025/01/03 [jira] [Created] (FLINK-37003) Implement async state version of Datastream Interval join Zakelly Lan (Jira)
• 2025/01/03 [jira] [Created] (FLINK-37002) Migrate DecomposeGroupingSetsRule Jacky Lau (Jira)
• 2025/01/03 Re:Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Yuepeng Pan
• 2025/01/03 [jira] [Created] (FLINK-37001) Remove all direct uses of `TableEnvironmentInternal#registerTableSinkInternal` in table module xuyang (Jira)

• Earlier messages
• Later messages