issues  

Messages by Date

• 2026/06/29 [jira] [Updated] (FLINK-39728) KafkaPartitionSplitReader.pauseOrResumeSplits throws IllegalStateException on concurrently unassigned partitions Jim Hughes (Jira)
• 2026/06/29 [jira] [Updated] (FLINK-39728) KafkaPartitionSplitReader.pauseOrResumeSplits throws IllegalStateException on concurrently unassigned partitions Jim Hughes (Jira)
• 2026/06/29 Re: [PR] [DO_NOT_MERGE][FLINK-38544] Validation: Force enable checkpointing during recovery in tests [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39938] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39938] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39938] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• 2026/06/29 Re: [PR] [BP-2.2][FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures [flink] via GitHub
• 2026/06/29 [jira] [Resolved] (FLINK-39728) KafkaPartitionSplitReader.pauseOrResumeSplits throws IllegalStateException on concurrently unassigned partitions Arvid Heise (Jira)
• 2026/06/29 [jira] [Commented] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Rui Fan (Jira)
• 2026/06/29 [jira] [Updated] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Rui Fan (Jira)
• 2026/06/29 [jira] [Commented] (FLINK-39728) KafkaPartitionSplitReader.pauseOrResumeSplits throws IllegalStateException on concurrently unassigned partitions Arvid Heise (Jira)
• 2026/06/29 Re: [PR] [BP-1.20][FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39728] Fix pauseOrResumeSplits race with unassigned partitions [flink-connector-kafka] via GitHub
• 2026/06/29 [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Rui Fan (Jira)
• 2026/06/29 Re: [PR] [FLINK-39728] Fix pauseOrResumeSplits race with unassigned partitions [flink-connector-kafka] via GitHub
• 2026/06/29 [jira] [Updated] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Rui Fan (Jira)
• 2026/06/29 [PR] [BP-1.20][FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures [flink] via GitHub
• 2026/06/29 [PR] [BP-2.2][FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/06/29 Re: [PR] [DO_NOT_MERGE][FLINK-38544] Validation: Force enable checkpointing during recovery in tests [flink] via GitHub
• 2026/06/29 Re: [D] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/06/29 [jira] [Created] (FLINK-40017) Introduce Seaweedfs in native-s3-fs Samrat Deb (Jira)
• 2026/06/29 Re: [PR] [FLINK-40012][table] Correctly inject Context into scalar-only PTFs in ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/29 Re: [PR] chore: move common CI scripts out of tools/azure-pipelines [flink] via GitHub
• 2026/06/29 Re: [PR] feat: new baseline nightly build [flink] via GitHub
• 2026/06/29 Re: [PR] feat: add nightly snapshot releases to GHA pipeline [flink] via GitHub
• 2026/06/29 Re: [PR] feat: add docs check to pull requests [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/06/29 [jira] [Updated] (FLINK-40012) Inject context into scalar only PTF invocation in PTF Test Harness ASF GitHub Bot (Jira)
• 2026/06/29 [PR] [FLINK-40012][table] Correctly inject Context into scalar-only PTFs in ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/29 [PR] chore: move common CI scripts out of tools/azure-pipelines [flink] via GitHub
• 2026/06/29 [PR] feat: new baseline nightly build [flink] via GitHub
• 2026/06/29 [PR] feat: add docs check to pull requests [flink] via GitHub
• 2026/06/29 [jira] [Assigned] (FLINK-39839) FLIP-580:AsyncTableFunction supports user-defined timeout handling logic lincoln lee (Jira)
• 2026/06/29 [PR] feat: add nightly snapshot releases to GHA pipeline [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/29 [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Rui Fan (Jira)
• 2026/06/29 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/29 [jira] [Commented] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Rui Fan (Jira)
• 2026/06/29 [jira] [Assigned] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Rui Fan (Jira)
• 2026/06/29 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-40013][table] Correctly clear state in ctx.clearState in ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/06/29 [jira] [Updated] (FLINK-40013) Correctly clear state in ctx.clearState in PTF Test Harness ASF GitHub Bot (Jira)
• 2026/06/29 [PR] [FLINK-40013][table] Correctly clear state in ctx.clearState in ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-40009][FLINK-40010][runtime] Stabilize RescaleTimelineITCase [flink] via GitHub
• 2026/06/29 Re: [PR] [hotfix][build] Bump netty to 4.2.15.Final [flink] via GitHub
• 2026/06/29 Re: [PR] [hotfix][build] Bump netty to 4.2.15.Final [flink] via GitHub
• 2026/06/29 [jira] [Created] (FLINK-40013) Correctly clear state in ctx.clearState in PTF Test Harness Mika Naylor (Jira)
• 2026/06/29 Re: [PR] [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-21995][yarn-tests] Whitelist netty-wrapped Pekko connection-refused WARN [flink] via GitHub
• 2026/06/29 [jira] [Created] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Martijn Visser (Jira)
• 2026/06/29 [jira] [Commented] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Martijn Visser (Jira)
• 2026/06/29 [jira] [Updated] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown. ASF GitHub Bot (Jira)
• 2026/06/29 [PR] [FLINK-21995][yarn-tests] Whitelist netty-wrapped Pekko connection-refused WARN [flink] via GitHub
• 2026/06/29 [jira] [Updated] (FLINK-40009) RescaleTimelineITCase.waitUntilConditionWithTimeout never enforces its timeout on a ForkJoinPool worker ASF GitHub Bot (Jira)
• 2026/06/29 [jira] [Updated] (FLINK-40011) CommonExecSinkITCase.testStreamRecordTimestampInserterSinkRuntimeProvider is flaky: test source can finish before NoMoreSplitsEvent is delivered ASF GitHub Bot (Jira)
• 2026/06/29 [PR] [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink] via GitHub
• 2026/06/29 [PR] [FLINK-40009][FLINK-40010][runtime] Stabilize RescaleTimelineITCase [flink] via GitHub
• 2026/06/29 Re: [PR] [python] warn when an action declares a return value [flink-agents] via GitHub
• 2026/06/29 [jira] [Created] (FLINK-40015) Wrap atomic PTF output in Row partition-key prepend & rowtime append in PTF Test Harness Mika Naylor (Jira)
• 2026/06/29 [jira] [Created] (FLINK-40014) Reject null entries/keys in list/map view in PTF Test Harness Mika Naylor (Jira)
• 2026/06/29 [jira] [Created] (FLINK-40012) Inject context into scalar only PTF invocation in PTF Test Harness Mika Naylor (Jira)
• 2026/06/29 [jira] [Created] (FLINK-40011) CommonExecSinkITCase.testStreamRecordTimestampInserterSinkRuntimeProvider is flaky: test source can finish before NoMoreSplitsEvent is delivered Martijn Visser (Jira)
• 2026/06/29 [jira] [Created] (FLINK-40010) RescaleTimelineITCase.testRescaleTerminatedByNoResourcesOrNoParallelismsChange is flaky: requirements-update can miss the in-progress rescale Martijn Visser (Jira)
• 2026/06/29 [jira] [Updated] (FLINK-40009) RescaleTimelineITCase.waitUntilConditionWithTimeout never enforces its timeout on a ForkJoinPool worker Martijn Visser (Jira)
• 2026/06/29 [jira] [Created] (FLINK-40009) RescaleTimelineITCase Martijn Visser (Jira)
• 2026/06/29 Re: [PR] [FLINK-40008][security] Replace fixed delegation token renewal retry backoff with exponential backoff [flink] via GitHub
• 2026/06/29 [PR] [hotfix][docs] Fix broken link in PyFlink documentation [flink] via GitHub
• 2026/06/29 [jira] [Created] (FLINK-40008) Replace fixed delegation token renewal retry backoff with exponential backoff Gabor Somogyi (Jira)
• 2026/06/29 Re: [PR] [hotfix][docs] Fix broken link in PyFlink documentation [flink] via GitHub
• 2026/06/29 Re: [PR] Bump @sigstore/core and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/06/29 [jira] [Updated] (FLINK-40008) Replace fixed delegation token renewal retry backoff with exponential backoff ASF GitHub Bot (Jira)
• 2026/06/29 [PR] [FLINK-40008][security] Replace fixed delegation token renewal retry backoff with exponential backoff [flink] via GitHub
• 2026/06/29 [PR] Bump @sigstore/core and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/06/29 [PR] [hotfix][docs] Document how to run the S3 end-to-end tests [flink] via GitHub
• 2026/06/29 Re: [PR] [hotfix][build] Bump netty to 4.2.15.Final [flink] via GitHub
• 2026/06/29 Re: [PR] [hotfix][docs] Document how to run the S3 end-to-end tests [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-30166][tests] Refactor tests that use the deprecated StreamingFileSink to FileSink [flink] via GitHub
• 2026/06/29 [jira] [Updated] (FLINK-39976) Flink cdc pipeline support db2 source pipeline connector ASF GitHub Bot (Jira)
• 2026/06/29 [PR] [FLINK-39976][pipeline-connector/db2] Add DB2 Pipeline connector [flink-cdc] via GitHub
• 2026/06/29 Re: [PR] Bump pygments from 2.19.2 to 2.20.0 in /flink-python/docs [flink] via GitHub
• 2026/06/29 Re: [I] [Tech Debt] Update Document version number from 0.2.0 and 0.2.1 [flink-agents] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/06/29 Re: [PR] Bump minimatch in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39274] TM It is impossible to bypass the KDC login process, yet the TOKEN issued by JM has not been actually utilized. [flink] via GitHub
• 2026/06/29 Re: [PR] Bump minimatch in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/06/29 Re: [PR] Bump minimatch in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39697] Bump Flink version to 2.2.1 [flink-connector-pulsar] via GitHub
• 2026/06/29 Re: [I] [Tech Debt] Update Document version number from 0.2.0 and 0.2.1 [flink-agents] via GitHub
• 2026/06/29 Re: [PR] [FLINK-38592] Initial Native Flink S3 FileSystem [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-37781][docs] Add elasticsearch lookup join document [flink-connector-elasticsearch] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/29 [jira] [Updated] (FLINK-40006) ElasticsearchRowDataLookupFunction leaks REST client / HTTP connections on task close ASF GitHub Bot (Jira)
• 2026/06/29 [PR] [FLINK-40006] ElasticsearchRowDataLookupFunction leaks REST client / HTTP connections on task close [flink-connector-elasticsearch] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/06/29 [PR] [FLINK-40007][postgres] Fix snapshot fetch size conf does not take effect [flink-cdc] via GitHub
• 2026/06/29 [jira] [Updated] (FLINK-40007) Fix Postgres CDC snapshot fetch size conf does not take effect Di Wu (Jira)
• 2026/06/29 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-40007][postgres] Use scan.snapshot.fetch.size for Postgres snapshot to avoid OOM on wide tables [flink-cdc] via GitHub
• 2026/06/29 [jira] [Updated] (FLINK-40007) Postgres CDC ignores scan.snapshot.fetch.size during snapshot, causing OOM on wide tables ASF GitHub Bot (Jira)
• 2026/06/29 [PR] [FLINK-40007][postgres] Use scan.snapshot.fetch.size for Postgres snapshot to avoid OOM on wide tables [flink-cdc] via GitHub
• 2026/06/29 [jira] [Updated] (FLINK-40007) Postgres CDC ignores scan.snapshot.fetch.size during snapshot, causing OOM on wide tables Di Wu (Jira)
• 2026/06/29 [jira] [Updated] (FLINK-40007) Postgres CDC ignores scan.snapshot.fetch.size during snapshot, causing OOM on wide tables Di Wu (Jira)
• 2026/06/28 Re: [PR] [FLINK-39888][Kafka] Allow configuring offset reset strategy independently [flink-connector-kafka] via GitHub
• 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

• Earlier messages
• Later messages