issues  

Messages by Date

• 2026/06/30 Re: [PR] [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-35230][table] Split FlinkSqlParserImplTest into smaller test classes [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-38233] Adds support to StreamNonDeterministicUpdatePlanVisitor for PTF changelogs [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/06/30 [jira] [Resolved] (FLINK-40013) Correctly clear state in ctx.clearState in PTF Test Harness Fabian Hueske (Jira)
• 2026/06/30 Re: [PR] [FLINK-40013][table] Correctly clear state in ctx.clearState in ProcessTableFunctionTestHarness [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-38697][runtime] Store task information blob key in JobVertex [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-39934][postgres] Fix invalid tables format error message [flink-cdc] via GitHub
• 2026/06/30 Re: [PR] [Flink-38911][cdc connector mysql] mysql-cdc-connector datastream support scan.binlog.newly-added-table.enabled [flink-cdc] via GitHub
• 2026/06/30 Re: [PR] [FLINK-39987][state] update State Processor API doc to include filter pushdown examples [flink] via GitHub
• 2026/06/30 Re: [PR] [api][java][python] Introduce EventType constants and unify Action trigger entry [flink-agents] via GitHub
• 2026/06/30 Re: [PR] [FLINK-35230][table] Split FlinkSqlParserImplTest into smaller test classes [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-35230][table] Split FlinkSqlParserImplTest into smaller test classes [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-35230][table] Split FlinkSqlParserImplTest into smaller test classes [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-35230][table] Split FlinkSqlParserImplTest into smaller test classes [flink] via GitHub
• 2026/06/30 [jira] [Reopened] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core Martijn Visser (Jira)
• 2026/06/30 [jira] [Commented] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core Martijn Visser (Jira)
• 2026/06/30 [PR] [FLINK-35459] Use Incremental Source Framework in Flink tidb CDC Source Connector [flink-cdc] via GitHub
• 2026/06/30 [jira] [Updated] (FLINK-38406) DefaultSchedulerCheckpointCoordinatorTest failed in test_ci core Martijn Visser (Jira)
• 2026/06/30 Re: [PR] [BP-1.20][FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures [flink] via GitHub
• 2026/06/30 Re: [PR] [BP-2.2][FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-35459] Use Incremental Source Framework in Flink tidb CDC Source Connector [flink-cdc] via GitHub
• 2026/06/30 [jira] [Updated] (FLINK-40009) RescaleTimelineITCase.waitUntilConditionWithTimeout never enforces its timeout on a ForkJoinPool worker Martijn Visser (Jira)
• 2026/06/30 Re: [PR] [FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator [flink] via GitHub
• 2026/06/30 Re: [PR] [hotfix][metrics] Fix NullArgumentException when calculating checkpoint statistics with empty data [flink] via GitHub
• 2026/06/30 Re: [PR] [hotfix][metrics] Fix NullArgumentException when calculating checkpoint statistics with empty data [flink] via GitHub
• 2026/06/30 [jira] [Commented] (FLINK-39718) Paimon pipeline sink fails with distributed source when target table does not exist Chengbing Liu (Jira)
• 2026/06/30 Re: [PR] [api][java][python] Introduce EventType constants and unify Action trigger entry [flink-agents] via GitHub
• 2026/06/30 Re: [PR] [FLINK-35230][table] Split FlinkSqlParserImplTest into smaller test classes [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-35230][table] Split FlinkSqlParserImplTest into smaller test classes [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-35230][table] Split FlinkSqlParserImplTest into smaller test classes [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-35230][table] Split FlinkSqlParserImplTest into smaller test classes [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-40021][table] `AND` for pushdown filters should be in uppercase [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-35230][table] Split FlinkSqlParserImplTest into smaller test classes [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-35230][table] Split FlinkSqlParserImplTest into smaller test classes [flink] via GitHub
• 2026/06/30 Re: [PR] [FLINK-39382][docs] Clarify auto.offset.reset support in Kafka SQL connector [flink-connector-kafka] via GitHub
• 2026/06/30 [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Martijn Visser (Jira)
• 2026/06/29 [jira] [Updated] (FLINK-40021) AND for pushdown filters should be in uppercase ASF GitHub Bot (Jira)
• 2026/06/29 [PR] [FLINK-40021][table] `AND` for pushdown filters should be in uppercase [flink] via GitHub
• 2026/06/29 [jira] [Closed] (FLINK-26514) YARNSessionFIFOITCase.testDetachedMode failed on azure Martijn Visser (Jira)
• 2026/06/29 [jira] [Assigned] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown. Martijn Visser (Jira)
• 2026/06/29 [jira] [Resolved] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown. Martijn Visser (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-21995][yarn-tests] Whitelist netty-wrapped Pekko connection-refused WARN [flink] via GitHub
• 2026/06/29 [jira] [Created] (FLINK-40021) AND for pushdown filters should be in uppercase Sergey Nuyanzin (Jira)
• 2026/06/29 Re: [PR] [FLINK-35275][table] Fix ArrayContainsFunction using incorrect element type from needle argument [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-35275][table] Fix ArrayContainsFunction using incorrect element type from needle argument [flink] via GitHub
• 2026/06/29 Re: [PR] [api][routing] Pluggable in-chat LLM routing (ChatModelRouter + RoutingStrategy) [flink-agents] via GitHub
• 2026/06/29 Re: [PR] [api][routing] Pluggable in-chat LLM routing (ChatModelRouter + RoutingStrategy) [flink-agents] via GitHub
• 2026/06/29 Re: [PR] [api][routing] Pluggable in-chat LLM routing (ChatModelRouter + RoutingStrategy) [flink-agents] 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] [api][routing] Pluggable in-chat LLM routing (ChatModelRouter + RoutingStrategy) [flink-agents] via GitHub
• 2026/06/29 Re: [PR] [api][routing] Pluggable in-chat LLM routing (ChatModelRouter + RoutingStrategy) [flink-agents] via GitHub
• 2026/06/29 Re: [PR] [api][routing] Pluggable in-chat LLM routing (ChatModelRouter + RoutingStrategy) [flink-agents] via GitHub
• 2026/06/29 [jira] [Assigned] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core Martijn Visser (Jira)
• 2026/06/29 Re: [PR] [hotfix] Fix typos in operator documentation, comments and scripts [flink-kubernetes-operator] via GitHub
• 2026/06/29 [jira] [Resolved] (FLINK-40011) CommonExecSinkITCase.testStreamRecordTimestampInserterSinkRuntimeProvider is flaky: test source can finish before NoMoreSplitsEvent is delivered Martijn Visser (Jira)
• 2026/06/29 Re: [PR] [FLINK-40011][table-planner] Fix NoMoreSplitsEvent race in CommonExecSinkITCase [flink] via GitHub
• 2026/06/29 [jira] [Resolved] (FLINK-38536) FinalizeOnMasterTest failed in test_cron_hadoop313 core Martijn Visser (Jira)
• 2026/06/29 Re: [PR] [FLINK-38536][tests] Fix data race in FinalizeOnMasterTest and ExecutionGraphFinishTest [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-40002][table] Fix PushFilterInCalcIntoTableSourceScanRule for metadata filter push-down [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-40002][table] Fix PushFilterInCalcIntoTableSourceScanRule for metadata filter push-down [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-40002][table] Fix PushFilterInCalcIntoTableSourceScanRule for metadata filter push-down [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-40009][FLINK-40010][runtime] Stabilize RescaleTimelineITCase [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39987][state] update doc [flink] via GitHub
• 2026/06/29 [jira] [Updated] (FLINK-40020) Flink 2.3: update reference data for migration tests David Anderson (Jira)
• 2026/06/29 [jira] [Created] (FLINK-40020) Flink 2.3: update migration data for tests David Anderson (Jira)
• 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] [hotfix][docs] Document how to run the S3 end-to-end tests [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-40002][table] Fix PushFilterInCalcIntoTableSourceScanRule for metadata filter push-down [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-40002][table] Fix PushFilterInCalcIntoTableSourceScanRule for metadata filter push-down [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-40002][table] Fix PushFilterInCalcIntoTableSourceScanRule for metadata filter push-down [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39193][Kafka Connector] Use reset strategy for missing specified offsets [flink-connector-kafka] via GitHub
• 2026/06/29 Re: [PR] [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/06/29 Re: [PR] [hotfix] Fix typos in documentation source and templates [flink-web] via GitHub
• 2026/06/29 [jira] [Closed] (FLINK-33505) switch away from using netty 3 based Pekko Classic Remoting Ferenc Csaky (Jira)
• 2026/06/29 Re: [PR] [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/06/29 [jira] [Assigned] (FLINK-40019) FLIP-588: Support per-job delegation tokens Rui Fan (Jira)
• 2026/06/29 [jira] [Created] (FLINK-40019) FLIP-588: Support per-job delegation tokens Aleksandr Savonin (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] [hotfix][docs] Document how to run the S3 end-to-end tests [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-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39775][mysql] Release snapshot split metadata after entering the stream phase [flink-cdc] 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] [Assigned] (FLINK-40003) IOMetrics not visible to ExecutionStateUpdateListeners during FINISHED/FAILED transitions Matthias Pohl (Jira)
• 2026/06/29 [jira] [Updated] (FLINK-40003) IOMetrics not visible to ExecutionStateUpdateListeners during FINISHED/FAILED transitions Matthias Pohl (Jira)
• 2026/06/29 [jira] [Created] (FLINK-40018) PTF changelog inference silently drops an unsatisfiable table input, causing IndexOutOfBoundsException Gustavo de Morais (Jira)
• 2026/06/29 Re: [PR] [FLINK-40003][runtime] Fix IOMetrics not visible to state transition listeners [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39995][json] Add ISO-8601 timestamp format with explicit timezone offset support [flink] via GitHub
• 2026/06/29 [jira] [Closed] (FLINK-39998) RocksDBStateDownloader loses parallel download failures, surfacing a misleading ClosedChannelException instead of the real root cause Gyula Fora (Jira)
• 2026/06/29 [jira] [Assigned] (FLINK-39998) RocksDBStateDownloader loses parallel download failures, surfacing a misleading ClosedChannelException instead of the real root cause Gyula Fora (Jira)
• 2026/06/29 Re: [PR] [FLINK-39998][state] Surface root cause exception when parallel RocksDB state download fails [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-39995][json] Add ISO-8601 timestamp format with explicit timezone offset support [flink] via GitHub
• 2026/06/29 Re: [PR] [FLINK-39995][json] Add ISO-8601 timestamp format with explicit timezone offset support [flink] via GitHub
• 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

• Earlier messages
• Later messages