issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2025/08/08
Re: [PR] [Python] Support for Event containing Row field can be json serializable [flink-agents]
via GitHub
2025/08/08
[PR] [hotfix][docs] Clarify Kryo behavior [flink]
via GitHub
2025/08/08
Re: [PR] [hotfix][docs] Clarify Kryo behavior [flink]
via GitHub
2025/08/08
[jira] [Created] (FLINK-38217) ChangelogNormalize unnecessarily emits updates for equal rows
Dawid Wysakowicz (Jira)
2025/08/08
[jira] [Resolved] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service
yuan (Jira)
2025/08/08
[jira] [Reopened] (FLINK-38111) Migrate OceanBase CDC Connector from LogProxy to OceanBase Binlog Service
yuan (Jira)
2025/08/08
[jira] [Commented] (FLINK-38192) Improve DynamicSourceUtils exception msg
Cai Liuyang (Jira)
2025/08/08
Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink]
via GitHub
2025/08/08
Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink]
via GitHub
2025/08/08
Re: [PR] [FLINK-38142] Upgrading the Paimon version to 1.2.0 [flink-cdc]
via GitHub
2025/08/08
Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink]
via GitHub
2025/08/08
Re: [PR] [FLINK-38198] Support WITH Clause in CREATE FUNCTION Statement [flink]
via GitHub
2025/08/08
Re: [PR] [plan][runtime][java] Introduce Resource and Resource Provider in java [flink-agents]
via GitHub
2025/08/08
[jira] [Created] (FLINK-38216) Refactor EndOfChannelStateEvent according to input buffer and output buffer
Rui Fan (Jira)
2025/08/08
[jira] [Updated] (FLINK-37963) Unstable MongoDB unit test cases that triggers JM failover
ASF GitHub Bot (Jira)
2025/08/08
[jira] [Updated] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE
Yanquan Lv (Jira)
2025/08/08
Re: [PR] [FLINK-37963] Fix potential NPE when triggering JobManager failover prematurely [flink-cdc]
via GitHub
2025/08/08
[jira] [Updated] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink
Yanquan Lv (Jira)
2025/08/08
[jira] [Assigned] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink
Yanquan Lv (Jira)
2025/08/08
[jira] [Commented] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink
wuzexian (Jira)
2025/08/08
[jira] [Commented] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE
wuzexian (Jira)
2025/08/08
Re: [PR] [FLINK-37905] Fix transform failure with non-ascii string literals [flink-cdc]
via GitHub
2025/08/08
[jira] [Commented] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE
Xiqian Yu (Jira)
2025/08/08
[jira] [Assigned] (FLINK-38204) When using route in pipeline, failed to write to MaxCompute sink
Yanquan Lv (Jira)
2025/08/08
[jira] [Assigned] (FLINK-37835) MySQL CDC BinlogOffset compareTo method throws NPE
Xiqian Yu (Jira)
2025/08/08
[jira] [Updated] (FLINK-38194) Iceberg connector supports auto-creating namespace
Yanquan Lv (Jira)
2025/08/07
Re: [PR] [FLINK-37479][postgres] Add support for PARTITIONED TABLE [flink-cdc]
via GitHub
2025/08/07
[jira] [Resolved] (FLINK-38194) Iceberg connector supports auto-creating namespace
Yanquan Lv (Jira)
2025/08/07
[jira] [Resolved] (FLINK-38154) Add HTTP support to OpenTelemetry Reporter
Robert Metzger (Jira)
2025/08/07
Re: [PR] [FLINK-38194][pipeline-connector/iceberg] Iceberg connector supports auto-creating namespace [flink-cdc]
via GitHub
2025/08/07
[jira] [Created] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed
junzhong qin (Jira)
2025/08/07
[jira] [Updated] (FLINK-38215) Remove HA data according to config option `job.savepoint-on-deletion` when cleanup terminal JM after ttl passed
junzhong qin (Jira)
2025/08/07
Re: [PR] [FLINK-38154][metrics] Add HTTP protocol support to OpenTelemetry reporters [flink]
via GitHub
2025/08/07
Re: [PR] [FLINK-38188][cdc-postgres] Fix database name validation logic in PostgresDataSourceFactory [flink-cdc]
via GitHub
2025/08/07
[jira] [Created] (FLINK-38214) Support Kinesis streams source in Python DataStream API
Dian Fu (Jira)
2025/08/07
[jira] [Resolved] (FLINK-37828) Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability.
Yanquan Lv (Jira)
2025/08/07
Re: [PR] [FLINK-37828] Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability [flink-cdc]
via GitHub
2025/08/07
Re: [PR] [plan][runtime][java] Introduce Resource and Resource Provider in java [flink-agents]
via GitHub
2025/08/07
Re: [PR] [FLINK-38194][pipeline-connector/iceberg] Iceberg connector supports auto-creating namespace [flink-cdc]
via GitHub
2025/08/07
Re: [PR] [FLINK-35907][pipeline-connector][postgres] Fix inconsistent bit type handling between snapshot and streaming phases [flink-cdc]
via GitHub
2025/08/07
[jira] [Updated] (FLINK-38213) Failed case: FlussE2eITCase.testMySqlToFluss
Yanquan Lv (Jira)
2025/08/07
[jira] [Updated] (FLINK-38213) Failed case: FlussE2eITCase.testMySqlToFluss
Yanquan Lv (Jira)
2025/08/07
[jira] [Created] (FLINK-38213) Failed
Yanquan Lv (Jira)
2025/08/07
[jira] [Resolved] (FLINK-38185) Failed case: IcebergWriterTest.testWriteWithAllSupportedTypes
Yanquan Lv (Jira)
2025/08/07
[jira] [Updated] (FLINK-37959) supported All postgres sql 14 field types.
ASF GitHub Bot (Jira)
2025/08/07
[PR] [FLINK-37959][postgres]Supported postgres sql 14 all field types. [flink-cdc]
via GitHub
2025/08/07
Re: [PR] [FLINK-35907][pipeline-connector][postgres] Fix inconsistent bit type handling between snapshot and streaming phases [flink-cdc]
via GitHub
2025/08/07
[PR] [FLINK-35907][pipeline-connector][postgres] Fix inconsistent bit type handling between snapshot and streaming phases [flink-cdc]
via GitHub
2025/08/07
[jira] [Updated] (FLINK-35907) Inconsistent handling of bit and bit(n) types in Flink CDC PostgreSQL Connector
ASF GitHub Bot (Jira)
2025/08/07
Re: [PR] [FLINK-38196][pipeline-connector][postgres] Support decimal.handling.mode config to Fix IndexOutOfBoundsException for numeric fields with NULL values ; [flink-cdc]
via GitHub
2025/08/07
Re: [PR] [FLINK-38196][pipeline-connector][postgres] Support decimal.handling.mode config to Fix IndexOutOfBoundsException for numeric fields with NULL values ; [flink-cdc]
via GitHub
2025/08/07
[jira] [Updated] (FLINK-38196) IndexOutOfBoundsException when processing PostgreSQL tables with numeric(0) fields in Flink CDC
ASF GitHub Bot (Jira)
2025/08/07
[PR] [FLINK-38196][pipeline-connector][postgres] Support decimal.handling.mode config to Fix IndexOutOfBoundsException for numeric fields with NULL values ; [flink-cdc]
via GitHub
2025/08/07
Re: [PR] [FLINK-38194][pipeline-connector/iceberg] Iceberg connector supports auto-creating namespace [flink-cdc]
via GitHub
2025/08/07
Re: [PR] [FLINK-38142] Upgrading the Paimon version to 1.2.0 [flink-cdc]
via GitHub
2025/08/07
Re: [PR] [hotfix][docs] README: fix variable name in Java Batch example [flink]
via GitHub
2025/08/07
[PR] [hotfix][docs] README: fix variable name in Java Batch example [flink]
via GitHub
2025/08/07
Re: [PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink]
via GitHub
2025/08/07
[jira] [Updated] (FLINK-38205) Discard unknown fields for Protobuf format
ASF GitHub Bot (Jira)
2025/08/07
[PR] [FLINK-38205][format][pb] Discard unknown fields by default [flink]
via GitHub
2025/08/07
Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink]
via GitHub
2025/08/07
Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc]
via GitHub
2025/08/07
Re: [PR] [FLINK-32695] [Tests] Replace NonSerializableTupleSource with DataGeneratorSource V2 API [flink]
via GitHub
2025/08/07
Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink]
via GitHub
2025/08/07
[jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc
Grzegorz Liter (Jira)
2025/08/07
[jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc
Grzegorz Liter (Jira)
2025/08/07
[jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc
Grzegorz Liter (Jira)
2025/08/07
[jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc
Grzegorz Liter (Jira)
2025/08/07
[jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc
Grzegorz Liter (Jira)
2025/08/07
[jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc
Grzegorz Liter (Jira)
2025/08/07
[jira] [Commented] (FLINK-38135) Non-existent method for RAW type hashing
Sergey Nuyanzin (Jira)
2025/08/07
[jira] [Resolved] (FLINK-38135) Non-existent method for RAW type hashing
Sergey Nuyanzin (Jira)
2025/08/07
[jira] [Assigned] (FLINK-38181) Code generation fails for ROW() with CAST to SMALLINT/TINYINT when input is non-literal
Timo Walther (Jira)
2025/08/07
Re: [PR] [FLINK-38135][table] Fix call to non-existent method for RAW type hashing [flink]
via GitHub
2025/08/07
[jira] [Closed] (FLINK-38181) Code generation fails for ROW() with CAST to SMALLINT/TINYINT when input is non-literal
Timo Walther (Jira)
2025/08/07
[jira] [Commented] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc
Grzegorz Liter (Jira)
2025/08/07
[jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc
Grzegorz Liter (Jira)
2025/08/07
[jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc
Grzegorz Liter (Jira)
2025/08/07
Re: [PR] [FLINK-38181] Fix code generation for primitive type casting and improve cast consistency across compile-time and runtime paths [flink]
via GitHub
2025/08/07
[jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc
Grzegorz Liter (Jira)
2025/08/07
[jira] [Updated] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc
Grzegorz Liter (Jira)
2025/08/07
[jira] [Commented] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc
Grzegorz Liter (Jira)
2025/08/07
[jira] [Created] (FLINK-38212) OOM during savepoint caused by potential memory leak issue in RocksDB related to jemalloc
Grzegorz Liter (Jira)
2025/08/07
[jira] [Updated] (FLINK-38211) Refactor explain for MultiJoin operator
Gustavo de Morais (Jira)
2025/08/07
Re: [PR] [FLINK-38135][table] Fix call to non-existent method for RAW type hashing [flink]
via GitHub
2025/08/07
[jira] [Created] (FLINK-38211) Refactor explain for MultiJoin operator
Gustavo de Morais (Jira)
2025/08/07
[jira] [Resolved] (FLINK-37700) SQL parse exception when creating a view with PTF
Sergey Nuyanzin (Jira)
2025/08/07
Re: [PR] [FLINK-37700][table-planner] Fix SQL parse exception when creating a view with PTF [flink]
via GitHub
2025/08/07
[jira] [Commented] (FLINK-37700) SQL parse exception when creating a view with PTF
Sergey Nuyanzin (Jira)
2025/08/07
[jira] [Assigned] (FLINK-37700) SQL parse exception when creating a view with PTF
Sergey Nuyanzin (Jira)
2025/08/07
[jira] [Resolved] (FLINK-38202) Allow to customize dynamic.max-pool-size-factor
Sergey Nuyanzin (Jira)
2025/08/07
[jira] [Commented] (FLINK-38202) Allow to customize dynamic.max-pool-size-factor
Sergey Nuyanzin (Jira)
2025/08/07
Re: [PR] [FLINK-38202][build] Allow to customize dynamic.max-pool-size-factor [flink]
via GitHub
2025/08/07
Re: [PR] [FLINK-32695] [Tests] Migrate CoGroupJoinITCase new Source/Sink V2 [flink]
via GitHub
2025/08/07
Re: [PR] [FLINK-32695] [Tests] ReactiveModeITCase-NewSource-Migration [flink]
via GitHub
2025/08/07
Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink]
via GitHub
2025/08/07
Re: [PR] [FLINK-38199] Add SinkUpsertMaterializerBenchmark [flink-benchmarks]
via GitHub
2025/08/07
Re: [PR] [FLINK-38199] Add SinkUpsertMaterializerBenchmark [flink-benchmarks]
via GitHub
2025/08/07
Re: [PR] [FLINK-38199] Add SinkUpsertMaterializerBenchmark [flink-benchmarks]
via GitHub
2025/08/07
Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink]
via GitHub
2025/08/07
Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink]
via GitHub
2025/08/07
[jira] [Updated] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management
ASF GitHub Bot (Jira)
2025/08/07
Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink]
via GitHub
2025/08/07
Re: [PR] [draft] MySqlDatabaseSchema include gh-ost ddl in HistorizedRelationalDatabaseSchema [flink-cdc]
via GitHub
2025/08/07
[PR] [draft] MySqlDatabaseSchema include gh-ost ddl in HistorizedRelationalDatabaseSchema [flink-cdc]
via GitHub
2025/08/07
Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink]
via GitHub
2025/08/07
[jira] [Updated] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management
Gustavo de Morais (Jira)
2025/08/07
Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink]
via GitHub
2025/08/07
Re: [PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin [flink]
via GitHub
2025/08/07
[PR] [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management [flink]
via GitHub
2025/08/07
Re: [PR] [FLINK-38045] Build createTableEventCache using TableSchemas from split and Make transform operator stateless [flink-cdc]
via GitHub
2025/08/07
Re: [PR] [FLINK-37828] Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability [flink-cdc]
via GitHub
2025/08/07
[jira] [Updated] (FLINK-38045) Refactor: Make transform operator stateless by building a createTableEventCache
ASF GitHub Bot (Jira)
2025/08/07
Re: [PR] [FLINK-37065]: MySQL cdc can lose/skip data during recovering from the checkpoint [flink-cdc]
via GitHub
2025/08/07
[jira] [Commented] (FLINK-38210) s5cmd somtimes fails due to path starting with s3p://
Grzegorz Liter (Jira)
2025/08/07
Re: [PR] [FLINK-38199] Add SinkUpsertMaterializerBenchmark [flink-benchmarks]
via GitHub
2025/08/07
[jira] [Created] (FLINK-38210) s5cmd somtimes fails due to path starting with s3p://
Grzegorz Liter (Jira)
2025/08/07
Re: [PR] [FLINK-37828] Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability [flink-cdc]
via GitHub
2025/08/07
[jira] [Comment Edited] (FLINK-36125) File not found exception on restoring state handles with file merging
Grzegorz Liter (Jira)
2025/08/07
[jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging
Grzegorz Liter (Jira)
2025/08/07
Re: [PR] [api][python] Support add action and resource to Agent instance. [flink-agents]
via GitHub
2025/08/07
Re: [PR] [FLINK-38201] SinkUpsertMaterializer should not be inserted for retract sinks [flink]
via GitHub
2025/08/07
[jira] [Created] (FLINK-38209) Use UniqueKeys instead of Upsertkeys for state management
Gustavo de Morais (Jira)
2025/08/07
Re: [PR] [FLINK-38202][build] Allow to customize dynamic.max-pool-size-factor [flink]
via GitHub
2025/08/07
[jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging
Zakelly Lan (Jira)
2025/08/07
Re: [PR] [FLINK-38199] Add SinkUpsertMaterializerBenchmark [flink-benchmarks]
via GitHub
2025/08/07
Re: [PR] [FLINK-38181] Fix code generation for primitive type casting and improve cast consistency across compile-time and runtime paths [flink]
via GitHub
2025/08/07
[jira] [Resolved] (FLINK-38164) MySQL connector support LONG and LONG VARCHAR type
Yanquan Lv (Jira)
2025/08/07
Re: [PR] [FLINK-38201] SinkUpsertMaterializer should not be inserted for retract sinks [flink]
via GitHub
2025/08/07
Re: [PR] [FLINK-38164][pipeline-connector/mysql] support mysql long and long varchar type [flink-cdc]
via GitHub
2025/08/07
Re: [PR] [FLINK-38199] Add SinkUpsertMaterializerBenchmark [flink-benchmarks]
via GitHub
2025/08/07
Re: [PR] WIP: [Feature][API] Introduce ChatModel,Tool and Prompt in Java [flink-agents]
via GitHub
2025/08/07
[jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging
Zakelly Lan (Jira)
2025/08/07
Re: [PR] WIP: [Feature][API] Introduce ChatModel,Tool and Prompt in Java [flink-agents]
via GitHub
2025/08/07
Re: [PR] [FLINK-38201] SinkUpsertMaterializer should not be inserted for retract sinks [flink]
via GitHub
2025/08/07
[jira] [Commented] (FLINK-37828) Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability.
JunboWang (Jira)
2025/08/07
[jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging
Grzegorz Liter (Jira)
2025/08/07
Re: [PR] [FLINK-38201] SinkUpsertMaterializer should not be inserted for retract sinks [flink]
via GitHub
2025/08/07
[PR] [FLINK-38208] Use new Fabric8 client CRD generator in Flink Operator [flink-kubernetes-operator]
via GitHub
2025/08/07
[jira] [Commented] (FLINK-38058) Add e2e test for fluss pipeline connector
Yanquan Lv (Jira)
2025/08/07
Re: [PR] [FLINK-38142] Upgrading the Paimon version to 1.2.0 [flink-cdc]
via GitHub
2025/08/07
[jira] [Commented] (FLINK-36708) Optimize Table Collection Handling Logic to Improve Efficiency
Yanquan Lv (Jira)
2025/08/07
[jira] [Comment Edited] (FLINK-38208) Use new Fabric8 client CRD generator in Flink Operator
Jira
2025/08/07
[jira] [Commented] (FLINK-38208) Use new Fabric8 client CRD generator in Flink Operator
Jira
2025/08/07
[PR] [FLINK-38201] SinkUpsertMaterializer should not be inserted for retract sinks [flink]
via GitHub
2025/08/07
[jira] [Updated] (FLINK-38208) Use new Fabric8 client CRD generator in Flink Operator
ASF GitHub Bot (Jira)
2025/08/07
[jira] [Updated] (FLINK-37828) Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability.
ASF GitHub Bot (Jira)
2025/08/07
[jira] [Created] (FLINK-38208) Use new Fabric8 client CRD generator in Flink Operator
Jira
2025/08/07
Re: [PR] [FLINK-38181] Fix code generation for primitive type casting and improve cast consistency across compile-time and runtime paths [flink]
via GitHub
2025/08/07
[jira] [Resolved] (FLINK-37958) Flink CDC Sink connector support fluss
Yanquan Lv (Jira)
2025/08/07
[PR] [FLINK-37828] Enable scan.incremental.snapshot.unbounded-chunk-first by default for improved stability [flink-cdc]
via GitHub
2025/08/07
[jira] [Resolved] (FLINK-36967) Bump dependency of Paimon Pipeline connector to 0.9.0
Yanquan Lv (Jira)
2025/08/07
[jira] [Updated] (FLINK-38207) Update Flink Operator to use JOSDK 5.1.2
ASF GitHub Bot (Jira)
2025/08/07
[jira] [Commented] (FLINK-38207) Update Flink Operator to use JOSDK 5.1.2
Jira
2025/08/07
[PR] [FLINK-38207] Update Flink Operator to use JOSDK 5.1.2 [flink-kubernetes-operator]
via GitHub
2025/08/07
[jira] [Closed] (FLINK-35586) Detected conflict when using Paimon as pipeline sink with parallelism > 1
Yanquan Lv (Jira)
2025/08/07
[jira] [Created] (FLINK-38207) Update Flink Operator to use JOSDK 5.1.2
Jira
2025/08/07
Re: [PR] [FLINK-38201] SinkUpsertMaterializer should not be inserted for retract sinks [flink]
via GitHub
2025/08/07
[jira] [Commented] (FLINK-37395) [BUG] When scan.startup.mode = latest-offset, an NullPointerException will be triggered
Yanquan Lv (Jira)
2025/08/07
Re: [PR] [FLINK-38142] Upgrading the Paimon version to 1.2.0 [flink-cdc]
via GitHub
2025/08/07
Re: [PR] [hotfix] Rename input/output event name in EventUtil to keep consiste… [flink-agents]
via GitHub
2025/08/07
[jira] [Updated] (FLINK-38201) SinkUpsertMaterializer should not be inserted for retract sinks
ASF GitHub Bot (Jira)
2025/08/07
[jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging
Zakelly Lan (Jira)
2025/08/07
[jira] [Reopened] (FLINK-36125) File not found exception on restoring state handles with file merging
Zakelly Lan (Jira)
2025/08/07
[jira] [Assigned] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures
Yanquan Lv (Jira)
2025/08/07
Re: [I] [Feature] [api][python] Support add action and resource to Agent instance [flink-agents]
via GitHub
2025/08/07
[PR] [FLINK-38206][pipeline-connector][paimon] Support writing to existed table with inconsistent schema with upstream. [flink-cdc]
via GitHub
2025/08/07
[jira] [Updated] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures
ASF GitHub Bot (Jira)
2025/08/07
Re: [PR] [FLINK-38188][cdc-postgres] Fix database name validation logic in PostgresDataSourceFactory [flink-cdc]
via GitHub
2025/08/07
Re: [PR] [FLINK-38199] Add SinkUpsertMaterializerBenchmark [flink-benchmarks]
via GitHub
2025/08/07
Re: [PR] [FLINK-38199] Add SinkUpsertMaterializerBenchmark [flink-benchmarks]
via GitHub
2025/08/07
Re: [PR] [FLINK-38199] Add SinkUpsertMaterializerBenchmark [flink-benchmarks]
via GitHub
2025/08/07
Re: [PR] [FLINK-38199] Add SinkUpsertMaterializerBenchmark [flink-benchmarks]
via GitHub
2025/08/07
[PR] [hotfix] Rename input/output event name in EventUtil to keep consiste… [flink-agents]
via GitHub
2025/08/07
Re: [PR] [FLINK-38164][pipeline-connector/mysql] support mysql long and long varchar type [flink-cdc]
via GitHub
2025/08/06
Re: [PR] [FLINK-38194][pipeline-connector/iceberg] Iceberg connector supports auto-creating namespace [flink-cdc]
via GitHub
2025/08/06
Re: [PR] [FLINK-38194][pipeline-connector/iceberg] Iceberg connector supports auto-creating namespace [flink-cdc]
via GitHub
2025/08/06
Re: [PR] [FLINK-38199] Add SinkUpsertMaterializerBenchmark [flink-benchmarks]
via GitHub
2025/08/06
Re: [PR] [FLINK-37905] Fix transform failure with non-ascii string literals [flink-cdc]
via GitHub
2025/08/06
Re: [PR] [FLINK-38198] Support WITH Clause in CREATE FUNCTION Statement [flink]
via GitHub
2025/08/06
Re: [PR] [FLINK-38194][pipeline-connector/iceberg] Iceberg connector supports auto-creating namespace [flink-cdc]
via GitHub
2025/08/06
[jira] [Commented] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures
Yanquan Lv (Jira)
2025/08/06
Re: [PR] [api][python] Support add action and resource to Agent instance. [flink-agents]
via GitHub
2025/08/06
[jira] [Resolved] (FLINK-38184) CDC no need to getCopyOfBuffer for each split info.
Yanquan Lv (Jira)
2025/08/06
Re: [PR] [FLINK-38164][pipeline-connector/mysql] support mysql long and long varchar type [flink-cdc]
via GitHub
2025/08/06
Re: [PR] [FLINK-38181] Fix code generation for primitive type casting and improve cast consistency across compile-time and runtime paths [flink]
via GitHub
2025/08/06
Re: [PR] [hotfix] [docs] Fix typo in docker.md [flink]
via GitHub
2025/08/06
Re: [PR] [table] Add support for temporal join on rolling aggregates [flink]
via GitHub
2025/08/06
Re: [PR] [table] Add support for temporal join on rolling aggregates [flink]
via GitHub
2025/08/06
Re: [PR] [hotfix] [docs] Fix typo in docker.md [flink]
via GitHub
2025/08/06
Re: [PR] [FLINK-38184] one time of GetCopyOfBuffer is enough When serializing split. [flink-cdc]
via GitHub
2025/08/06
Re: [PR] [FLINK-38142] Upgrading the Paimon version to 1.2.0 [flink-cdc]
via GitHub
2025/08/06
[jira] [Comment Edited] (FLINK-36125) File not found exception on restoring state handles with file merging
Grzegorz Liter (Jira)
2025/08/06
[jira] [Commented] (FLINK-36125) File not found exception on restoring state handles with file merging
Grzegorz Liter (Jira)
2025/08/06
[jira] [Comment Edited] (FLINK-36125) File not found exception on restoring state handles with file merging
Grzegorz Liter (Jira)
2025/08/06
Re: [PR] [FLINK-38142] Upgrading the Paimon version to 1.2.0 [flink-cdc]
via GitHub
2025/08/06
Re: [PR] [FLINK-38142] Upgrading the Paimon version to 1.2.0 [flink-cdc]
via GitHub
2025/08/06
Re: [PR] [FLINK-38188][cdc-postgres] Fix database name validation logic in PostgresDataSourceFactory [flink-cdc]
via GitHub
2025/08/06
Re: [PR] [plan][runtime][java] Introduce Resource and Resource Provider in java [flink-agents]
via GitHub
2025/08/06
[jira] [Created] (FLINK-38206) Update Paimon Table based on upstream schema to avoid inconsistent table structures
Yanquan Lv (Jira)
Earlier messages
Later messages