dev  

Messages by Thread

• [jira] [Created] (FLINK-37335) ForSt fails to generate the first checkpoint in IncrementalCP and NO_CLAIM mode. Han Yin (Jira)
• [jira] [Created] (FLINK-37334) Fix mysql's add column after event becomes add column last MOBIN (Jira)
• [jira] [Created] (FLINK-37333) Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect xingbe (Jira)
• [jira] [Created] (FLINK-37332) Support any columns as chunk key column (postgres, orcale, db2, sqlserver) Lee SeungMin (Jira)
• [jira] [Created] (FLINK-37331) Add comprehensive data type coverage tests for new MysqlSource implementation ronghangye (Jira)
• [jira] [Created] (FLINK-37330) Add state migration test for Flink 2.0 Arvid Heise (Jira)
• [jira] [Created] (FLINK-37329) Skip Source Stats Collection When "table.optimizer.source.report-statistics-enabled Syed Shameerur Rahman (Jira)
• [jira] [Created] (FLINK-37328) Upgrade GCS Connector to 2.2.26. Chris Nauroth (Jira)
• Question about in-place rescaling support in Flink k8s operator JIAZHOU GAO
  • Re: Question about in-place rescaling support in Flink k8s operator Maximilian Michels
• [VOTE] FLIP-491: BundledAggregateFunction for batched aggregation Alan Sheinberg
  • Re: [VOTE] FLIP-491: BundledAggregateFunction for batched aggregation Timo Walther
  • Re: [VOTE] FLIP-491: BundledAggregateFunction for batched aggregation Fabian Hüske
  • Re: [VOTE] FLIP-491: BundledAggregateFunction for batched aggregation Stefan Richter
  • Re: [VOTE] FLIP-491: BundledAggregateFunction for batched aggregation Martijn Visser
• [jira] [Created] (FLINK-37327) Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows Kevin Lam (Jira)
• [DISCUSS] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State Han Yin
  • Re: [DISCUSS] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State Zakelly Lan
  • Re: [DISCUSS] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State Han Yin
  • Re: [DISCUSS] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State Yanfei Lei
  • Re: [DISCUSS] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State Han Yin
  • Re: [DISCUSS] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State Han Yin
• [jira] [Created] (FLINK-37326) The transform module reports an error when column is a Java keyword zexin gong (Jira)
• Re: Flink 1.18.2 release date Yang LI
  • Re: Flink 1.18.2 release date Ferenc Csaky
• [jira] [Created] (FLINK-37325) SQL connector for keyed savepoint data Chinese documentation Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-37324) RocksDB keys iterator performance improvement Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-37323) Checkpoint Growth & Akka FrameSize Exception when Migrating from FlinkKafkaProducer to KafkaSink Zimehr Abbasi (Jira)
• [jira] [Created] (FLINK-37322) surport eval groovy scripts udf for flink sql tianyuan (Jira)
• [jira] [Created] (FLINK-37321) Make window functions with wrong input fail during planning rather than runtime Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-37320) FINISHED jobs incorrectly being set to RECONCILING Luca Castelli (Jira)
• [jira] [Created] (FLINK-37319) Add retry in RocksDBStateUploader for fault tolerant Zhenqiu Huang (Jira)
• 2025/02/13 CHI Eastern time zone workgroup meeting minutes David Radley
• Migrating CI to Github Actions Tom Cooper
  • Re: Migrating CI to Github Actions Matthias Pohl
• Re: Kafka connector releases Yanquan Lv
  • Re: Kafka connector releases Arvid Heise
• [VOTE] FLIP-508: Add support for Smile format for Compiled plans Sergey Nuyanzin
  • Re: [VOTE] FLIP-508: Add support for Smile format for Compiled plans Timo Walther
  • Re: [VOTE] FLIP-508: Add support for Smile format for Compiled plans David Radley
  • Re: [VOTE] FLIP-508: Add support for Smile format for Compiled plans Fabian Hüske
  • Re: [VOTE] FLIP-508: Add support for Smile format for Compiled plans Samrat Deb
  • Re: [VOTE] FLIP-508: Add support for Smile format for Compiled plans Martijn Visser
  • Re: [VOTE] FLIP-508: Add support for Smile format for Compiled plans Sergey Nuyanzin
• [jira] [Created] (FLINK-37318) RocksDBKeyedStateBackend disposed before task exit Feifan Wang (Jira)
• [jira] [Created] (FLINK-37317) Checkpoint asyncOperationsThreadPool has only one thread running Jufang He (Jira)
• [jira] [Created] (FLINK-37316) Add StateManager#getStateOptional and StateManager#getState methods for DataStream V2 xuhuang (Jira)
• [jira] [Created] (FLINK-37315) Improve SelectivityEstimator#estimateEquals for columns in VARCHAR type Biao Geng (Jira)
• [jira] [Created] (FLINK-37314) The watermark and lateness document has an error which may mislead users Liu (Jira)
• [jira] [Created] (FLINK-37313) [BUG] MySQL snapshot read phase is unresponsive for a long time (even up to several hours) zexin gong (Jira)
• [jira] [Created] (FLINK-37312) Missing closing tab in state_v2.md Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-37311) Fix doc generation issues with new version of hugo Gabor Somogyi (Jira)
• [jira] [Created] (FLINK-37310) SQL connector for keyed savepoint data documentation Gabor Somogyi (Jira)
• [OUTAGE] Flink build is affected by latest net.minidev:json-smart release David Morávek
• [SUMMARY] Flink 2.0 Release Sync 02/12/2015 Xintong Song
• [jira] [Created] (FLINK-37309) Skewed join optimization not working as expected Lei Yang (Jira)
• [jira] [Created] (FLINK-37308) HybridSourceReader doesn't support pauseOrResumeSplits Xingcan Cui (Jira)
• [jira] [Created] (FLINK-37307) Flink CDC CI failed due to OceanBaseE2eITCase JunboWang (Jira)
• [jira] [Created] (FLINK-37306) Flink CDC CI failed due to timezone shift Leonard Xu (Jira)
• [jira] [Created] (FLINK-37305) JDBC Connector CI failed due to network issue Leonard Xu (Jira)
• [jira] [Created] (FLINK-37304) Dynamic Kafka Source logs credentials in plaintext under INFO Leonard Xu (Jira)
• [ANNOUNCE] Apache flink-connector-hive 3.0.0 released Sergey Nuyanzin
• [jira] [Created] (FLINK-37303) Bump guava to 33.4.0 Sergey Nuyanzin (Jira)
• [RESULT] [VOTE] Release 1.20.1, release candidate #1 Alexander Fedulov
  • Re: [RESULT] [VOTE] Release 1.20.1, release candidate #1 Alexander Fedulov
• [RESULT] [VOTE] Release 1.19.2, release candidate #1 Alexander Fedulov
  • Re: [RESULT] [VOTE] Release 1.19.2, release candidate #1 Leonard Xu
  • Re: [RESULT] [VOTE] Release 1.19.2, release candidate #1 Zach Zhang
  • Re: [RESULT] [VOTE] Release 1.19.2, release candidate #1 Alexander Fedulov
• [jira] [Created] (FLINK-37301) Fix wrong flag returned by ForStStateBackend#supportsSavepointFormat Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37302) Support timers in PTFs Timo Walther (Jira)
• [DISCUSS] Pluggable Batching for Async Sink in Flink Poorvank Bhatia
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Ahmed Hamdy
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Poorvank Bhatia
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Ahmed Hamdy
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Ahmed Hamdy
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Danny Cranmer
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Arvid Heise
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Poorvank Bhatia
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Poorvank Bhatia
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Arvid Heise
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Poorvank Bhatia
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Poorvank Bhatia
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Poorvank Bhatia
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Doğuşcan Namal
  • Re: [DISCUSS] Pluggable Batching for Async Sink in Flink Poorvank Bhatia
• [jira] [Created] (FLINK-37300) Add database native type information to Column struct to generate ddl correctly He Wang (Jira)
• Flink CDC to Paimon Taher Koitawala
  • Re: Flink CDC to Paimon Xiqian YU
  • Re: Flink CDC to Paimon Leonard Xu
  • Re: Flink CDC to Paimon Taher Koitawala
  • Re: Flink CDC to Paimon Taher Koitawala
  • Re: Flink CDC to Paimon Taher Koitawala
• [jira] [Created] (FLINK-37299) flink stateless startup cannot continue consuming from the current location of the consumer group Quan Limin (Jira)
• [jira] [Created] (FLINK-37298) Custom Batch Handling in AsyncSink Poorvank Bhatia (Jira)
• [jira] [Created] (FLINK-37297) Either type Pojo deserialization fails with NPE Daniel Lopes (Jira)
• [jira] [Created] (FLINK-37296) Add ability to add File Level Header in the File Sink forRowFormat kyle n (Jira)
• [KINDLY REMINDER] Flink 2.0 Release Sync 02/12/2025 Xintong Song
• [jira] [Created] (FLINK-37294) Support state migration between disabling and enabling ttl in HeapKeyedStateBackend xiangyu feng (Jira)
• [jira] [Created] (FLINK-37295) Update state ttl migration compatibility in docs xiangyu feng (Jira)
• [jira] [Created] (FLINK-37293) Length of Binary type is missing in OceanBase pipeline connector He Wang (Jira)
• [jira] [Created] (FLINK-37292) The Flink-Kubernetes dependency embedded in the packaging of flink-cdc-dist is incompatible with Flink 1.20. Wenkai Qi (Jira)
• [jira] [Created] (FLINK-37291) Weekly Kafka CI detects producer leaks Martijn Visser (Jira)
• [jira] [Created] (FLINK-37290) Introduce endPartition to DataStream V2 ProcessFunction xuhuang (Jira)
• Introduce TDengine connector 门世斌
  • Re: Introduce TDengine connector Leonard Xu
  • Re: Introduce TDengine connector 门世斌
• Request for PMC help with flink-connector-hive release Sergey Nuyanzin
  • Re: Request for PMC help with flink-connector-hive release Leonard Xu
  • Re: Request for PMC help with flink-connector-hive release Leonard Xu
  • Re: Request for PMC help with flink-connector-hive release Sergey Nuyanzin
• [RESULT][VOTE] Release flink-connector-hive, release candidate #2 Sergey Nuyanzin
• [jira] [Created] (FLINK-37289) Resolve JVM bytecode size limit exceeded in <init> method due to excessive field initializations in SQL job Xinglong Wang (Jira)
• [jira] [Created] (FLINK-37288) Add Google Cloud Spanner dialect and catalog Tomoyuki NAKAMURA (Jira)
• [jira] [Created] (FLINK-37287) There was Apache Paimon 0.9, but it is gone. 911432 (Jira)
• [jira] [Created] (FLINK-37286) Introduce ClickHouseDialect And ClickHouseCatalog Chaojian Fu (Jira)
• [jira] [Created] (FLINK-37285) Adapt DataSinkTranslator to support new Sink API of FLIP-372 Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37284) ForwardForConsecutiveHashPartitioner cannot be chained in Adaptive batch. Junrui Lee (Jira)
• [jira] [Created] (FLINK-37283) Improved ability to split ‘db./.*./.*.’ ouyangwulin (Jira)
• [jira] [Created] (FLINK-37282) Add backchannel for producer recycling Arvid Heise (Jira)
• [jira] [Created] (FLINK-37281) Refactor KafkaSinkITCase Arvid Heise (Jira)
• Minutes of the Community Health Initiative (CHI) for Western time zone David Radley
• [jira] [Created] (FLINK-37280) Inconsistent content of TableConfig in planner when mini batch is enabled Piotr Nowojski (Jira)
• [DISCUSS] FLIP-508: Add support for Smile format for Compiled plans Sergey Nuyanzin
  • Re: [DISCUSS] FLIP-508: Add support for Smile format for Compiled plans Gyula Fóra
  • Re: [DISCUSS] FLIP-508: Add support for Smile format for Compiled plans Timo Walther
  • Re: [DISCUSS] FLIP-508: Add support for Smile format for Compiled plans Gyula Fóra
  • Re: [DISCUSS] FLIP-508: Add support for Smile format for Compiled plans Sergey Nuyanzin
• [jira] [Created] (FLINK-37279) Add Flink CDC Pipeline Clickhouse connector qinghuan wang (Jira)
• [jira] [Created] (FLINK-37278) Regular schema evolution process is too slow when starting from specific offset yux (Jira)
• [jira] [Created] (FLINK-37277) Add guidance for configuring different kind of catalog of Paimon Sink. Yanquan Lv (Jira)
• [jira] [Created] (FLINK-37276) Missing interfaces in `RuntimeContext` Zakelly Lan (Jira)
• [jira] [Created] (FLINK-37275) MySQL source connector supports using the base module's source metric statistics JunboWang (Jira)
• [jira] [Created] (FLINK-37274) Add examples for datastream api v2 xuhuang (Jira)
• [jira] [Created] (FLINK-37273) Dynamodb Streams getRecords call adaptive delay Pranav Wadekar (Jira)
• [jira] [Created] (FLINK-37272) FileSinkAvroWritersTests::test_avro_basic_write failed Weijie Guo (Jira)
• [jira] [Created] (FLINK-37271) Add network channel reconnect capability Zhenqiu Huang (Jira)
• [DISCUSS] FLIP:507 Add Model DDL methods in TABLE API Yash Anand
  • Re: [DISCUSS] FLIP:507 Add Model DDL methods in TABLE API Yanquan Lv
  • Re: [DISCUSS] FLIP:507 Add Model DDL methods in TABLE API Hao Li
  • Re: [DISCUSS] FLIP:507 Add Model DDL methods in TABLE API Mingge Deng
  • Re: [DISCUSS] FLIP:507 Add Model DDL methods in TABLE API Yash Anand
• [jira] [Created] (FLINK-37270) Flink Support to SSL enabled MongoDb/DocumentDB source connector vijaya lakshmi chanumolu (Jira)
• [jira] [Created] (FLINK-37269) Add new DESCRIPTOR data type Timo Walther (Jira)
• [jira] [Created] (FLINK-37268) Add async state word count example Yanfei Lei (Jira)
• [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Martijn Visser
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Yanquan Lv
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Kevin Cheng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Kevin Cheng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Cong Cheng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Lincoln Lee
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner Ron Liu
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner weijie guo
  • Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner xiangyu feng
• [jira] [Created] (FLINK-37267) Support WITH ORDINALITY for UNNEST Gustavo de Morais (Jira)
• [jira] [Created] (FLINK-37266) Python CLI arguments doesn't work in session mode Dian Fu (Jira)
• RabbitMQ Connector upgrade Fabrizzio Chávez Tejada
  • Re: RabbitMQ Connector upgrade Yanquan Lv
• [jira] [Created] (FLINK-37265) document of python elasticsearch connector exeample has a mistake Zhang Hechuan (Jira)
• [jira] [Created] (FLINK-37264) two bugs of DSv2 xuhuang (Jira)
• [jira] [Created] (FLINK-37263) AggregateITCase.testConstantGroupKeyWithUpsertSink failed Weijie Guo (Jira)
• [jira] [Created] (FLINK-37262) MySQL CDC connector could not configure the `scan.parse.online.schema.changes.enabled` option yux (Jira)
• [jira] [Created] (FLINK-37261) Provide JSON series functions in YAML pipeline JunboWang (Jira)
• [jira] [Created] (FLINK-37260) Change MySQL Connector address 911432 (Jira)
• [jira] [Created] (FLINK-37259) StreamCheckpointingITCase times out Matthias Pohl (Jira)
• [jira] [Created] (FLINK-37258) Order Flink Job list in Flink UI with start time Ahmed Hamdy (Jira)
• [jira] [Created] (FLINK-37257) Add an API on keyedStream to allow users to customize the hash method from key to parallelism. Jinkun Liu (Jira)
• [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Jiabao Sun
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Xiqian YU
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Leonard Xu
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Yanquan Lv
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 gongzhongqiang
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Jiabao Sun
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Robert Metzger
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Ferenc Csaky
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 weijie guo
  • Re: [VOTE] Release flink-connector-mongodb v2.0.0, release candidate #2 Jiabao Sun
• [jira] [Created] (FLINK-37256) Firing timers can block recovery process Piotr Nowojski (Jira)
• Cancel flink-connector-mongodb v2.0.0 release candidate #1 Jiabao Sun
  • Re: Cancel flink-connector-mongodb v2.0.0 release candidate #1 Leonard Xu
• [jira] [Created] (FLINK-37255) Unsupported options: scan.partition.record-size Jiabao Sun (Jira)
• [jira] [Created] (FLINK-37254) flink cdc的oceanbase cdc 存在表字段的默认值为default '0'抛出异常 caixiaowei (Jira)
• [DISCUSS] FLINK-20625: Reviewer needed for pubsub source refactor PR Claire McCarthy
• [jira] [Created] (FLINK-37253) Display state size in application status and deployment metrics Maximilian Michels (Jira)

• Earlier messages
• Later messages