issues  

Messages by Date

• 2026/06/28 [jira] [Created] (FLINK-40007) Postgres CDC ignores scan.snapshot.fetch.size during snapshot, causing OOM on wide tables Di Wu (Jira)
• 2026/06/28 [jira] [Created] (FLINK-40006) ElasticsearchRowDataLookupFunction leaks REST client / HTTP connections on task close reswqa (Jira)
• 2026/06/28 Re: [PR] [FLINK-40002][table] Fix PushFilterInCalcIntoTableSourceScanRule for metadata filter push-down [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-40002][table] Fix PushFilterInCalcIntoTableSourceScanRule for metadata filter push-down [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-36334][tests] Enable Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses in flink-table-api-scala module [flink] via GitHub
• 2026/06/28 [jira] [Commented] (FLINK-38290) Application cluster: FINISHED FlinkDeployment falls back to RECONCILING if JM pod is lost/recreated Gunapati Bharath Reddy (Jira)
• 2026/06/28 Re: [PR] [FLINK-40005][cdc-cli] CliExecutor application mode reads pipeline definition from local file path [flink-cdc] via GitHub
• 2026/06/28 [jira] [Updated] (FLINK-40005) [cdc-cli] CliExecutor in application mode parses the pipeline definition file path as YAML content -> "Missing required field 'source'" ASF GitHub Bot (Jira)
• 2026/06/28 [PR] [FLINK-40005][cdc-cli] CliExecutor application mode reads pipeline definition from local file path [flink-cdc] via GitHub
• 2026/06/28 [jira] [Created] (FLINK-40005) [cdc-cli] CliExecutor in application mode parses the pipeline definition file path as YAML content -> "Missing required field 'source'" Jiyong Wang (Jira)
• 2026/06/28 [jira] [Created] (FLINK-40004) Flink 1.20.x with jdbc-connector 3.3.0 fails to create Catalog due to multiple 'jdbc' CatalogFactory implementations in classpath songbin (Jira)
• 2026/06/28 Re: [PR] [FLINK-30975][filesystems] Upgrade to Hadoop to 3.4.3 and support AWS SDK v2 in flink-filesystem [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39179][mysql] Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing [flink-cdc] via GitHub
• 2026/06/28 Re: [PR] [FLINK-38236][mongodb] Add metadata support for full document in MongoDB CDC connector [flink-cdc] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39020][pipeline][doris] Fix the bug When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) [flink-cdc] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39873][streaming] Add null check for `connectedSocket` in `SocketStreamIterator.notifyOfError()` [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39987][state] update doc [flink] via GitHub
• 2026/06/28 [jira] [Updated] (FLINK-39987) Update docs related to flink-state-processing-api ASF GitHub Bot (Jira)
• 2026/06/28 [PR] [FLINK-39987][state] update doc [flink] via GitHub
• 2026/06/28 [PR] Add JDK-25 to the JDK build matrix [flink-connector-opensearch] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39980] Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes [flink-connector-kafka] via GitHub
• 2026/06/28 Re: [PR] [hotfix] Add JDK-25 to the JDK build matrix [flink-connector-opensearch] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39875][table-gateway] Restore thread interrupt status in ResultStore [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39951][python] Fix string reference equality bug in ArrayConstructor causing silent long value truncation [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39951][python] Fix string reference equality bug in ArrayConstructor causing silent long value truncation [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39951][python] Fix string reference equality bug in ArrayConstructor causing silent long value truncation [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39951][python] Fix string reference equality bug in ArrayConstructor causing silent long value truncation [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39951][python] Fix string reference equality bug in ArrayConstructor causing silent long value truncation [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39951][python] Fix string reference equality bug in ArrayConstructor causing silent long value truncation [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-36317][runtime] Populate ArchivedExecutionGraph with CheckpointStatsSnapshot in WaitingForResources state [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39875][table-gateway] Restore thread interrupt status in ResultStore [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39951][python] Fix string reference equality bug in ArrayConstructor causing silent long value truncation [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/28 [PR] Fix MySQL CDC column comment propagation and complete schema change/comment PR [flink-cdc] via GitHub
• 2026/06/28 Re: [PR] [FLINK-30166][tests] Refactor tests that use the deprecated StreamingFileSink to FileSink [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-30166][tests] Refactor tests that use the deprecated StreamingFileSink to FileSink [flink] via GitHub
• 2026/06/28 [PR] [FLINK-30166][tests] Refactor tests that use the deprecated StreamingFileSink to FileSink [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-39499][tests] Launch the SeaweedFS S3 test backend via 'weed mini' [flink] via GitHub
• 2026/06/28 [jira] [Commented] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb Purushottam Sinha (Jira)
• 2026/06/28 [jira] [Commented] (FLINK-29776) [JUnit5 Migration] Module: flink-statebackend-changelog Purushottam Sinha (Jira)
• 2026/06/28 Re: [PR] [FLINK-37951] Enable VariantSerializerUpgradeTest [flink] via GitHub
• 2026/06/28 Re: [PR] [FLINK-37951] Enable VariantSerializerUpgradeTest [flink] via GitHub
• 2026/06/27 [PR] [hotfix][docs] Fix typos in operator documentation [flink-kubernetes-operator] via GitHub
• 2026/06/27 Re: [PR] [FLINK-38961][metrics] Display process metrics (CPU, Memory, I/O) on TaskManager Web UI [flink] via GitHub
• 2026/06/27 [jira] [Updated] (FLINK-38961) Display process metrics (CPU, Memory, I/O) on TaskManager Web UI ASF GitHub Bot (Jira)
• 2026/06/27 [PR] [FLINK-38961][metrics] Display process metrics (CPU, Memory, I/O) on TaskManager Web UI [flink] via GitHub
• 2026/06/27 [PR] ci: pin GitHub Actions to full commit SHAs [flink] via GitHub
• 2026/06/27 [PR] ci: pin GitHub Actions to full commit SHAs [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/27 [jira] [Commented] (FLINK-39193) SpecifiedOffsetsInitializer can fail if the caller passes a non-empty but incomplete specific-offset map. Qiu Yanjun (Jira)
• 2026/06/27 [PR] [FLINK-39193][Kafka Connector] Use reset strategy for missing specified offsets [flink-connector-kafka] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39962] [runtime] Fix flaky DeclarativeSlotPoolBridgeTest [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-33725][core] Return false from MathUtils.isPowerOf2 for non-positive values [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/27 [jira] [Commented] (FLINK-33505) switch away from using netty 3 based Pekko Classic Remoting PJ Fanning (Jira)
• 2026/06/27 [jira] [Comment Edited] (FLINK-33505) switch away from using netty 3 based Pekko Classic Remoting PJ Fanning (Jira)
• 2026/06/27 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/27 [jira] [Updated] (FLINK-39770) [JUnit5 Migration] Module: flink-state-processing-api ASF GitHub Bot (Jira)
• 2026/06/27 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/27 [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39499][tests] Launch the SeaweedFS S3 test backend via 'weed mini' [flink] via GitHub
• 2026/06/27 [PR] [FLINK-39499][tests] Launch the SeaweedFS S3 test backend via 'weed mini' [flink] via GitHub
• 2026/06/27 Re: [PR] [DO_NOT_MERGE][CDR][FTW] checkpointing during recovery [flink] via GitHub
• 2026/06/27 Re: [PR] [DO_NOT_MERGE] Force CDR in tests [flink] via GitHub
• 2026/06/27 Re: [PR] [DO_NOT_MERGE][CDR][FTW] checkpointing during recovery [flink] via GitHub
• 2026/06/27 Re: [PR] [DO_NOT_MERGE] Disable CDR in tests [flink] via GitHub
• 2026/06/27 Re: [PR] [DO_NOT_MERGE] Force CDR in tests [flink] via GitHub
• 2026/06/27 [PR] [DO_NOT_MERGE] Disable CDR in tests [flink] via GitHub
• 2026/06/27 [PR] [DO_NOT_MERGE] Force CDR in tests [flink] via GitHub
• 2026/06/27 [jira] [Comment Edited] (FLINK-34406) Expose RuntimeContext in FunctionContext Chen Zhang (Jira)
• 2026/06/27 [jira] [Resolved] (FLINK-39772) [JUnit5 Migration] Module: flink-fs-tests Sergey Nuyanzin (Jira)
• 2026/06/27 [jira] [Commented] (FLINK-39999) Make Flink Sql calls unparsable as it is required by Calcite 1.42.0 Sergey Nuyanzin (Jira)
• 2026/06/27 [jira] [Resolved] (FLINK-39999) Make Flink Sql calls unparsable as it is required by Calcite 1.42.0 Sergey Nuyanzin (Jira)
• 2026/06/27 [jira] [Commented] (FLINK-39772) [JUnit5 Migration] Module: flink-fs-tests Sergey Nuyanzin (Jira)
• 2026/06/27 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39999][table] Make Flink Sql calls unparsable as it is required by Calcite 1.42.0 [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-38262][table] add CreateConnectionOperation and converter [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-33725][core] Return false from MathUtils.isPowerOf2 for non-positive values [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-33725][core] Return false from MathUtils.isPowerOf2 for non-positive values [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-33725][core] Return false from MathUtils.isPowerOf2 for non-positive values [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-40002][table] Fix PushFilterInCalcIntoTableSourceScanRule for metadata filter push-down [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-33725][core] Return false from MathUtils.isPowerOf2 for non-positive values [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39832] Fix Oracle NUMBER(p,0) with p>=19 incorrectly mapped to BIGINT [flink-cdc] via GitHub
• 2026/06/27 Re: [PR] [FLINK-33725][core] Return false from MathUtils.isPowerOf2 for non-positive values [flink] via GitHub
• 2026/06/27 [jira] [Resolved] (FLINK-40000) Remove the redundant testing util class SynchronousComponentMainThreadExecutor Yuepeng Pan (Jira)
• 2026/06/27 [jira] [Commented] (FLINK-40000) Remove the redundant testing util class SynchronousComponentMainThreadExecutor Yuepeng Pan (Jira)
• 2026/06/27 Re: [PR] [FLINK-40000][runtime/test] Remove the redundant testing util class SynchronousComponentMainThreadExecutor [flink] via GitHub
• 2026/06/27 [jira] [Updated] (FLINK-33725) MathUtils.isPowerOf2 does not cover the case of value=0 ASF GitHub Bot (Jira)
• 2026/06/27 [PR] [FLINK-33725][core] Return false from MathUtils.isPowerOf2 for non-positive values [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39160][Rpc] Add RPC response frame size metrics [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-39160][Rpc] Add RPC response frame size metrics [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-36540][Runtime] Add Support for Hadoop Caller Context when using Flink to operate hdfs. [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-36540][Runtime] Add Support for Hadoop Caller Context when using Flink to operate hdfs. [flink] via GitHub
• 2026/06/27 Re: [PR] [FLINK-37431]We should use guava Lists instead of curator shade Lists… [flink] via GitHub
• 2026/06/26 Re: [PR] [DEBUG - DO NOT MERGE][FLINK-38544] hunt 1 [flink] via GitHub
• 2026/06/26 Re: [PR] [DO_NOT_MERGE][CDR][FTW] checkpointing during recovery [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-40000][runtime/test] Remove the redundant testing util class SynchronousComponentMainThreadExecutor [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/06/26 Re: [PR] [FLINK-36813][cdc-connectors][mysql] support mysql sync part columns [flink-cdc] via GitHub
• 2026/06/26 Re: [PR] [FLINK-40002][table] Fix PushFilterInCalcIntoTableSourceScanRule for metadata filter push-down [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/06/26 [jira] [Updated] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore ASF GitHub Bot (Jira)
• 2026/06/26 [PR] [FLINK-40002][table] Fix PushFilterInCalcIntoTableSourceScanRule for metadata filter push-down [flink] via GitHub
• 2026/06/26 [jira] [Updated] (FLINK-40003) IOMetrics not visible to ExecutionStateUpdateListeners during FINISHED/FAILED transitions ASF GitHub Bot (Jira)
• 2026/06/26 [PR] [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/06/26 Re: [PR] [DO_NOT_MERGE] checkpointing during recovery [flink] via GitHub
• 2026/06/26 [PR] [DO_NOT_MERGE] checkpointing during recovery [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39980] Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes [flink-connector-kafka] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39980] Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes [flink-connector-kafka] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39980] Implement split rebalance/reassignment support in DynamicKafkaSource after metadata changes [flink-connector-kafka] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/26 [jira] [Updated] (FLINK-40003) IOMetrics not visible to ExecutionStateUpdateListeners during FINISHED/FAILED transitions Chris Johnson (Jira)
• 2026/06/26 [jira] [Created] (FLINK-40003) IOMetrics not visible to ExecutionStateUpdateListeners during FINISHED/FAILED transitions Chris Johnson (Jira)
• 2026/06/26 Re: [PR] FLIP-573: [DRAFT] Queues for Kafka [flink-connector-kafka] via GitHub
• 2026/06/26 Re: [PR] FLIP-573: [DRAFT] Queues for Kafka [flink-connector-kafka] via GitHub
• 2026/06/26 Re: [PR] [hotfix] Fix reader idleness test output [flink-connector-kafka] via GitHub
• 2026/06/26 Re: [PR] [hotfix] Fix typos in documentation source and templates [flink-web] via GitHub
• 2026/06/26 [PR] [hotfix] Fix typos in documentation source and templates [flink-web] via GitHub
• 2026/06/26 [PR] [hotfix] Fix reader idleness test output [flink-connector-kafka] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39837] Reassign retained dynamic Kafka offsets upon readd [flink-connector-kafka] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39837] Reassign retained dynamic Kafka offsets upon readd [flink-connector-kafka] via GitHub
• 2026/06/26 [jira] [Resolved] (FLINK-39443) Prepare Flink 2.3 release David Anderson (Jira)
• 2026/06/26 [jira] [Resolved] (FLINK-39378) Add support for timers in ProcessTableFunctionTestHarness Fabian Hueske (Jira)
• 2026/06/26 [jira] [Assigned] (FLINK-39378) Add support for timers in ProcessTableFunctionTestHarness Fabian Hueske (Jira)
• 2026/06/26 Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink] via GitHub
• 2026/06/26 Re: [PR] [hotfix] Add HTTP connector 1.0 docs [flink] via GitHub
• 2026/06/26 Re: [PR] FLIP-573: [DRAFT] Queues for Kafka [flink-connector-kafka] via GitHub
• 2026/06/26 Re: [PR] [FLINK-36334][tests] Enable Remove the Disable markers from the tests in the various TypeSerializerUpgradeTestBase subclasses in flink-table-api-scala module [flink] via GitHub
• 2026/06/26 [jira] [Updated] (FLINK-38919) add doc of pyflink DynamicKafkaSource per cluster offset feature to flink-connector-kafka ASF GitHub Bot (Jira)
• 2026/06/26 [PR] [FLINK-38919][docs] Document PyFlink per-cluster offsets [flink-connector-kafka] via GitHub
• 2026/06/26 Re: [PR] FLIP-573: [DRAFT] Queues for Kafka [flink-connector-kafka] via GitHub
• 2026/06/26 [jira] [Updated] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal Bowen Li (Jira)
• 2026/06/26 [jira] [Commented] (FLINK-39979) DynamicKafkaSource should mark reader idle when metadata removal leaves a subtask with no active subreaders Bowen Li (Jira)
• 2026/06/26 [jira] [Updated] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal Bowen Li (Jira)
• 2026/06/26 [jira] [Resolved] (FLINK-39979) DynamicKafkaSource should mark reader idle when metadata removal leaves a subtask with no active subreaders Bowen Li (Jira)
• 2026/06/26 Re: [PR] [FLINK-39979] DynamicKafkaSource should mark reader idle when metadata removal leaves a subtask with no active subreaders [flink-connector-kafka] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39979] DynamicKafkaSource should mark reader idle when metadata removal leaves a subtask with no active subreaders [flink-connector-kafka] via GitHub
• 2026/06/26 Re: [PR] [test] Try to Fix flaky tests with AI assistance [flink-cdc] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-38262][table] add CreateConnectionOperation and converter [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-38262][table] add CreateConnectionOperation and converter [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-38262][table] add CreateConnectionOperation and converter [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-38262][table] add CreateConnectionOperation and converter [flink] via GitHub
• 2026/06/26 Re: [PR] [DEBUG - DO NOT MERGE][FLINK-38544] hunt 1 [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-38262][table] add CreateConnectionOperation and converter [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/06/26 [jira] [Commented] (FLINK-39969) use the same SSL protcol and algorithms on all the flink services and all clients Jira
• 2026/06/26 [jira] [Updated] (FLINK-39969) use the same SSL protcol and algorithms on all the flink services and all clients Jira
• 2026/06/26 [jira] [Updated] (FLINK-39969) use the same SSL protcol and algorithms on all the flink services and all clients Jira
• 2026/06/26 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/06/26 [jira] [Commented] (FLINK-39969) use the same SSL protcol and algorithms on all the flink services and all clients Jira
• 2026/06/26 [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39999][table] Make Flink Sql calls unparsable as it is required by Calcite 1.42.0 [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39999][table] Make Flink Sql calls unparsable as it is required by Calcite 1.42.0 [flink] via GitHub
• 2026/06/26 Re: [PR] [test] Try to Fix flaky tests with AI assistance [flink-cdc] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39772][tests][JUnit5 migration] Module: flink-fs-tests [flink] via GitHub
• 2026/06/26 Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink] via GitHub
• 2026/06/26 [jira] [Assigned] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore Jim Hughes (Jira)
• 2026/06/26 [jira] [Assigned] (FLINK-33217) Flink SQL: UNNEST fails with on LEFT JOIN with NOT NULL type in array Jim Hughes (Jira)
• 2026/06/26 [jira] [Assigned] (FLINK-33217) Flink SQL: UNNEST fails with on LEFT JOIN with NOT NULL type in array Jim Hughes (Jira)
• 2026/06/26 [jira] [Created] (FLINK-40002) `PushFilterInCalcIntoTableSourceScanRule` misroutes metadata predicates, crashing compiled-plan restore Jim Hughes (Jira)
• 2026/06/26 Re: [PR] [FLINK-39999][table] Make Flink Sql calls unparsable as it is required by Calcite 1.42.0 [flink] via GitHub
• 2026/06/26 [jira] [Updated] (FLINK-39969) use the same SSL protcol and algorithms on all the flink services and all clients Jira
• 2026/06/26 Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink] via GitHub
• 2026/06/26 [jira] [Assigned] (FLINK-39031) [PyFlink] support Python 3.13 and 3.14 Mika Naylor (Jira)
• 2026/06/26 Re: [PR] [FLINK-39378][table] Add support for Context, timers and on_time to PTF test harness [flink] via GitHub
• 2026/06/26 [jira] [Updated] (FLINK-40000) Remove the redundant testing util class SynchronousComponentMainThreadExecutor ASF GitHub Bot (Jira)
• 2026/06/26 Re: [PR] [FLINK-40000][runtime/test] Remove the redundant testing util class SynchronousComponentMainThreadExecutor [flink] via GitHub

• Earlier messages
• Later messages