dev  

Messages by Date

• 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)
• 2025/01/03 [jira] [Created] (FLINK-37000) MySQL CDC could not handle date and time data prior to unix epoch yux (Jira)
• 2025/01/03 [jira] [Created] (FLINK-36999) Null pointer exception when the source field type is decimal and the value is null Jira
• 2025/01/03 [jira] [Created] (FLINK-36998) The RowKind of data about globalUpsertResult is different in KeyedUpsertingSinkFunction while being inserted or be restored xuyang (Jira)
• 2025/01/02 Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Anil Dasari
• 2025/01/02 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
• 2025/01/02 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
• 2025/01/02 [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Xu Huang
• 2025/01/02 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/02 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/02 [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/02 Extend Flink jdbc Trino supported types Christopher Teoh
• 2025/01/02 Re: Log4j JSONTemplateLayout Ryan van Huuksloot
• 2025/01/02 [DISCUSS] FLIP-498: AsyncTableFunction for async table function support Alan Sheinberg
• 2025/01/02 [jira] [Created] (FLINK-36997) Add Log4j JSONTemplateLayout to Flink-Dist Ryan van Huuksloot (Jira)
• 2025/01/02 Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history Matthias Pohl
• 2025/01/02 [jira] [Created] (FLINK-36996) The schema and namespace of MySQL pipeline connector metadata are reversed Thorne (Jira)
• 2025/01/02 [jira] [Created] (FLINK-36995) Support REPLACE MATERIALIZED TABLE AS statement Feng Jin (Jira)
• 2025/01/02 [jira] [Created] (FLINK-36994) Support Alter Materialized Table As Query Feng Jin (Jira)
• 2025/01/02 [jira] [Created] (FLINK-36993) FLIP-492: Support Query Modifications for Materialized Tables Feng Jin (Jira)
• 2025/01/02 [jira] [Created] (FLINK-36992) Migrate SplitAggregateRule Jacky Lau (Jira)
• 2025/01/02 [jira] [Created] (FLINK-36991) NPE in BinarySegmentUtils Jira
• 2025/01/01 [RESULT][VOTE] FLIP-492: Support Query Modifications for Materialized Tables Feng Jin
• 2025/01/01 Re: Re: [VOTE] FLIP-492: Support Query Modifications for Materialized Tables Feng Jin
• 2025/01/01 [jira] [Created] (FLINK-36990) SchemaRegistry fails on failover due to NPE exception caught while executing runnable in main thread zjjiang (Jira)
• 2025/01/01 [jira] [Created] (FLINK-36988) Migrate LogicalCorrelateToJoinFromTemporalTableFunctionRule Jacky Lau (Jira)
• 2025/01/01 [jira] [Created] (FLINK-36987) Mismatched docs with current active ES table connector Yun Tang (Jira)
• 2025/01/01 Re: Dynamic Iceberg Sink Anil Dasari
• 2025/01/01 [jira] [Created] (FLINK-36986) Migrate SplitRemoteConditionFromJoinRule Jacky Lau (Jira)
• 2025/01/01 Re:Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment Xuyang
• 2025/01/01 Re:Re: [VOTE] FLIP-492: Support Query Modifications for Materialized Tables Xuyang
• 2025/01/01 Re: [VOTE] FLIP-492: Support Query Modifications for Materialized Tables Shengkai Fang
• 2025/01/01 申请退订邮件 越张
• 2025/01/01 [jira] [Created] (FLINK-36985) remove Catalog.ColumnAlreadyExistException when apply applyAddColumnEventWithPosition in paimon hiliuxg (Jira)
• 2024/12/31 [jira] [Created] (FLINK-36984) Support precision of SQL FLOOR and CEIL functions for TimeStampLtz Hanyu Zheng (Jira)
• 2024/12/31 [jira] [Created] (FLINK-36983) Observing unreliable IO metrics Anurag Kyal (Jira)
• 2024/12/31 Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment Dawid Wysakowicz
• 2024/12/30 Re: [VOTE] FLIP-492: Support Query Modifications for Materialized Tables Yuepeng Pan
• 2024/12/30 Re: Resolving Flink Backpressure Samrat Deb
• 2024/12/30 [jira] [Created] (FLINK-36982) Failed to run pipeline if using `DATE_FORMAT(NOW(), 'yyyy-MM-dd') as datetime` in Yanquan Lv (Jira)
• 2024/12/30 Re: [Discuss] Kafka Enumerator assigns splits based on the current assignment situation. Hongshun Wang
• 2024/12/30 Re: [Discuss] Kafka Enumerator assigns splits based on the current assignment situation. Ahmed Hamdy
• 2024/12/30 Re: [VOTE] FLIP-492: Support Query Modifications for Materialized Tables Lincoln Lee
• 2024/12/30 Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks Xu Huang
• 2024/12/30 Re: [VOTE] FLIP-492: Support Query Modifications for Materialized Tables Ron Liu
• 2024/12/30 [jira] [Created] (FLINK-36981) The bug of transform merging with route in YAML task Wenkai Qi (Jira)
• 2024/12/30 [jira] [Created] (FLINK-36980) Build a new introductory practice "Streaming ELT from MySQL to Kafka" sukang (Jira)
• 2024/12/29 [REMINDER] 2 weeks away from release 2.0 feature freeze Xintong Song
• 2024/12/29 Re: [Discuss] Kafka Enumerator assigns splits based on the current assignment situation. Hongshun Wang
• 2024/12/29 Re: Memory leak in pekko's Netty 4 transport. ConradJam
• 2024/12/29 Re: [Discuss] Kafka Enumerator assigns splits based on the current assignment situation. Hongshun Wang
• 2024/12/29 [VOTE] FLIP-492: Support Query Modifications for Materialized Tables Feng Jin
• 2024/12/29 Re: [Discuss] Kafka Enumerator assigns splits based on the current assignment situation. Ahmed Hamdy
• 2024/12/29 [jira] [Created] (FLINK-36979) Revert netty bump for 1.20 and 1.19 Matthias Pohl (Jira)
• 2024/12/29 Re: Memory leak in pekko's Netty 4 transport. Matthias Pohl
• 2024/12/29 Re: [DISCUSS] FLIP-467: Introduce Generalized Watermarks Hongshun Wang
• 2024/12/28 Re: Memory leak in pekko's Netty 4 transport. PJ Fanning
• 2024/12/28 Memory leak in pekko's Netty 4 transport. kerr
• 2024/12/28 [jira] [Created] (FLINK-36978) Fix the bug where the command-line option `from-savepoint` is invalid in K8s deployment mode. hiliuxg (Jira)
• 2024/12/28 [jira] [Created] (FLINK-36977) paimon apply default value options when apply add column_schema change hiliuxg (Jira)
• 2024/12/28 [jira] [Created] (FLINK-36976) Bump jackson to 2.18.2 Sergey Nuyanzin (Jira)
• 2024/12/27 [jira] [Created] (FLINK-36975) Invalid ConfigOption for "aws.credentials.provider.role.provider" in AWSConfigOptions Mohsen Rezaei (Jira)
• 2024/12/27 [jira] [Created] (FLINK-36974) support overwrite flink config by command line hiliuxg (Jira)
• 2024/12/27 [jira] [Created] (FLINK-36973) udf dateformat support LocalZonedTimestampData hiliuxg (Jira)
• 2024/12/27 申请退订邮件 樊跃翔
• 2024/12/27 [jira] [Created] (FLINK-36972) Unify AWS sink implementation Ahmed Hamdy (Jira)
• 2024/12/27 [jira] [Created] (FLINK-36971) Add Sqs Sink SQL connector Ahmed Hamdy (Jira)
• 2024/12/27 [jira] [Created] (FLINK-36969) Merge result of data type BIGINT and DOUBLE should be DOUBLE instead of STRING Xiao Huang (Jira)
• 2024/12/27 [jira] [Created] (FLINK-36970) Merge result of data type BIGINT and DOUBLE should be DOUBLE instead of STRING Xiao Huang (Jira)
• 2024/12/26 [jira] [Created] (FLINK-36968) The "values" lookup table used for testing does not deduplicate data with the same key. xuyang (Jira)
• 2024/12/26 [Discuss] Kafka Enumerator assigns splits based on the current assignment situation. Hongshun Wang
• 2024/12/26 [jira] [Created] (FLINK-36967) Bump dependency of Paimon Pipeline connector to 0.9.0 Jeff Yang (Jira)
• 2024/12/26 Re: Resolving Flink Backpressure Samrat Deb
• 2024/12/26 [jira] [Created] (FLINK-36966) Bump mockito to 5.x Sergey Nuyanzin (Jira)
• 2024/12/25 Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables. Feng Jin
• 2024/12/25 [jira] [Created] (FLINK-36965) Enable to allow re-create the pod watch with many retries on k8s cluster failure Yun Tang (Jira)
• 2024/12/25 [jira] [Created] (FLINK-36964) Fix potential exception when SchemaChange in parallel with Paimon Sink. Yanquan Lv (Jira)
• 2024/12/25 Re: [DISCUSS] FLIP-496: SQL connector for keyed state data Gabor Somogyi
• 2024/12/25 [jira] [Created] (FLINK-36963) Wrong context maintain around `asyncProcessWithKey` Zakelly Lan (Jira)
• 2024/12/25 [jira] [Created] (FLINK-36962) push down non-deterministic filter after stream join to source by mistake Shuai Xu (Jira)
• 2024/12/25 [jira] [Created] (FLINK-36961) Wait ForSt state excutor shutdown when disposing Yanfei Lei (Jira)
• 2024/12/24 [RESULT][VOTE] FLIP-467: Introduce Generalized Watermarks Xu Huang
• 2024/12/24 [Discuss] FLIP-485: Flink UDF metrics Linda Li
• 2024/12/24 [jira] [Created] (FLINK-36960) FLIP-467 Introduce Generalized Watermarks for DataStream V2 xuhuang (Jira)
• 2024/12/24 [jira] [Created] (FLINK-36959) Computing readable buffer offsets and sizes when including empty buffers fails. Junrui Lee (Jira)
• 2024/12/24 [jira] [Created] (FLINK-36958) Support pipeline-connector-kafka to reuse csv, canal-json and debezium-json Format Options MOBIN (Jira)
• 2024/12/23 Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment Feng Jin
• 2024/12/23 [jira] [Created] (FLINK-36957) Implement async StreamFlatMap Yanfei Lei (Jira)
• 2024/12/23 Re: Resolving Flink Backpressure Mohammad Aamir Iqubal
• 2024/12/23 [jira] [Created] (FLINK-36956) Pipeline transform should deduce PK column types to be NOT NULL yux (Jira)
• 2024/12/23 Re: [DISCUSS] FLIP-496: SQL connector for keyed state data Venkatakrishnan Sowrirajan
• 2024/12/23 [jira] [Created] (FLINK-36955) Migrate RewriteIntersectAllRule Jacky Lau (Jira)
• 2024/12/23 Re: [DISCUSS] FLIP-496: SQL connector for keyed state data Shengkai Fang
• 2024/12/23 Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment Yuepeng Pan
• 2024/12/23 Re: [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment Ron Liu
• 2024/12/23 [jira] [Created] (FLINK-36954) Migrate CalcRankTransposeRule Jacky Lau (Jira)
• 2024/12/23 [jira] [Created] (FLINK-36953) FLIP-497: Early Fire Support for Flink SQL Interval Join Weiqing Yang (Jira)
• 2024/12/23 Re: [DISCUSS] FLIP-496: SQL connector for keyed state data Gabor Somogyi
• 2024/12/23 [jira] [Created] (FLINK-36952) fix mongodb chinese doc Thorne (Jira)
• 2024/12/22 [jira] [Created] (FLINK-36951) Migrate ProjectSemiAntiJoinTransposeRule Jacky Lau (Jira)
• 2024/12/22 [DISCUSS] Early Fire Support for Flink SQL Interval Join Weiqing Yang
• 2024/12/22 [jira] [Created] (FLINK-36950) Migrate WindowPropertiesRules Jacky Lau (Jira)
• 2024/12/22 [jira] [Created] (FLINK-36949) Make getCurrentKey of async state operators return the ground truth Zakelly Lan (Jira)
• 2024/12/22 Re: [DISCUSS] FLIP-496: SQL connector for keyed state data Shengkai Fang
• 2024/12/22 Re: [VOTE] FLIP-467: Introduce Generalized Watermarks Yunfeng Zhou
• 2024/12/22 [jira] [Created] (FLINK-36948) Drop deprecated FlinkMatchers Sergey Nuyanzin (Jira)
• 2024/12/21 Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status gyula . fora
• 2024/12/21 Re: Slack Invite Yun Tang
• 2024/12/20 Slack Invite Fadojutimi, Bowofola (Toye)
• 2024/12/20 Flink technical debt. Chi meeting David Radley
• 2024/12/20 RE: [VOTE] FLIP-493: Add K8S conditions to CRD's Status David Radley
• 2024/12/20 Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status gyula . fora
• 2024/12/20 [VOTE] FLIP-493: Add K8S conditions to CRD's Status Lajith Koova
• 2024/12/20 [jira] [Created] (FLINK-36947) Rate limiting the GetRecord call frequency Burak Ozakinci (Jira)
• 2024/12/20 [jira] [Created] (FLINK-36946) optimize sink operator name truncate tartarus (Jira)
• 2024/12/20 [VOTE] FLIP-494: Add missing createTable/createView methods to TableEnvironment Sergey Nuyanzin
• 2024/12/20 [jira] [Created] (FLINK-36945) MySQL CDC internal schema representation becomes out of sync with the real database schema when restarting a job Yohei Yoshimuta (Jira)
• 2024/12/20 [jira] [Created] (FLINK-36944) Introduce 'enableAsycState' in DataStream v1 interfaces Zakelly Lan (Jira)
• 2024/12/20 Re: [VOTE] FLIP-467: Introduce Generalized Watermarks weijie guo
• 2024/12/20 Re: [VOTE] FLIP-467: Introduce Generalized Watermarks Junrui Lee
• 2024/12/20 Re: [VOTE] FLIP-467: Introduce Generalized Watermarks Xintong Song
• 2024/12/20 [jira] [Created] (FLINK-36943) FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs Zakelly Lan (Jira)
• 2024/12/20 [RESULT][VOTE] FLIP-488: Expose Async State Processing and New State APIs in Datastream(V1) APIs Zakelly Lan

• Earlier messages
• Later messages