dev

Messages by Date

2025/02/23 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Lincoln Lee
2025/02/23 Re: [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner Zhanghao Chen
2025/02/22 Integrating LLMs into apache flink pipelines Ganesh
2025/02/22 [VOTE] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
2025/02/22 [jira] [Created] (FLINK-37371) Postgres CDC incremental source fails to handle upper-case table and column names Sergei Morozov (Jira)
2025/02/21 Request for PMC help to move forward with release of flink-shaded Sergey Nuyanzin
2025/02/21 [RESULT] [VOTE] Release flink-shaded 20.0, release candidate #1 Sergey Nuyanzin
2025/02/21 Re: [VOTE] Release flink-shaded 20.0, release candidate #1 Sergey Nuyanzin
2025/02/21 This weeks Community Health Initiative (CHI) meeting David Radley
2025/02/21 [jira] [Created] (FLINK-37370) [Observer] Finished batch jobs throw ReconciliationException and never reach FINISHED in the CR Luca Castelli (Jira)
2025/02/21 Re: [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0 Alexander Fedulov
2025/02/21 Re: [DISCUSS] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State Han Yin
2025/02/21 [jira] [Created] (FLINK-37369) Flink CDC OceanBase Connector Throws Exception for Column DEFAULT VALUE CURRENT_TIMESTAMP caixiaowei (Jira)
2025/02/21 [jira] [Created] (FLINK-37368) MySQL Pipeline job failed to checkpoint after closing idle readers yux (Jira)
2025/02/21 [jira] [Created] (FLINK-37367) Properly inherit uploaded SST files after ForSt restore Zakelly Lan (Jira)
2025/02/20 Re: [ANNOUNCE] New Apache Flink Committer - Feng Jin Leonard Xu
2025/02/20 [jira] [Created] (FLINK-37366) Allow configurable retry for Kafka topic metadata fetch Shuyi Chen (Jira)
2025/02/20 Re: 回复：[ANNOUNCE] New Apache Flink Committer - Feng Jin Jacky Lau
2025/02/20 [DISCUSSION] Upgrade to Kryo 5 for Flink 2.0 Gyula Fóra
2025/02/20 Re: [ANNOUNCE] New Apache Flink Committer - Feng Jin Shengkai Fang
2025/02/20 Re:回复：[ANNOUNCE] New Apache Flink Committer - Feng Jin Xuyang
2025/02/20 Re: [ANNOUNCE] New Apache Flink Committer - Feng Jin Ron Liu
2025/02/20 Re:[ANNOUNCE] New Apache Flink Committer - Feng Jin Yuepeng Pan
2025/02/20 [ANNOUNCE] New Apache Flink Committer - Feng Jin Lincoln Lee
2025/02/20 Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Poorvank Bhatia
2025/02/20 [jira] [Created] (FLINK-37365) Add API stability annotations (@Experimental, @PublicEvolving) to PyFlink APIs Mika Naylor (Jira)
2025/02/20 Re: [DISCUSS] Adding API stability annotations (@Experimental, @PublicEvolving) to PyFlink APIs Mika Naylor
2025/02/20 Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Poorvank Bhatia
2025/02/20 Re: [DISCUSS] Adding API stability annotations (@Experimental, @PublicEvolving) to PyFlink APIs Ferenc Csaky
2025/02/20 [jira] [Created] (FLINK-37364) Bump Flink 1.19, 1.20 patch versions in Flink CDC Ferenc Csaky (Jira)
2025/02/20 [jira] [Created] (FLINK-37362) PolardbxCharsetITCase test has timed out after 60 minutes Leonard Xu (Jira)
2025/02/20 Re: [DISCUSS] Adding API stability annotations (@Experimental, @PublicEvolving) to PyFlink APIs Dian Fu
2025/02/20 [jira] [Created] (FLINK-37363) Remove confusing and duplicated state.backend.type config from state SQL connector Gabor Somogyi (Jira)
2025/02/20 [jira] [Created] (FLINK-37361) Update japicmp configuration post 1.19.2 Alexander Fedulov (Jira)
2025/02/20 [jira] [Created] (FLINK-37360) Update japicmp configuration post 1.20.1 Alexander Fedulov (Jira)
2025/02/20 Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Arvid Heise
2025/02/20 [jira] [Created] (FLINK-37359) Docker build fails for Kubernetes operator Gyula Fora (Jira)
2025/02/20 Re: [VOTE] Release flink-shaded 20.0, release candidate #1 Martijn Visser
2025/02/20 Re: [DISCUSS] Adding API stability annotations (@Experimental, @PublicEvolving) to PyFlink APIs Timo Walther
2025/02/20 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang Feng Jin
2025/02/20 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang gongzhongqiang
2025/02/20 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang weijie guo
2025/02/19 [jira] [Created] (FLINK-37358) Support pass format options to kafka pipeline sink Xiao Huang (Jira)
2025/02/19 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang ConradJam
2025/02/19 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang Jingsong Li
2025/02/19 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang Sergey Nuyanzin
2025/02/19 [jira] [Created] (FLINK-37357) Migrating conversion logic to SqlNodeConverters Hirson Zhang (Jira)
2025/02/19 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang Hongshun Wang
2025/02/19 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang Shawn Huang
2025/02/19 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang Yanquan Lv
2025/02/19 退订于峰13
2025/02/19 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang Jacky Lau
2025/02/19 退订李乐
2025/02/19 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang Zakelly Lan
2025/02/19 退订李乐
2025/02/19 [jira] [Created] (FLINK-37356) Recycle use of kafka producer(which commit error) will send data without AddPartitionsToTxnRequest Hongshun Wang (Jira)
2025/02/19 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang Junrui Lee
2025/02/19 [ANNOUNCE] New Apache Flink Committer - Xuyang Lincoln Lee
2025/02/19 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang yh z
2025/02/19 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang Shengkai Fang
2025/02/19 Re: [ANNOUNCE] New Apache Flink Committer - Xuyang Ron Liu
2025/02/19 [jira] [Created] (FLINK-37355) When using the DataStream API of Flink CDC 3.3.0 and setting the tableList to database_name.*, it fails to restore from the checkpoint. longwang0616 (Jira)
2025/02/19 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
2025/02/19 Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Danny Cranmer
2025/02/19 Re: Re: Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join Becket Qin
2025/02/19 Re: [VOTE] FLIP-507: Add Model DDL methods in TABLE API Hao Li
2025/02/19 Re: [RESULT] [VOTE] Release 1.19.2, release candidate #1 Alexander Fedulov
2025/02/19 Re: [ANNOUNCE] Apache Flink 1.20.1 released Ferenc Csaky
2025/02/19 Re: [ANNOUNCE] Apache Flink 1.19.2 released Ferenc Csaky
2025/02/19 Re: [VOTE] Release flink-shaded 20.0, release candidate #1 Dawid Wysakowicz
2025/02/19 Re: [ANNOUNCE] Apache Flink 1.19.2 released Alexander Fedulov
2025/02/19 [ANNOUNCE] Apache Flink 1.19.2 released Alexander Fedulov
2025/02/19 Re: [ANNOUNCE] Apache Flink 1.20.1 released Alexander Fedulov
2025/02/19 [DISCUSS] Adding API stability annotations (@Experimental, @PublicEvolving) to PyFlink APIs Mika Naylor
2025/02/19 [ANNOUNCE] Apache Flink 1.20.1 released Alexander Fedulov
2025/02/19 [jira] [Created] (FLINK-37354) Kubernetes Operator HealthCheck compatibility Anton Solovev (Jira)
2025/02/19 [jira] [Created] (FLINK-37353) [Doc] Add doc for scan.incremental.snapshot.chunk.key-column Mysql Data Sink Yanquan Lv (Jira)
2025/02/19 [jira] [Created] (FLINK-37352) Write full changelog to Paimon Sink. Yanquan Lv (Jira)
2025/02/19 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
2025/02/19 Re: [VOTE] Release flink-shaded 20.0, release candidate #1 Timo Walther
2025/02/19 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
2025/02/19 [jira] [Created] (FLINK-37351) Ensure writer and committer are colocated Arvid Heise (Jira)
2025/02/19 [SUMMARY] Flink 2.0 Release Sync 02/19/2015 Xintong Song
2025/02/18 [jira] [Created] (FLINK-37350) Memory leak caused by skewed join optimization strategy Lei Yang (Jira)
2025/02/18 [jira] [Created] (FLINK-37349) Add timeout for test case that call waitForSinkSize method to avoid Infinite waiting Yanquan Lv (Jira)
2025/02/18 [jira] [Created] (FLINK-37348) [pipeline-paimon]fix paimon ArrayIndexOutOfBoundsException when add column before first_column MOBIN (Jira)
2025/02/18 [jira] [Created] (FLINK-37347) [docs ]Support any columns as chunk key column (postgres, orcale, db2, sqlserver) Lee SeungMin (Jira)
2025/02/18 [jira] [Created] (FLINK-37346) [CI] Unit Tests (mysql) / compile_and_test (8, generic) (pull_request)Failing after 60m Yanquan Lv (Jira)
2025/02/18 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
2025/02/18 Re: Plans for JDBC connector for 1.20? Yanquan Lv
2025/02/18 [VOTE] FLIP-507: Add Model DDL methods in TABLE API Yash Anand
2025/02/18 Re: Flink 1.18.2 release date Ferenc Csaky
2025/02/18 [VOTE] Release flink-shaded 20.0, release candidate #1 Sergey Nuyanzin
2025/02/18 [jira] [Created] (FLINK-37345) [BUG] ClassCastException zexin gong (Jira)
2025/02/18 [jira] [Created] (FLINK-37344) setup_hugo.sh should install the hugo binary only Gabor Somogyi (Jira)
2025/02/18 Re: [DISCUSS] Release flink-shaded 20.0 Tom Cooper
2025/02/18 [DISCUSS] Release flink-shaded 20.0 Sergey Nuyanzin
2025/02/18 [jira] [Created] (FLINK-37343) Support for Dynamic Table Selection in DynamoDB Sink Connector Alex Aranovsky (Jira)
2025/02/18 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Cong Cheng
2025/02/17 [jira] [Created] (FLINK-37339) Add documentation about JDK21 support Weijie Guo (Jira)
2025/02/17 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Kevin Cheng
2025/02/17 [jira] [Created] (FLINK-37342) Add support for smile format in flink-shaded Sergey Nuyanzin (Jira)
2025/02/17 [jira] [Created] (FLINK-37341) FLIP-508: Add support for Smile format for Compiled plans Sergey Nuyanzin (Jira)
2025/02/17 [RESULT][VOTE] FLIP-508: Add support for Smile format for Compiled plans Sergey Nuyanzin
2025/02/17 [jira] [Created] (FLINK-37340) Flink Flink supports pushing metrics immediately at the end of the task. lizhiqiang (Jira)
2025/02/17 Re: [VOTE] FLIP-508: Add support for Smile format for Compiled plans Sergey Nuyanzin
2025/02/17 [jira] [Created] (FLINK-37338) Cross-team verification for " Support Java 21(LTS)" Weijie Guo (Jira)
2025/02/17 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
2025/02/17 [KINDLY REMINDER] Flink 2.0 Release Sync 02/19/2025 Xintong Song
2025/02/17 [jira] [Created] (FLINK-37337) Deploy script SQL Client in Embedded Mode to Kubernetes Results in FileNotFoundException Feng Jin (Jira)
2025/02/17 Re: Question about in-place rescaling support in Flink k8s operator Maximilian Michels
2025/02/17 [jira] [Created] (FLINK-37336) Introduce TablePipeline to Python API Mika Naylor (Jira)
2025/02/17 Re: [VOTE] FLIP-508: Add support for Smile format for Compiled plans Martijn Visser
2025/02/17 [jira] [Created] (FLINK-37335) ForSt fails to generate the first checkpoint in IncrementalCP and NO_CLAIM mode. Han Yin (Jira)
2025/02/17 Re: Introduce TDengine connector 门世斌
2025/02/17 [jira] [Created] (FLINK-37334) Fix mysql's add column after event becomes add column last MOBIN (Jira)
2025/02/16 [jira] [Created] (FLINK-37333) Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect xingbe (Jira)
2025/02/16 Re: [DISCUSS] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State Zakelly Lan
2025/02/15 [jira] [Created] (FLINK-37332) Support any columns as chunk key column (postgres, orcale, db2, sqlserver) Lee SeungMin (Jira)
2025/02/15 [jira] [Created] (FLINK-37331) Add comprehensive data type coverage tests for new MysqlSource implementation ronghangye (Jira)
2025/02/15 [jira] [Created] (FLINK-37330) Add state migration test for Flink 2.0 Arvid Heise (Jira)
2025/02/15 [jira] [Created] (FLINK-37329) Skip Source Stats Collection When "table.optimizer.source.report-statistics-enabled Syed Shameerur Rahman (Jira)
2025/02/14 [jira] [Created] (FLINK-37328) Upgrade GCS Connector to 2.2.26. Chris Nauroth (Jira)
2025/02/14 Question about in-place rescaling support in Flink k8s operator JIAZHOU GAO
2025/02/14 [VOTE] FLIP-491: BundledAggregateFunction for batched aggregation Alan Sheinberg
2025/02/14 [jira] [Created] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows Kevin Lam (Jira)
2025/02/14 [DISCUSS] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State Han Yin
2025/02/14 [jira] [Created] (FLINK-37326) The transform module reports an error when column is a Java keyword zexin gong (Jira)
2025/02/14 Re: Flink 1.18.2 release date Yang LI
2025/02/14 [jira] [Created] (FLINK-37325) SQL connector for keyed savepoint data Chinese documentation Gabor Somogyi (Jira)
2025/02/14 [jira] [Created] (FLINK-37324) RocksDB keys iterator performance improvement Gabor Somogyi (Jira)
2025/02/14 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Kevin Cheng
2025/02/13 Re: Migrating CI to Github Actions Matthias Pohl
2025/02/13 Re: [DISCUSS] Elasticsearch v3.1 release weijie guo
2025/02/13 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
2025/02/13 退订 cun8cun8
2025/02/13 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
2025/02/13 [jira] [Created] (FLINK-37323) Checkpoint Growth & Akka FrameSize Exception when Migrating from FlinkKafkaProducer to KafkaSink Zimehr Abbasi (Jira)
2025/02/13 [jira] [Created] (FLINK-37322) surport eval groovy scripts udf for flink sql tianyuan (Jira)
2025/02/13 Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation Alan Sheinberg
2025/02/13 [jira] [Created] (FLINK-37321) Make window functions with wrong input fail during planning rather than runtime Sergey Nuyanzin (Jira)
2025/02/13 [jira] [Created] (FLINK-37320) FINISHED jobs incorrectly being set to RECONCILING Luca Castelli (Jira)
2025/02/13 [jira] [Created] (FLINK-37319) Add retry in RocksDBStateUploader for fault tolerant Zhenqiu Huang (Jira)
2025/02/13 Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Ahmed Hamdy
2025/02/13 Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation Timo Walther
2025/02/13 Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Ahmed Hamdy
2025/02/13 2025/02/13 CHI Eastern time zone workgroup meeting minutes David Radley
2025/02/13 Migrating CI to Github Actions Tom Cooper
2025/02/13 Re: Kafka connector releases Arvid Heise
2025/02/13 Re: Kafka connector releases Yanquan Lv
2025/02/13 Re: [VOTE] FLIP-508: Add support for Smile format for Compiled plans Samrat Deb
2025/02/13 Re: [VOTE] FLIP-508: Add support for Smile format for Compiled plans Fabian Hüske
2025/02/13 Re: [VOTE] FLIP-508: Add support for Smile format for Compiled plans David Radley
2025/02/13 Re: [VOTE] FLIP-508: Add support for Smile format for Compiled plans Timo Walther
2025/02/13 [VOTE] FLIP-508: Add support for Smile format for Compiled plans Sergey Nuyanzin
2025/02/13 [jira] [Created] (FLINK-37318) RocksDBKeyedStateBackend disposed before task exit Feifan Wang (Jira)
2025/02/13 [jira] [Created] (FLINK-37317) Checkpoint asyncOperationsThreadPool has only one thread running Jufang He (Jira)
2025/02/13 [jira] [Created] (FLINK-37316) Add StateManager#getStateOptional and StateManager#getState methods for DataStream V2 xuhuang (Jira)
2025/02/13 Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Poorvank Bhatia
2025/02/13 Re: [RESULT] [VOTE] Release 1.19.2, release candidate #1 Zach Zhang
2025/02/12 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
2025/02/12 [jira] [Created] (FLINK-37315) Improve SelectivityEstimator#estimateEquals for columns in VARCHAR type Biao Geng (Jira)
2025/02/12 [jira] [Created] (FLINK-37314) The watermark and lateness document has an error which may mislead users Liu (Jira)
2025/02/12 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
2025/02/12 Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
2025/02/12 [jira] [Created] (FLINK-37313) [BUG] MySQL snapshot read phase is unresponsive for a long time (even up to several hours) zexin gong (Jira)
2025/02/12 Re: [DISCUSS] FLIP:507 Add Model DDL methods in TABLE API Yash Anand
2025/02/12 Re: [DISCUSS] FLIP:507 Add Model DDL methods in TABLE API Mingge Deng
2025/02/12 [jira] [Created] (FLINK-37312) Missing closing tab in state_v2.md Gabor Somogyi (Jira)
2025/02/12 [jira] [Created] (FLINK-37311) Fix doc generation issues with new version of hugo Gabor Somogyi (Jira)
2025/02/12 [jira] [Created] (FLINK-37310) SQL connector for keyed savepoint data documentation Gabor Somogyi (Jira)
2025/02/12 [OUTAGE] Flink build is affected by latest net.minidev:json-smart release David Morávek
2025/02/12 Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Ahmed Hamdy
2025/02/12 Re: [RESULT] [VOTE] Release 1.20.1, release candidate #1 Alexander Fedulov
2025/02/12 [SUMMARY] Flink 2.0 Release Sync 02/12/2015 Xintong Song
2025/02/12 [jira] [Created] (FLINK-37309) Skewed join optimization not working as expected Lei Yang (Jira)
2025/02/11 [jira] [Created] (FLINK-37308) HybridSourceReader doesn't support pauseOrResumeSplits Xingcan Cui (Jira)
2025/02/11 [jira] [Created] (FLINK-37307) Flink CDC CI failed due to OceanBaseE2eITCase JunboWang (Jira)
2025/02/11 [jira] [Created] (FLINK-37306) Flink CDC CI failed due to timezone shift Leonard Xu (Jira)
2025/02/11 [jira] [Created] (FLINK-37305) JDBC Connector CI failed due to network issue Leonard Xu (Jira)
2025/02/11 [jira] [Created] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO Leonard Xu (Jira)
2025/02/11 Re:Re: [VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join Xuyang
2025/02/11 Re: [RESULT] [VOTE] Release 1.19.2, release candidate #1 Leonard Xu
2025/02/11 退订乔志权
2025/02/11 [ANNOUNCE] Apache flink-connector-hive 3.0.0 released Sergey Nuyanzin
2025/02/11 [jira] [Created] (FLINK-37303) Bump guava to 33.4.0 Sergey Nuyanzin (Jira)
2025/02/11 Re: [DISCUSS] FLIP-508: Add support for Smile format for Compiled plans Sergey Nuyanzin
2025/02/11 Re: [DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Sergio Chong Loo
2025/02/11 [RESULT] [VOTE] Release 1.20.1, release candidate #1 Alexander Fedulov
2025/02/11 Re: [VOTE] Release 1.20.1, release candidate #1 Alexander Fedulov
2025/02/11 [RESULT] [VOTE] Release 1.19.2, release candidate #1 Alexander Fedulov
2025/02/11 Re: [VOTE] Release 1.19.2, release candidate #1 Alexander Fedulov
2025/02/11 [jira] [Created] (FLINK-37301) Fix wrong flag returned by ForStStateBackend#supportsSavepointFormat Zakelly Lan (Jira)
2025/02/11 [jira] [Created] (FLINK-37302) Support timers in PTFs Timo Walther (Jira)
2025/02/11 Re: [VOTE] Release 1.19.2, release candidate #1 Robert Metzger
2025/02/11 Re: [VOTE] Release 1.20.1, release candidate #1 Leonard Xu
2025/02/11 Re: [VOTE] Release 1.19.2, release candidate #1 Leonard Xu
2025/02/11 Re: [VOTE] Release 1.19.2, release candidate #1 Márton Balassi
2025/02/11 [DISCUSS] Pluggable Batching for Async Sink in Flink Poorvank Bhatia
2025/02/11 [jira] [Created] (FLINK-37300) Add database native type information to Column struct to generate ddl correctly He Wang (Jira)