Messages by Date
-
2026/02/26
[jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled
Rui Fan (Jira)
-
2026/02/26
[jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled
Rui Fan (Jira)
-
2026/02/26
[jira] [Updated] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots
Luca Occhipinti (Jira)
-
2026/02/26
[jira] [Created] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots in clustered instances
Luca Occhipinti (Jira)
-
2026/02/26
[jira] [Updated] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots
Luca Occhipinti (Jira)
-
2026/02/26
[jira] [Updated] (FLINK-39169) [mysql-connector] Use reader instances to run snapshots
Luca Occhipinti (Jira)
-
2026/02/26
[jira] [Commented] (FLINK-38585) Pyflink's thread mode may not work when using shipped venv.zip archive as virtual env
Biao Geng (Jira)
-
2026/02/26
[jira] [Created] (FLINK-39168) improve mysql’s snapshot-split
Thorne (Jira)
-
2026/02/26
[jira] [Created] (FLINK-39167) Initialize source output before emitting final watermark
Roman Khachatryan (Jira)
-
2026/02/26
[jira] [Updated] (FLINK-39166) Add bucket level config parity
Samrat Deb (Jira)
-
2026/02/26
[jira] [Created] (FLINK-39166) Add bucket level config parity
Samrat Deb (Jira)
-
2026/02/26
[jira] [Closed] (FLINK-39159) Using KeyedProcessFunction in batch mode reads events out of order
Grzegorz Liter (Jira)
-
2026/02/26
[jira] [Comment Edited] (FLINK-39130) Allow native types to be used for MetricConfig
Rui Fan (Jira)
-
2026/02/26
[jira] [Updated] (FLINK-39130) Allow native types to be used for MetricConfig
Rui Fan (Jira)
-
2026/02/26
[jira] [Updated] (FLINK-39165) Concurrent FlinkDeployment and FlinkSessionJob upgrades lead to savepoint failure and state loss
Ihor Mielientiev (Jira)
-
2026/02/26
[jira] [Created] (FLINK-39165) Concurrent FlinkDeployment and FlinkSessionJob upgrades lead to savepoint failure and state loss
Ihor Mielientiev (Jira)
-
2026/02/26
[jira] [Commented] (FLINK-39161) INTERVAL WEEK, QUARTER has wrong math
Sergey Nuyanzin (Jira)
-
2026/02/26
[jira] [Resolved] (FLINK-39161) INTERVAL WEEK, QUARTER has wrong math
Sergey Nuyanzin (Jira)
-
2026/02/26
[jira] [Updated] (FLINK-39161) INTERVAL WEEK, QUARTER has wrong math
Sergey Nuyanzin (Jira)
-
2026/02/25
[jira] [Closed] (FLINK-38928) Implement an operator for handling DO ERROR/NOTHING
Dawid Wysakowicz (Jira)
-
2026/02/25
[jira] [Assigned] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Zhu Zhu (Jira)
-
2026/02/25
[jira] [Assigned] (FLINK-38956) Fix the job-overview Web UI cannot automatically show the latest edge name for AdaptiveScheduler
Yuepeng Pan (Jira)
-
2026/02/25
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Lei Yang (Jira)
-
2026/02/25
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Zhu Zhu (Jira)
-
2026/02/25
[jira] [Commented] (FLINK-34415) Move away from Kafka-Zookeeper based tests in favor of Kafka-KRaft
Taranpreet Kaur (Jira)
-
2026/02/25
Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
-
2026/02/25
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
-
2026/02/25
[jira] [Created] (FLINK-39164) Flaky test HistoryServerTest.testRemoveApplicationArchivesBeyondHistorySizeLimit
Yi Zhang (Jira)
-
2026/02/25
[jira] [Commented] (FLINK-37951) Enable VariantSerializerUpgradeTest in Flink 2.2
Jinkun Liu (Jira)
-
2026/02/25
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
lincoln lee (Jira)
-
2026/02/25
[jira] [Created] (FLINK-39163) Support ML_PREDICT in Flink Python API
Biao Geng (Jira)
-
2026/02/25
[jira] [Assigned] (FLINK-39145) UnalignedCheckpointITCase.execute fails - IllegalStateException: Trying to access closed classloader
Yuepeng Pan (Jira)
-
2026/02/25
[jira] [Commented] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests
Samrat Deb (Jira)
-
2026/02/25
[jira] [Closed] (FLINK-38973) Job ID assignment and matching based on name
Zhu Zhu (Jira)
-
2026/02/25
[jira] [Resolved] (FLINK-38340) Introduce the rescale timeline related abstraction for performing rescale operations
Wei Zhong (Jira)
-
2026/02/25
[jira] [Commented] (FLINK-38340) Introduce the rescale timeline related abstraction for performing rescale operations
Wei Zhong (Jira)
-
2026/02/25
[jira] [Comment Edited] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency
Jon Chase (Jira)
-
2026/02/25
[jira] [Commented] (FLINK-39136) GS file system fails to retry on certain 503's due to old GCS lib dependency
Jon Chase (Jira)
-
2026/02/25
[jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled
Rui Fan (Jira)
-
2026/02/25
[jira] [Updated] (FLINK-39162) The data of the custom partitioner is corrupted when unaligned checkpoint is enabled
Rui Fan (Jira)
-
2026/02/25
[jira] [Created] (FLINK-39162) The data of the custom partitioner is corrupted during unaligned checkpoint
Rui Fan (Jira)
-
2026/02/25
[jira] [Updated] (FLINK-39161) INTERVAL WEEK, QUARTER has wron math
Sergey Nuyanzin (Jira)
-
2026/02/25
[jira] [Created] (FLINK-39161) INTERVAL WEEK, QUARTER has wron math
Sergey Nuyanzin (Jira)
-
2026/02/25
[jira] [Commented] (FLINK-39160) [Runtime][Rpc][Metrics] Expose RPC response frame size and oversized-response rejection metrics
Arun Lakshman (Jira)
-
2026/02/25
[jira] [Updated] (FLINK-39160) [Runtime][Rpc][Metrics] Expose RPC response frame size and oversized-response rejection metrics
Arun Lakshman (Jira)
-
2026/02/25
[jira] [Updated] (FLINK-39160) [runtime][rpc][metrics] Expose RPC response frame size and oversized-response rejection metrics
Arun Lakshman (Jira)
-
2026/02/25
[jira] [Updated] (FLINK-39160) [runtime][rpc][metrics] Expose RPC response frame size and oversized-response rejection metrics
Arun Lakshman (Jira)
-
2026/02/25
[jira] [Created] (FLINK-39160) [runtime][rpc][metrics] Expose RPC response frame size and oversized-response rejection metrics
Arun Lakshman (Jira)
-
2026/02/25
Re: [PR] FLINK-39098 fixing test-case failure [flink-connector-mongodb]
via GitHub
-
2026/02/25
[PR] FLINK-39098 fixing test-case failure due to build server not supporting docker 1.33 api [flink-connector-mongodb]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-38866][flink-table-planner] Passing timestamp precision from window strategy to window operators to support non-compact BinaryRowData timestamps [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39124][test] Migrate operator restore tests to JUnit 5 [flink]
via GitHub
-
2026/02/25
[jira] [Created] (FLINK-39159) Using KeyedProcessFunction in batch mode reads events out of order
Grzegorz Liter (Jira)
-
2026/02/25
Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink]
via GitHub
-
2026/02/25
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]
via GitHub
-
2026/02/25
[PR] [FLINK-33634] Add Conditions to Flink CRD's Status field [flink-kubernetes-operator]
via GitHub
-
2026/02/25
Re: [PR] Bump io.airlift:aircompressor from 0.27 to 2.0.3 in /flink-runtime [flink]
via GitHub
-
2026/02/25
[PR] Bump io.airlift:aircompressor from 0.27 to 2.0.3 in /flink-runtime [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from Junit4 to Junit5 [flink-connector-kafka]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-37951] Enable VariantSerializerUpgradeTest [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-25538][Connectors/Kafka] Migration flink-connector-kafka from Junit4 to Junit5 [flink-connector-kafka]
via GitHub
-
2026/02/25
[jira] [Updated] (FLINK-37951) Enable VariantSerializerUpgradeTest in Flink 2.2
ASF GitHub Bot (Jira)
-
2026/02/25
[PR] [FLINK-37951] Enable VariantSerializerUpgradeTest [flink]
via GitHub
-
2026/02/25
Re: [D] Community Sync - 2026 [flink-agents]
via GitHub
-
2026/02/25
Re: [D] Planning Flink Agents 0.3 [flink-agents]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39139] Update lz4-java to 1.10.3 [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink]
via GitHub
-
2026/02/25
[jira] [Commented] (FLINK-39150) Join operator crashes jobs when using custom types or custom type serializers
Timo Walther (Jira)
-
2026/02/25
Re: [PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink]
via GitHub
-
2026/02/25
[jira] [Updated] (FLINK-39157) ColumnList has no hashCode/equals
ASF GitHub Bot (Jira)
-
2026/02/25
[PR] [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39158][runtime/test] Minor polish for RestAPIStabilityTestUtils to reduce redundant lines [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39151][metrics] Hide warning about UnixOperatingSystemMXBean missing on Windows [flink]
via GitHub
-
2026/02/25
[jira] [Updated] (FLINK-39158) Minor polish for RestAPIStabilityTestUtils to reduce redundant lines
ASF GitHub Bot (Jira)
-
2026/02/25
[PR] [FLINK-39158][runtime/test] Minor polish for RestAPIStabilityTestUtils to reduce redundant lines [flink]
via GitHub
-
2026/02/25
[jira] [Created] (FLINK-39158) Minor polish for RestAPIStabilityTestUtils to reduce redundant lines
Yuepeng Pan (Jira)
-
2026/02/25
[jira] [Created] (FLINK-39157) ColumnList has no hashCode/equals
Timo Walther (Jira)
-
2026/02/25
Re: [PR] Dynamodb client refresh [flink-connector-aws]
via GitHub
-
2026/02/25
[PR] Dynamodb client refresh [flink-connector-aws]
via GitHub
-
2026/02/25
Re: [PR] Dynamodb client refresh [flink-connector-aws]
via GitHub
-
2026/02/25
[PR] Dynamodb client refresh [flink-connector-aws]
via GitHub
-
2026/02/25
Re: [PR] Dynamodb client refresh [flink-connector-aws]
via GitHub
-
2026/02/25
[jira] [Comment Edited] (FLINK-39139) Update lz4-java to 1.10.3
Rui Fan (Jira)
-
2026/02/25
[jira] [Updated] (FLINK-39139) Update lz4-java to 1.10.3
Rui Fan (Jira)
-
2026/02/25
[jira] [Comment Edited] (FLINK-39139) Update lz4-java to 1.10.3
Rui Fan (Jira)
-
2026/02/25
Re: [PR] [FLINK-39139] Update lz4-java to 1.10.3 [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39139] Update lz4-java to 1.10.3 [flink]
via GitHub
-
2026/02/25
[jira] [Resolved] (FLINK-39139) Update lz4-java to 1.10.3
Rui Fan (Jira)
-
2026/02/25
[jira] [Updated] (FLINK-39139) Update lz4-java to 1.10.3
ASF GitHub Bot (Jira)
-
2026/02/25
Re: [PR] [FLINK-39139] Update lz4-java to 1.10.3 [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39139] Update lz4-java to 1.10.3 [flink]
via GitHub
-
2026/02/25
Re: [PR] [hotfix][tests] Fix HistoryServerTest by adding delay to avoid identi… [flink]
via GitHub
-
2026/02/25
[PR] [hotfix][tests] Fix HistoryServerTest by adding delay to avoid identi… [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39130][metrics] Allow native types in MetricConfig [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39130][metrics] Allow native types in MetricConfig [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39130][metrics] Allow native types in MetricConfig [flink]
via GitHub
-
2026/02/25
[PR] [FLINK-39130][metrics] Allow native types in MetricConfig [flink]
via GitHub
-
2026/02/25
[PR] [FLINK-39130][metrics] Allow native types in MetricConfig [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure [flink-connector-aws]
via GitHub
-
2026/02/25
[jira] [Comment Edited] (FLINK-39131) Multi-Input Processors
Salva (Jira)
-
2026/02/25
Re: [PR] [FLINK-39106] Support ROW and ARRAY<ROW> data types in DynamoDB API / SQL sink [flink-connector-aws]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39015][table] Fix key extractor for multi join. Change GenericRowData to BinaryRowData [flink]
via GitHub
-
2026/02/25
[jira] [Reopened] (FLINK-39130) Allow native types to be used for MetricConfig
Rui Fan (Jira)
-
2026/02/25
[jira] [Updated] (FLINK-39130) Allow native types to be used for MetricConfig
Rui Fan (Jira)
-
2026/02/25
[jira] [Resolved] (FLINK-39130) Allow native types to be used for MetricConfig
Rui Fan (Jira)
-
2026/02/25
[jira] [Assigned] (FLINK-39130) Allow native types to be used for MetricConfig
Rui Fan (Jira)
-
2026/02/25
Re: [PR] [FLINK-39130][metrics] Allow native types in MetricConfig [flink]
via GitHub
-
2026/02/25
[jira] [Updated] (FLINK-38851) Support passing arbitrary database options to JDBC Catalog
Yuepeng Pan (Jira)
-
2026/02/25
[jira] [Resolved] (FLINK-39001) [doc] Supplement the documentation with newlyaddedtable
Yanquan Lv (Jira)
-
2026/02/25
Re: [PR] [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors [flink-cdc]
via GitHub
-
2026/02/25
[jira] [Updated] (FLINK-38850) Support PostgreSQL uuid type
Yuepeng Pan (Jira)
-
2026/02/25
Re: [PR] [FLINK-38729] Bump Flink version to 2.2.0 [flink-cdc]
via GitHub
-
2026/02/25
[jira] [Updated] (FLINK-38729) Bump Flink version of Flink CDC to 2.1 or 2.2
ASF GitHub Bot (Jira)
-
2026/02/25
[PR] [FLINK-38729] Bump Flink version to 2.2.0 [flink-cdc]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-38916][table-planner] MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1 [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors [flink-cdc]
via GitHub
-
2026/02/25
[jira] [Created] (FLINK-39156) Document the changes
Dawid Wysakowicz (Jira)
-
2026/02/25
[jira] [Created] (FLINK-39155) Add a check watermarks are defined in source for ERROR/NOTHING
Dawid Wysakowicz (Jira)
-
2026/02/25
Re: [PR] [FLINK-39106] Support ROW and ARRAY<ROW> data types in DynamoDB API / SQL sink [flink-connector-aws]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors [flink-cdc]
via GitHub
-
2026/02/25
[jira] [Updated] (FLINK-39140) Enhance Unaligned Checkpoint ITCases to perform checkpointing during recovery
Rui Fan (Jira)
-
2026/02/25
[jira] [Updated] (FLINK-39140) Enhance Unaligned Checkpoint ITCases to perform checkpointing during recovery
Rui Fan (Jira)
-
2026/02/25
Re: [PR] [FLINK-34864][cdc-connector-mysql] Add the IgnoreNoPrimaryKeyTable parameter to skip tables without primary keys in multi-table synchronization [flink-cdc]
via GitHub
-
2026/02/25
[jira] [Updated] (FLINK-39154) [Table/SQL] Support Async Batch Lookup Join (with Calc) for Temporal Table Join
featzhang (Jira)
-
2026/02/25
[jira] [Updated] (FLINK-39154) [Table]Support Async Batch Lookup Join (with Calc) for Temporal Table Join
featzhang (Jira)
-
2026/02/25
[jira] [Created] (FLINK-39154) [Table]Support Async Batch Lookup Join (with Calc) for Temporal Table Join
featzhang (Jira)
-
2026/02/25
Re: [PR] [FLINK-38977][runtime] Expose exceptions for applications [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39106] Support ROW and ARRAY<ROW> data types in DynamoDB API / SQL sink [flink-connector-aws]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39001][doc][Flink-source]supple NewlyAddTable's doc with mongodb,postgres,oracle connectors [flink-cdc]
via GitHub
-
2026/02/25
[jira] [Comment Edited] (FLINK-39131) Multi-Input Processors
Salva (Jira)
-
2026/02/25
[jira] [Comment Edited] (FLINK-39131) Multi-Input Processors
Salva (Jira)
-
2026/02/25
[jira] [Comment Edited] (FLINK-39131) Multi-Input Processors
Salva (Jira)
-
2026/02/25
Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING (#2… [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING (#2… [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING (#2… [flink]
via GitHub
-
2026/02/25
[jira] [Closed] (FLINK-38978) Expose JM config for applications
Zhu Zhu (Jira)
-
2026/02/25
[jira] [Closed] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception
Zhu Zhu (Jira)
-
2026/02/25
[jira] [Assigned] (FLINK-39133) DispatcherTest.testApplicationStatusChange_ThrowsIfDuplicateTerminalStatus fails on state exception
Zhu Zhu (Jira)
-
2026/02/25
Re: [PR] [FLINK-38978][runtime] Expose JM config for applications [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39133][runtime] Fix DispatcherTest to properly handle async op… [flink]
via GitHub
-
2026/02/25
Re: [PR] [FLINK-39124][test] Migrate CancellingTestBase and StreamFaultToleranceTestBase to JUnit 5 [flink]
via GitHub
-
2026/02/24
Re: [PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
-
2026/02/24
Re: [PR] [FLINK-39124][test] Migrate streaming and runtime ITCases to JUnit 5 [flink]
via GitHub
-
2026/02/24
Re: [PR] [FLINK-39124][test] Migrate checkpointing ITCases to JUnit 5 [flink]
via GitHub
-
2026/02/24
Re: [PR] [FLINK-39124][test] Migrate operator restore tests to JUnit 5 [flink]
via GitHub
-
2026/02/24
[PR] [FLINK-39124][test] Migrate remaining flink-tests to JUnit 5 [flink]
via GitHub
-
2026/02/24
[PR] [FLINK-39124][test] Migrate streaming and runtime ITCases to JUnit 5 [flink]
via GitHub
-
2026/02/24
[PR] [FLINK-39124][test] Migrate checkpointing ITCases to JUnit 5 [flink]
via GitHub
-
2026/02/24
[PR] [FLINK-39124][test] Migrate operator restore tests to JUnit 5 [flink]
via GitHub
-
2026/02/24
[PR] [FLINK-39124][test] Migrate CancellingTestBase and StreamFaultToleranceTestBase to JUnit 5 [flink]
via GitHub
-
2026/02/24
Re: [PR] [FLINK-39117] Fix flaky ChainUnionTest [flink]
via GitHub
-
2026/02/24
[jira] [Updated] (FLINK-39117) Flaky ChainUnionTest testMigrationAndRestore
ASF GitHub Bot (Jira)
-
2026/02/24
[PR] [FLINK-39117] Fix flaky ChainUnionTest [flink]
via GitHub
-
2026/02/24
[jira] [Resolved] (FLINK-39041) Rebuild REST API docs pages to supplement the missing content.
Yuepeng Pan (Jira)
-
2026/02/24
Re: [PR] [FLINK-39041][docs] Rebuild REST API docs pages to supplement the missing content. [flink]
via GitHub
-
2026/02/24
Re: [PR] [FLINK-39041][docs] Rebuild REST API docs pages to supplement the missing content. [flink]
via GitHub
-
2026/02/24
Re: [PR] [FLINK-39094][table-planner] Avoid creating duplicate function instances in code generation [flink]
via GitHub
-
2026/02/24
[jira] [Created] (FLINK-39153) Add comprehensive performance metrics for PyFlink
Liu (Jira)
-
2026/02/24
Re: [I] [Feature] Support per-event-type configurable log levels for event log [flink-agents]
via GitHub
-
2026/02/24
[D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents]
via GitHub
-
2026/02/24
Re: [PR] [FLINK-38916][table-planner] MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1 [flink]
via GitHub
-
2026/02/24
Re: [PR] [FLINK-39094][table-planner] Avoid creating duplicate function instances in code generation [flink]
via GitHub
-
2026/02/24
Re: [PR] [FLINK-39094][table-planner] Avoid creating duplicate function instances in code generation [flink]
via GitHub
-
2026/02/24
Re: [I] [Feature] Runtime reloading for MCP tools and prompts [flink-agents]
via GitHub
-
2026/02/24
Re: [I] [Feature] Runtime reloading for MCP tools and prompts [flink-agents]
via GitHub
-
2026/02/24
[PR] [FLINK-39080][debug] test CI license behavior [flink-connector-kafka]
via GitHub
-
2026/02/24
Re: [D] [Feature] Dynamic Runtime Loading and Refresh of MCP Tools and Prompts [flink-agents]
via GitHub
-
2026/02/24
Re: [PR] Bump @angular/common from 20.1.3 to 20.3.14 in /flink-runtime-web/web-dashboard [flink]
via GitHub
-
2026/02/24
Re: [PR] [FLINK-37932] Add UserAgent in GCS requests [flink]
via GitHub
-
2026/02/24
Re: [PR] [FLINK-37932] Add UserAgent in GCS requests [flink]
via GitHub
-
2026/02/24
[jira] [Assigned] (FLINK-39117) Flaky ChainUnionTest testMigrationAndRestore
Roman Khachatryan (Jira)
-
2026/02/24
[jira] [Commented] (FLINK-39117) Flaky ChainUnionTest testMigrationAndRestore
Roman Khachatryan (Jira)
-
2026/02/24
Re: [I] [Feature] Support per-event-type configurable log levels for event log [flink-agents]
via GitHub
-
2026/02/24
[jira] [Commented] (FLINK-39117) Flaky ChainUnionTest testMigrationAndRestore
Shekhar Prasad Rajak (Jira)
-
2026/02/24
[jira] [Commented] (FLINK-38262) Convert connection sqlnode to operations
Shekhar Prasad Rajak (Jira)
-
2026/02/24
[jira] [Commented] (FLINK-38264) Connection table api
Shekhar Prasad Rajak (Jira)
-
2026/02/24
[jira] [Commented] (FLINK-38259) FLIP-529: Connections in Flink SQL and TableAPI
Shekhar Prasad Rajak (Jira)
-
2026/02/24
Re: [PR] [FLINK-38999][lineage] License lineage files [flink-connector-kafka]
via GitHub
-
2026/02/24
[jira] [Updated] (FLINK-39149) `gtid.new.channel.position=LATEST` Incorrectly Replays Pre-Checkpoint Transactions for Old Channels in Multi-Source Replication
ASF GitHub Bot (Jira)
-
2026/02/24
[PR] [FLINK-39149][mysql-cdc] Implement LATEST mode GTID merging to prevent replaying pre-checkpoint transactions with non-contiguous ranges [flink-cdc]
via GitHub
-
2026/02/24
[PR] Fix FlussConfig Utils class is not in the correct directory and does … [flink-cdc]
via GitHub
-
2026/02/24
Re: [PR] [FLINK-38247] Handle BIGINT UNSIGNED overflow in PreparedStatement [flink-cdc]
via GitHub
-
2026/02/24
[jira] [Created] (FLINK-39152) The FlussConfig Utils class is not in the correct directory and does not have a private instance
Thorne (Jira)
-
2026/02/24
[jira] [Commented] (FLINK-39049) Introduce built-in functions `VARIANT_VALUE` and `VARIANT_QUERY` to extract values from a variant
dylanhz (Jira)
-
2026/02/24
[jira] [Resolved] (FLINK-38455) MySQL CDC to ES8 pipeline connector cannot work
Yanquan Lv (Jira)
-
2026/02/24
[jira] [Updated] (FLINK-38893) Introduce the /jobs/:jobid/rescales/overview endpoint in the REST API
Yuepeng Pan (Jira)
-
2026/02/24
[jira] [Updated] (FLINK-38895) Introduce the /jobs/:jobid/rescales/details/:rescaleuuid endpoint in the REST API
Yuepeng Pan (Jira)
-
2026/02/24
[jira] [Updated] (FLINK-38896) Introduce the /jobs/:jobid/rescales/summary endpoint in the REST API
Yuepeng Pan (Jira)
-
2026/02/24
[jira] [Resolved] (FLINK-39143) It is better to use a transient connection for fluss's connection
Yanquan Lv (Jira)
-
2026/02/24
[jira] [Updated] (FLINK-38894) Introduce the /jobs/:jobid/rescales/history endpoint in the REST API
Yuepeng Pan (Jira)
-
2026/02/24
[jira] [Updated] (FLINK-38892) Introduce the scheduler and type information of the target job in the JobDetails(Info).java
Yuepeng Pan (Jira)
-
2026/02/24
[jira] [Updated] (FLINK-38897) Introduce the /jobs/:jobid/rescales/config endpoint in the REST API
Yuepeng Pan (Jira)