dev  

Messages by Thread

• [jira] [Created] (FLINK-37059) Cross-team verification for FLINK-4602 Xintong Song (Jira)
• [jira] [Created] (FLINK-37058) Cross-team verification for FLINK-35573 Xintong Song (Jira)
• [jira] [Created] (FLINK-37055) Cross-team verification for "Introduce a clean configuration layer" Xintong Song (Jira)
• [jira] [Created] (FLINK-37057) Cross-team verification for "Revisit all config option types and default values" Xintong Song (Jira)
• [jira] [Created] (FLINK-37056) Cross-team verification for FLINK-23620 Xintong Song (Jira)
• [jira] [Created] (FLINK-37049) Cross-team verification for "Remove all Scala APIs" Xintong Song (Jira)
• [jira] [Created] (FLINK-37054) Cross-team verification for FLINK-33750 Xintong Song (Jira)
• [jira] [Created] (FLINK-37053) Cross-team verification for FLINK-14068 Xintong Song (Jira)
• [jira] [Created] (FLINK-37052) Cross-team verification for FLINK-36245 Xintong Song (Jira)
• [jira] [Created] (FLINK-37051) Cross-team verification for FLINK-36369 Xintong Song (Jira)
• [jira] [Created] (FLINK-37050) Cross-team verification for "Remove Sink V1 API in 2.0" Xintong Song (Jira)
• [jira] [Created] (FLINK-37048) Cross-team verification for "Remove Deprecated methods/fields/classes in DataStream API" Xintong Song (Jira)
• [jira] [Created] (FLINK-37047) Cross-team verification for "Remove DataSet API" Xintong Song (Jira)
• [SUMMARY] Flink 2.0 Release Sync 01/08/2025 Xintong Song
• [jira] [Created] (FLINK-37046) OceanBase CDC Support for DDL event handling, converted to Debezium JSON format. hzk (Jira)
• [jira] [Created] (FLINK-37045) Expose state v2 creation APIs to datastream user Zakelly Lan (Jira)
• Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status Maximilian Michels
  • Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status Rui Fan
  • Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status Alexander Fedulov
  • Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status Yuepeng Pan
  • Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status Lajith Koova
• [jira] [Created] (FLINK-37044) Support connectors and formats as plugins Karan Makhija (Jira)
• [jira] [Created] (FLINK-37043) [Umbrella] Test Flink Release 2.0 Xintong Song (Jira)
• [jira] [Created] (FLINK-37042) Unify option names using kebab-case in MaxComputeDataSinkOptions ChaomingZhang (Jira)
• [jira] [Created] (FLINK-37036) CLONE - [Release-1.20] Prepare RC0 release Xintong Song (Jira)
• [jira] [Created] (FLINK-37041) CLONE - [Release-1.20] Verify that no exclusions were erroneously added to the japicmp plugin Xintong Song (Jira)
• [jira] [Created] (FLINK-37031) Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown Weijie Guo (Jira)
• [jira] [Created] (FLINK-37034) CLONE - [Release-1.20] Select executing Release Manager Xintong Song (Jira)
• [jira] [Created] (FLINK-37037) CLONE - [Release-1.20] Review Release Notes in JIRA Xintong Song (Jira)
• [jira] [Created] (FLINK-37038) CLONE - [Release-1.20] Cross team testing Xintong Song (Jira)
• [jira] [Created] (FLINK-37040) CLONE - [Release-1.20] Review and update documentation Xintong Song (Jira)
• [jira] [Created] (FLINK-37039) CLONE - [Release-1.20] Triage release-blocking issues in JIRA Xintong Song (Jira)
• [jira] [Created] (FLINK-37035) CLONE - [Release-1.20] Create a release branch Xintong Song (Jira)
• [jira] [Created] (FLINK-37033) CLONE - [Release-1.20] Create a new version in JIRA Xintong Song (Jira)
• [jira] [Created] (FLINK-37032) Prepare Flink 2.0 Release Xintong Song (Jira)
• [jira] [Created] (FLINK-37030) Support lazy initialization for state serializer in State V2 Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37029) Fix the materialized table docs of full mode cron expression dalongliu (Jira)
• [jira] [Created] (FLINK-37028) Datastream Window operator with async state processing Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37027) Chinese document translation for additional TO_TIMESTAMP_LTZ() functions Yiyu Tian (Jira)
• [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API Xu Huang
  • RE: [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API wenjin
  • Re: [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API Junrui Lee
  • Re: [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API Xu Huang
  • Re: [DISCUSS] FLIP-501: Support Window Extension in DataStream V2 API Xu Huang
• [jira] [Created] (FLINK-37026) Enable Stale PR Github Action Thomas Cooper (Jira)
• [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xu Huang
  • Re: [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 weijie guo
  • Re: [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Yuepeng Pan
  • Re: [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Junrui Lee
  • Re: [VOTE] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xintong Song
• [jira] [Created] (FLINK-37025) Periodic SQL watermarks can travel back in time Dawid Wysakowicz (Jira)
• [jira] [Created] (FLINK-37024) Task can be stuck in deploying state forever when canceling job/failover Zhanghao Chen (Jira)
• [jira] [Created] (FLINK-37023) JobManager rest API returns 500 error with CancellationException amjidc (Jira)
• Re: Full Checkpoint information in UI and API Zakelly Lan
  • Re: Full Checkpoint information in UI and API Ryan van Huuksloot
  • Re: Full Checkpoint information in UI and API Gabor Somogyi
• Elastic Scaling in Apache Flink and minimum parallelism Pavel Dmitriev
  • Re: Elastic Scaling in Apache Flink and minimum parallelism Rui Fan
• [NOTICE] Flink 2.0 Release Sync 01/08/2025 Xintong Song
• [jira] [Created] (FLINK-37022) When will flink cdc support jdk21? Is there a support plan for jdk21 in the community? Hui Wang (Jira)
• [jira] [Created] (FLINK-37021) Implement fast rescaling for ForStKeyedStateBackend Yanfei Lei (Jira)
• [jira] [Created] (FLINK-37020) Remove CHARACTER_FILTER.filterCharacters function when notify dimension values. hiliuxg (Jira)
• Re: CHI: Automatic Stale PR Cleanup Rui Fan
  • Re: CHI: Automatic Stale PR Cleanup Tom Cooper
  • Re: CHI: Automatic Stale PR Cleanup Hong
• Re: Blue/Green Deployments support for Flink Sergio Chong Loo
• Re: Plans for JDBC connector for 1.20? Xingcan Cui
  • RE: Plans for JDBC connector for 1.20? David Radley
  • Re: Plans for JDBC connector for 1.20? Yanquan Lv
  • Re: Plans for JDBC connector for 1.20? Hang Ruan
• [jira] [Created] (FLINK-37019) Bump junit to 5.11 Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37018) Adaptive scheduler triggers multiple internal restarts for a single rescale event Sai Sharath Dandi (Jira)
• Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Xingcan Cui
  • Re:Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Xuyang
  • Query Regarding encryption support in RocksDB MUKUL GUPTA
  • Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re:Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Xuyang
  • Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re:Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Xuyang
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Venkatakrishnan Sowrirajan
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Venkatakrishnan Sowrirajan
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Venkatakrishnan Sowrirajan
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Xingcan Cui
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Venkatakrishnan Sowrirajan
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Becket Qin
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Becket Qin
  • Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
• [DISCUSS] - Propagation of Startup Errors Luca Castelli
• [VOTE] CHI: Stale PR cleanup Tom Cooper
  • Re: [VOTE] CHI: Stale PR cleanup Gyula Fóra
  • RE: [VOTE] CHI: Stale PR cleanup David Radley
  • Re: [VOTE] CHI: Stale PR cleanup Ron Liu
  • Re: [VOTE] CHI: Stale PR cleanup Rui Fan
  • Re: [VOTE] CHI: Stale PR cleanup Luke Chen
  • Re: [VOTE] CHI: Stale PR cleanup Ahmed Hamdy
  • Re: [VOTE] CHI: Stale PR cleanup Tom Cooper
  • Re: [VOTE] CHI: Stale PR cleanup Hong
  • Re: [VOTE] CHI: Stale PR cleanup Sergey Nuyanzin
  • Re: [VOTE] CHI: Stale PR cleanup Tom Cooper
  • Re: [VOTE] CHI: Stale PR cleanup Andrei Kaigorodov
  • Re: [VOTE] CHI: Stale PR cleanup Venkatakrishnan Sowrirajan
  • Re: [VOTE] CHI: Stale PR cleanup Tom Cooper
• [jira] [Created] (FLINK-37017) Supports complex DataTypes in Flink CDC Leonard Xu (Jira)
• Re: Memory leak in pekko's Netty 4 transport. Alexander Fedulov
  • Re: Memory leak in pekko's Netty 4 transport. PJ Fanning
  • Re: Memory leak in pekko's Netty 4 transport. kerr
  • Re: Memory leak in pekko's Netty 4 transport. Ferenc Csaky
  • Re: Memory leak in pekko's Netty 4 transport. He Pin
• [jira] [Created] (FLINK-37016) NPE when ClusterEntrypoing is shut down before initialization Chesnay Schepler (Jira)
• [jira] [Created] (FLINK-37015) Revise serialization doc to reflect the 2.0 breaking changes properly Zhanghao Chen (Jira)
• [jira] [Created] (FLINK-37014) Examples are wrong in materialized table statment doc Mingcan Wang (Jira)
• [jira] [Created] (FLINK-37013) Job failed to restart on time liting liu (Jira)
• [jira] [Created] (FLINK-37012) Fix exception caused by MetadataColumns causing argument type mismatch MOBIN (Jira)
• [jira] [Created] (FLINK-37011) Improve get source field value by column name in PreTransformProcessor. ChaomingZhang (Jira)
• [jira] [Created] (FLINK-37010) Unify KeyedProcessFunction and the async one Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37009) Migrate PruneAggregateCallRule Jacky Lau (Jira)
• [jira] [Created] (FLINK-37008) Flink UI should show the type of checkpoint (full vs incremental) Ryan van Huuksloot (Jira)
• Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Matthias Pohl
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Maximilian Michels
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Rui Fan
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Maximilian Michels
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Maximilian Michels
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Maximilian Michels
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Zhanghao Chen
• [jira] [Created] (FLINK-37007) FLIP-494: Add missing createTable/createView methods to TableEnvironment Sergey Nuyanzin (Jira)
• [RESULT][VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment Sergey Nuyanzin
• Re: Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment Sergey Nuyanzin
  • Re: Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment Sergey Nuyanzin
• [jira] [Created] (FLINK-36934) Enrich numSubpartitions to TierMasterAgent#addPartitionAndGetShuffleDescriptor Weijie Guo (Jira)
• [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Junrui Lee
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Fabian Paul
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Timo Walther
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xintong Song
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
  • Re: [DISCUSS] FLIP-500: Support Join Extension in DataStream V2 API Xu Huang
• [jira] [Created] (FLINK-37006) Apply changes from FLINK-36277 to AdaptiveJoin Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37005) Make StreamExecDeduplicate ouput insert only where possible Piotr Nowojski (Jira)
• [jira] [Created] (FLINK-37004) Implement Multithreaded SourceReader Hong Liang Teoh (Jira)
• Re: [DISCUSS] Flink 1.18.2 release & grace period for EOL versions Robert Metzger
  • Re: [DISCUSS] Flink 1.18.2 release & grace period for EOL versions Rui Fan
  • Re: [DISCUSS] Flink 1.18.2 release & grace period for EOL versions Matthias Pohl
  • Re: [DISCUSS] Flink 1.18.2 release & grace period for EOL versions Matthias Pohl
• [jira] [Created] (FLINK-37003) Implement async state version of Datastream Interval join Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37002) Migrate DecomposeGroupingSetsRule Jacky Lau (Jira)
• [jira] [Created] (FLINK-37001) Remove all direct uses of `TableEnvironmentInternal#registerTableSinkInternal` in table module xuyang (Jira)
• [jira] [Created] (FLINK-37000) MySQL CDC could not handle date and time data prior to unix epoch yux (Jira)
• [jira] [Created] (FLINK-36999) Null pointer exception when the source field type is decimal and the value is null Jira
• [jira] [Created] (FLINK-36998) The RowKind of data about globalUpsertResult is different in KeyedUpsertingSinkFunction while being inserted or be restored xuyang (Jira)
• [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xu Huang
  • Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Anil Dasari
  • Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xu Huang
  • Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Anil Dasari
  • Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xu Huang
  • Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Junrui Lee
  • Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xu Huang
  • Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Anil Dasari
• [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
  • 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
  • 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
  • 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 Feng Jin
  • 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 Ron Liu
  • 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
• Extend Flink jdbc Trino supported types Christopher Teoh
• Re: Log4j JSONTemplateLayout Ryan van Huuksloot
• [DISCUSS] FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg
  • Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support Timo Walther
  • Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support Dawid Wysakowicz
  • Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg
  • Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg
  • Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support Timo Walther
  • Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support Fabian Hüske
  • Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg
• [jira] [Created] (FLINK-36997) Add Log4j JSONTemplateLayout to Flink-Dist Ryan van Huuksloot (Jira)
• Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Matthias Pohl
  • Re:Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Yuepeng Pan
  • Re: Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Matthias Pohl
  • Re: Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Yuepeng Pan
  • Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Yuepeng Pan
• [jira] [Created] (FLINK-36996) The schema and namespace of MySQL pipeline connector metadata are reversed Thorne (Jira)
• [jira] [Created] (FLINK-36995) Support REPLACE MATERIALIZED TABLE AS statement Feng Jin (Jira)
• [jira] [Created] (FLINK-36994) Support Alter Materialized Table As Query Feng Jin (Jira)
• [jira] [Created] (FLINK-36993) FLIP-492: Support Query Modifications for Materialized Tables Feng Jin (Jira)
• [jira] [Created] (FLINK-36992) Migrate SplitAggregateRule Jacky Lau (Jira)
• [jira] [Created] (FLINK-36991) NPE in BinarySegmentUtils Jira
• [RESULT][VOTE] FLIP-492: Support Query Modifications for Materialized Tables Feng Jin

• Later messages