issues

Messages by Date

2026/10/25 [jira] [Created] (FLINK-41173) Migrate AbstractQueryableStateTestBase sources to Source V2 Martijn Visser (Jira)
2026/10/25 [jira] [Created] (FLINK-41175) Migrate S5CmdOnSeaweedFsITCase to FailingCheckpointedSource Martijn Visser (Jira)
2026/10/25 Re: [PR] [FLINK-41100][Connectors/Kafka] Make dynamic source split ids unique per partition [flink-connector-kafka] via GitHub
2026/10/25 Re: [PR] [FLINK-41116][Connectors/Kafka] Upgrade kafka-clients to 4.4.0 [flink-connector-kafka] via GitHub
2026/10/25 [jira] [Updated] (FLINK-41119) Prepare Flink 2.4 release ASF GitHub Bot (Jira)
2026/10/25 [PR] [FLINK-41119][release] Build docs for release-2.4 branch [flink] via GitHub
2026/10/25 [jira] [Created] (FLINK-41172) Migrate flink-state-processing-api test sources to Source V2 Martijn Visser (Jira)
2026/10/25 [jira] [Created] (FLINK-41164) Upgrade Testcontainers to 1.21.4 on the flink-connector-mongodb v2.0 branch Purushottam Sinha (Jira)
2026/10/25 [jira] [Created] (FLINK-41162) Migrate CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase to Source V2 Martijn Visser (Jira)
2026/10/25 [jira] [Updated] (FLINK-41122) [release-2.4] Create release branch ASF GitHub Bot (Jira)
2026/10/25 [PR] [FLINK-41122] Add version 2.5 and update nightly build action [flink] via GitHub
2026/10/25 [jira] [Created] (FLINK-41178) Upgrade version tag from '2.4-SNAPSHOT' to '2.5-SNAPSHOT' in REST-API related doc files to fix CI failure Yuepeng Pan (Jira)
2026/10/25 [jira] [Updated] (FLINK-41178) Upgrade version tag from '2.4-SNAPSHOT' to '2.5-SNAPSHOT' in REST-API related doc files to fix CI failure Yuepeng Pan (Jira)
2026/10/25 [jira] [Created] (FLINK-41174) Migrate KubernetesHighAvailabilityRecoverFromSavepointITCase to Source V2 Martijn Visser (Jira)
2026/10/25 Re: [PR] [FLINK-32695] [Tests] Migrated SimpleStringGenerator to Source V2 Implementation [flink] via GitHub
2026/10/25 [jira] [Created] (FLINK-41171) Migrate the operator restore test jobs KeyedJob and NonKeyedJob to Source V2 Martijn Visser (Jira)
2026/10/25 Re: [PR] [FLINK-41116][Connectors/Kafka] Upgrade kafka-clients to 4.4.0 [flink-connector-kafka] via GitHub
2026/10/25 [jira] [Created] (FLINK-41159) Remove unused SourceFunction test sources from flink-yarn-tests Martijn Visser (Jira)
2026/10/25 [jira] [Created] (FLINK-41176) Migrate flink-connector-files sink ITCase sources to Source V2 Martijn Visser (Jira)
2026/10/25 [jira] [Updated] (FLINK-41164) Upgrade Testcontainers to 1.21.4 on the flink-connector-mongodb v2.0 branch ASF GitHub Bot (Jira)
2026/10/25 [PR] [FLINK-41164][build] Upgrade Testcontainers to 1.21.4 [flink-connector-mongodb] via GitHub
2026/10/25 Re: [PR] [FLINK-40278][connector-http] Document and test that HTTP sink retries resend the whole batch [flink-connector-http] via GitHub
2026/10/25 [jira] [Updated] (FLINK-41116) Connectors/Kafka: Upgrade kafka-clients to 4.4.0 Purushottam Sinha (Jira)
2026/10/25 Re: [PR] [FLINK-37751][autoscaler] Add vertex name to the autoscaler scaling metrics [flink-kubernetes-operator] via GitHub
2026/10/25 [jira] [Created] (FLINK-41165) Migrate the remaining checkpointing ITCases with generated sources to DataGeneratorSource Martijn Visser (Jira)
2026/10/25 [jira] [Created] (FLINK-41170) Migrate classloading jar programs and shared util sources to Source V2 Martijn Visser (Jira)
2026/10/25 [jira] [Created] (FLINK-41167) Migrate the remaining checkpointing ITCases with controllable sources to Source V2 Martijn Visser (Jira)
2026/10/25 Re: [PR] [docs] Migrate documentation from Hugo to Docusaurus [flink-cdc] via GitHub
2026/10/25 Re: [PR] [FLINK-40873][operator] Remove overlapping config key prefixes [flink-kubernetes-operator] via GitHub
2026/10/25 Re: [PR] [FLINK-41100][Connectors/Kafka] Make dynamic source split ids unique per partition [flink-connector-kafka] via GitHub
2026/10/25 [jira] [Resolved] (FLINK-41158) Upgrade Testcontainers to 2.0.5 in flink-connector-kafka Martijn Visser (Jira)
2026/10/25 Re: [PR] [FLINK-41116][Connectors/Kafka] Upgrade kafka-clients to 4.4.0 [flink-connector-kafka] via GitHub
2026/10/25 Re: [PR] [FLINK-40129][Connectors/Kafka] Topic integrity check in table API [flink-connector-kafka] via GitHub
2026/10/25 Re: [PR] [FLINK-40873][operator] Remove overlapping config key prefixes [flink-kubernetes-operator] via GitHub
2026/10/25 Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
2026/10/25 [jira] [Resolved] (FLINK-41156) Upgrade Testcontainers to 1.21.4 on the JDBC connector v4.1 and v3.4 branches to support Docker 29 Martijn Visser (Jira)
2026/10/25 Re: [PR] [FLINK-41100][Connectors/Kafka] Make dynamic source split ids unique per partition [flink-connector-kafka] via GitHub
2026/10/25 Re: [PR] [BP-4.1][FLINK-41156][build] Bump Testcontainers to 1.21.4 [flink-connector-jdbc] via GitHub
2026/10/25 [jira] [Resolved] (FLINK-40949) WindowedUnsliceAssigner reports a NULL window bound as "RowTime field should not be null." Sergey Nuyanzin (Jira)
2026/10/25 Re: [PR] [FLINK-40949][table-runtime] Update UnsliceAssigners NULL window exception message [flink] via GitHub
2026/10/25 Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
2026/10/25 Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
2026/10/25 Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
2026/10/25 [jira] [Updated] (FLINK-41154) Make the connector release scripts work reliably on macOS and Linux ASF GitHub Bot (Jira)
2026/10/25 Re: [PR] [FLINK-41154] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
2026/10/25 [jira] [Created] (FLINK-41157) Stateless jobs with HA enabled cannot be recovered or restarted when HA metadata is missing Dennis-Mircea Ciupitu (Jira)
2026/10/25 [jira] [Created] (FLINK-41147) Release Testing Instructions: FLIP-583: Expose JobInfo on Source contexts Yuepeng Pan (Jira)
2026/10/25 [jira] [Created] (FLINK-41158) Upgrade Testcontainers to 2.0.5 in flink-connector-kafka Purushottam Sinha (Jira)
2026/10/25 [PR] [integration][java] Send user images, audio, video and documents to Gemini [flink-agents] via GitHub
2026/10/25 Re: [PR] [integration][observability] Add OpenTelemetry GenAI exporter for Agent Traces (Phase 1) [flink-agents] via GitHub
2026/10/25 [PR] [FLINK-41101][jdbc] Roll back the prepared transactions that earlier jobs left behind [flink-connector-jdbc] via GitHub
2026/10/25 [jira] [Updated] (FLINK-41157) Stateless jobs with HA enabled cannot be recovered or restarted when HA metadata is missing Dennis-Mircea Ciupitu (Jira)
2026/10/25 [jira] [Created] (FLINK-41142) Release Testing Instructions: FLIP-578: In-place Table to Materialized Table conversion Yuepeng Pan (Jira)
2026/10/25 [jira] [Updated] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver Martijn Visser (Jira)
2026/10/25 Re: [D] Human-in-the-loop approval: pluggable approver (decision model first, human fallback) - design discussion for #1067 [flink-agents] via GitHub
2026/10/25 Re: [PR] [FLINK-41048][container] Fix MiniClusterJobEntryPointITCase race condition [flink] via GitHub
2026/10/25 [PR] [BP-3.4][FLINK-41156][build] Bump Testcontainers to 1.21.4 [flink-connector-jdbc] via GitHub
2026/10/25 [PR] [BP-4.1][FLINK-41156][build] Bump Testcontainers to 1.21.4 [flink-connector-jdbc] via GitHub
2026/10/25 [jira] [Created] (FLINK-41150) Release Testing Instructions: FLIP-599: State Catalog Yuepeng Pan (Jira)
2026/10/25 [jira] [Created] (FLINK-41156) Upgrade Testcontainers to 1.21.4 on the JDBC connector v4.1 and v3.4 branches to support Docker 29 Martijn Visser (Jira)
2026/10/25 [jira] [Created] (FLINK-41154) Make the connector release scripts work reliably on macOS and Linux Martijn Visser (Jira)
2026/10/25 [jira] [Created] (FLINK-41155) Add stage_source_release_atr.sh for Apache Trusted Releases Martijn Visser (Jira)
2026/10/25 [jira] [Closed] (FLINK-41030) Close operator-owned executors and metric reporters on operator shutdown Dennis-Mircea Ciupitu (Jira)
2026/10/25 [jira] [Closed] (FLINK-41031) Close operator-owned resources on shutdown and exit on startup failure Dennis-Mircea Ciupitu (Jira)
2026/10/25 Re: [PR] [FLINK-33186][tests][BP-2.3] Addressing CheckpointAfterAllTasksFinishedITCase CI flakiness [flink] via GitHub
2026/10/25 [PR] [FLINK-33186][BP 2.3 [flink] via GitHub
2026/10/25 [jira] [Created] (FLINK-41146) Release Testing Instructions: FLIP-547 V2: Filtering record before processing with spilling strategy Yuepeng Pan (Jira)
2026/10/25 [jira] [Created] (FLINK-41145) Release Testing Instructions: FLIP-591: Introducing Python DataFrame API in PyFlink Yuepeng Pan (Jira)
2026/10/25 [jira] [Created] (FLINK-41141) Release Testing Instructions: FLIP-574 Metadata Filter Push-Down for Table Sources Yuepeng Pan (Jira)
2026/10/25 Re: [PR] [FLINK-40638][historyserver] Add optional custom URL handlers for JobManager and TaskManager logs in the history server [flink] via GitHub
2026/10/25 [jira] [Created] (FLINK-41151) Release Testing Instructions: FLINK-39268: Support Common Subexpression Elimination (CSE) in Calc Code Generation Yuepeng Pan (Jira)
2026/10/25 Re: [PR] [FLINK-36902][core] Keep process exit working on JDK 24+ where the Security Manager is disabled [flink] via GitHub
2026/10/25 [jira] [Updated] (FLINK-41151) Release Testing Instructions: FLINK-39268：Support Common Subexpression Elimination (CSE) in Calc Code Generation Yuepeng Pan (Jira)
2026/10/25 [jira] [Created] (FLINK-41153) Release Testing Instructions: FLIP-527: State Schema Evolution for RowData Yuepeng Pan (Jira)
2026/10/25 [jira] [Created] (FLINK-41152) Release Testing Instructions: Upgrade Calcite to 1.41.0 Yuepeng Pan (Jira)
2026/10/25 [jira] [Created] (FLINK-41149) Release Testing Instructions: FLIP-585: Introduce Lazy Loading for HistoryServer Yuepeng Pan (Jira)
2026/10/25 [jira] [Created] (FLINK-41148) Release Testing Instructions: FLIP-584: Support Pluggable Storage Backend for HistoryServer Yuepeng Pan (Jira)
2026/10/25 [jira] [Created] (FLINK-41144) Release Testing Instructions: FLIP-604: Complete VARIANT Primitive Coverage with UUID and Timestamps Yuepeng Pan (Jira)
2026/10/25 [jira] [Created] (FLINK-41143) Release Testing Instructions: FLIP-579: LATERAL SNAPSHOT Join Yuepeng Pan (Jira)
2026/10/24 Re: [PR] Upgrade Avro Dependency to 1.12.1 [flink] via GitHub
2026/10/24 Re: [PR] Upgrade Avro Dependency to 1.12.1 [flink] via GitHub
2026/10/24 Re: [PR] [FLINK-40237][cep] Clean up expired NFA state in processing-time timers [flink] via GitHub
2026/10/24 [jira] [Closed] (FLINK-41009) Use a single Pulsar transaction per checkpoint in the Pulsar sink Ferenc Csaky (Jira)
2026/10/24 Re: [PR] [FLINK-41009][connector/pulsar] Use a single transaction per checkpoint [flink-connector-pulsar] via GitHub
2026/10/24 [jira] [Created] (FLINK-41140) Release Testing Instructions: FLIP-568: Strict BYTES-to-STRING CAST with UTF-8 Validation Utilities Yuepeng Pan (Jira)
2026/10/24 [jira] [Created] (FLINK-41139) Release Testing Instructions: FLIP-567: Introduce a ProcessTableFunction Test Harness Yuepeng Pan (Jira)
2026/10/24 [jira] [Created] (FLINK-41138) Release Testing Instructions: FLIP-566: Introduce a new IMMUTABLE columns constraint Yuepeng Pan (Jira)
2026/10/24 [jira] [Created] (FLINK-41137) Release Testing Instructions: FLIP-565: Improve ProcessTableFunctions for late data handling and state access Yuepeng Pan (Jira)
2026/10/24 [I] [Feature] Decision-model routing strategy for MODEL_ROUTER [flink-agents] via GitHub
2026/10/24 [jira] [Commented] (FLINK-39889) Convert table sqlnode to operation Yuepeng Pan (Jira)
2026/10/24 [jira] [Resolved] (FLINK-41056) Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize Sergey Nuyanzin (Jira)
2026/10/24 [PR] [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] via GitHub
2026/10/24 [PR] [hotfix][build] Bump Testcontainers to 2.0.5 [flink-connector-kafka] via GitHub
2026/10/24 [PR] [FLINK-40846][tests] Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase [flink] via GitHub
2026/10/24 [jira] [Updated] (FLINK-41133) Release Testing Instructions: FLIP-529: Connections in Flink SQL and TableAPI Yuepeng Pan (Jira)
2026/10/24 [jira] [Created] (FLINK-41121) [release-2.4] Select executing release manager Yuepeng Pan (Jira)
2026/10/24 [jira] [Created] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
2026/10/24 Re: [PR] [FLINK-38727][tests] Remove checkpointing test startup delay [flink] via GitHub
2026/10/24 Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc] via GitHub
2026/10/24 [jira] [Created] (FLINK-41134) Release Testing Instructions: FLIP-564: Support FROM_CHANGELOG and TO_CHANGELOG built-in PTFs Yuepeng Pan (Jira)
2026/10/24 Re: [PR] Bump undici and @angular/build in /flink-runtime-web/web-dashboard [flink] via GitHub
2026/10/24 Re: [PR] Bump fast-uri from 3.1.8 to 3.1.9 in /flink-runtime-web/web-dashboard [flink] via GitHub
2026/10/24 Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc] via GitHub
2026/10/24 Re: [PR] [FLINK-40129][Connectors/Kafka] Topic integrity check in table API [flink-connector-kafka] via GitHub
2026/10/24 [PR] Bump undici and @angular/build in /flink-runtime-web/web-dashboard [flink] via GitHub
2026/10/24 [PR] Bump fast-uri from 3.1.8 to 3.1.9 in /flink-runtime-web/web-dashboard [flink] via GitHub
2026/10/24 Re: [PR] [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper [flink] via GitHub
2026/10/24 Re: [PR] [FLINK-41060][jdbc] Commit XA transactions in the JdbcSink committer [flink-connector-jdbc] via GitHub
2026/10/24 Re: [PR] [FLINK-41056][table] Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize [flink] via GitHub
2026/10/24 [PR] [hotfix] Make release_utils work on macOS and Linux [flink-connector-shared-utils] via GitHub
2026/10/24 [jira] [Updated] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
2026/10/24 Re: [PR] [FLINK-36902][core] Keep process exit working on JDK 24+ where the Security Manager is disabled [flink] via GitHub
2026/10/24 [jira] [Assigned] (FLINK-41133) Release Testing Instructions: FLIP-529: Connections in Flink SQL and TableAPI Yuepeng Pan (Jira)
2026/10/24 [jira] [Updated] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier ASF GitHub Bot (Jira)
2026/10/24 Re: [PR] [FLINK-41135][jdbc] Don't start a transaction after the end of input [flink-connector-jdbc] via GitHub
2026/10/24 [PR] [FLINK-41060][jdbc] Commit XA transactions in the JdbcSink committer [flink-connector-jdbc] via GitHub
2026/10/24 [jira] [Updated] (FLINK-41135) Exactly-once JdbcSink fails with "currentXid not null" after the end of input ASF GitHub Bot (Jira)
2026/10/24 [jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
2026/10/24 [PR] [FLINK-41135][jdbc] Don't start a transaction after the end of input [flink-connector-jdbc] via GitHub
2026/10/24 [jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
2026/10/24 Re: [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
2026/10/24 [jira] [Updated] (FLINK-40729) Refresh the JDBC driver and test dependency versions raised by Dependabot Martijn Visser (Jira)
2026/10/24 [jira] [Assigned] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
2026/10/24 [jira] [Comment Edited] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver Martijn Visser (Jira)
2026/10/24 [jira] [Assigned] (FLINK-41135) Exactly-once JdbcSink fails with "currentXid not null" after the end of input Martijn Visser (Jira)
2026/10/24 [jira] [Resolved] (FLINK-40574) Update SLF4J from 1.7.36 to 2.x Martijn Visser (Jira)
2026/10/24 Re: [PR] Bump org.assertj:assertj-core from 3.23.1 to 3.27.7 in /flink-connector-cassandra [flink-connector-cassandra] via GitHub
2026/10/24 [jira] [Created] (FLINK-41136) Exactly-once JdbcSink in BATCH mode fails for good after its committer restarts mid-commit Martijn Visser (Jira)
2026/10/24 [jira] [Created] (FLINK-41135) Exactly-once JdbcSink fails with "currentXid not null" after the end of input Martijn Visser (Jira)
2026/10/24 [jira] [Created] (FLINK-41133) Release Testing Instructions: FLIP-527: State Schema Evolution for RowData Yuepeng Pan (Jira)
2026/10/24 [jira] [Commented] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver Martijn Visser (Jira)
2026/10/24 [jira] [Created] (FLINK-41132) Release Testing Instructions: FLIP-497: Early Fire Support for Flink SQL Interval Join Yuepeng Pan (Jira)
2026/10/24 Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc] via GitHub
2026/10/24 [jira] [Created] (FLINK-41129) [release-2.4] Add release notes Yuepeng Pan (Jira)
2026/10/24 [PR] [hotfix][build] Update version to 5.0-SNAPSHOT [flink-connector-jdbc] via GitHub
2026/10/24 Re: [PR] [hotfix][build] Update version to 5.0-SNAPSHOT [flink-connector-jdbc] via GitHub
2026/10/24 Re: [PR] [FLINK-36902][core] Keep process exit working on JDK 24+ where the Security Manager is disabled [flink] via GitHub
2026/10/24 [jira] [Commented] (FLINK-41056) Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize Sergey Nuyanzin (Jira)
2026/10/24 Re: [PR] [FLINK-40586][Connectors/Kafka] Clear the no-more-splits dedup set on a metadata change [flink-connector-kafka] via GitHub
2026/10/24 Re: [PR] [FLINK-41056][table] Keep non-compact decimals with unscaled value fitting in a long as long to avoid BigDecimal on read, add, subtract, cast and deserialize [flink] via GitHub
2026/10/24 [jira] [Updated] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
2026/10/24 [jira] [Updated] (FLINK-41101) discoverAndRollbackOnRecovery never rolls back a transaction against a real driver Martijn Visser (Jira)
2026/10/24 [jira] [Updated] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
2026/10/24 [jira] [Updated] (FLINK-41060) Exactly-once JdbcSink commits its XA branch at the checkpoint barrier Martijn Visser (Jira)
2026/10/24 Re: [PR] [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA [flink] via GitHub
2026/10/24 Re: [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
2026/10/24 Re: [PR] [FLINK-40846][tests] Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase [flink] via GitHub
2026/10/24 [jira] [Updated] (FLINK-40846) Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase ASF GitHub Bot (Jira)
2026/10/24 [jira] [Created] (FLINK-41123) [release-2.4] Prepare RC0 release Yuepeng Pan (Jira)
2026/10/24 Re: [PR] [FLINK-40586][Connectors/Kafka] Clear the no-more-splits dedup set on a metadata change [flink-connector-kafka] via GitHub
2026/10/24 [jira] [Resolved] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
2026/10/24 [jira] [Updated] (FLINK-40574) Update SLF4J from 1.7.36 to 2.x Martijn Visser (Jira)
2026/10/24 Re: [PR] [FLINK-40574][build] Update SLF4J from 1.7.36 to 2.0.20 [flink] via GitHub
2026/10/24 [jira] [Resolved] (FLINK-40621) FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed fails with InvalidProducerEpochException instead of ProducerFencedException Martijn Visser (Jira)
2026/10/24 [jira] [Assigned] (FLINK-40621) FlinkKafkaInternalProducerITCase.testResetInnerTransactionIfFinalizingTransactionFailed fails with InvalidProducerEpochException instead of ProducerFencedException Martijn Visser (Jira)
2026/10/24 Re: [PR] [FLINK-40621][Connectors/Kafka] test: Flush before fencing in producer reset test [flink-connector-kafka] via GitHub
2026/10/24 [jira] [Assigned] (FLINK-41131) Release Testing Instructions: FLIP-485: Add UDF Metrics Yuepeng Pan (Jira)
2026/10/24 [jira] [Assigned] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
2026/10/24 Re: [PR] [FLINK-40621][Connectors/Kafka] test: Flush before fencing in producer reset test [flink-connector-kafka] via GitHub
2026/10/24 [jira] [Created] (FLINK-41131) Release Testing Instructions: FLIP-485: Add UDF Metrics Yuepeng Pan (Jira)
2026/10/24 [jira] [Updated] (FLINK-40838) Add a DataStream end-to-end test for the Confluent Schema Registry format Martijn Visser (Jira)
2026/10/24 Re: [PR] Bump org.apache.logging.log4j:log4j-core from 2.17.1 to 2.25.3 in /flink-connector-cassandra [flink-connector-cassandra] via GitHub
2026/10/24 [jira] [Resolved] (FLINK-40817) Remove the deprecated configuration keys from the flink-yarn module. Yuepeng Pan (Jira)
2026/10/24 Re: [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
2026/10/24 Re: [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
2026/10/24 [jira] [Created] (FLINK-41128) [release-2.4] Verify that no exclusions were erroneously added to the japicmp plugin Yuepeng Pan (Jira)
2026/10/24 [jira] [Assigned] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
2026/10/24 [jira] [Updated] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
2026/10/24 [jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
2026/10/24 [jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
2026/10/24 [jira] [Created] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
2026/10/24 [jira] [Updated] (FLINK-41130) [Umbrella] Test Flink Release 2.4 Yuepeng Pan (Jira)
2026/10/24 [jira] [Commented] (FLINK-41119) Prepare Flink 2.4 release Yuepeng Pan (Jira)
2026/10/24 Re: [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
2026/10/24 [jira] [Created] (FLINK-41127) [release-2.4] Review and update documentation Yuepeng Pan (Jira)
2026/10/24 [jira] [Created] (FLINK-41126) [release-2.4] Triage release blockers in JIRA Yuepeng Pan (Jira)
2026/10/24 [jira] [Created] (FLINK-41124) [release-2.4] Review release notes in JIRA Yuepeng Pan (Jira)
2026/10/24 [jira] [Created] (FLINK-41125) [release-2.4] Cross-team testing Yuepeng Pan (Jira)
2026/10/24 [PR] [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` [flink] via GitHub
2026/10/24 [jira] [Updated] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
2026/10/24 [jira] [Updated] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
2026/10/24 [jira] [Assigned] (FLINK-41122) [release-2.4] Create release branch Yuepeng Pan (Jira)
2026/10/24 [jira] [Updated] (FLINK-41121) [release-2.4] Select executing release manager Yuepeng Pan (Jira)
2026/10/24 [jira] [Created] (FLINK-41120) [release-2.4] Create new version in Jira Yuepeng Pan (Jira)
2026/10/24 [jira] [Created] (FLINK-41119) Prepare Flink 2.4 release Yuepeng Pan (Jira)
2026/10/24 Re: [PR] [FLINK-40586][Connectors/Kafka] Clear the no-more-splits dedup set on a metadata change [flink-connector-kafka] via GitHub
2026/10/24 [jira] [Updated] (FLINK-40710) Dynamic Kafka Source assigns duplicate partition owners after local failover Martijn Visser (Jira)
2026/10/24 Re: [PR] [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module. [flink] via GitHub
2026/10/24 [jira] [Commented] (FLINK-41117) Move CI to ubuntu 26 Sergey Nuyanzin (Jira)
2026/10/24 [jira] [Resolved] (FLINK-31006) job is not finished when using pipeline mode to run bounded source like kafka Martijn Visser (Jira)
2026/10/24 Re: [PR] [FLINK-31006][Connectors/Kafka] Signal no more splits after a restored bounded enumerator finds no partition changes [flink-connector-kafka] via GitHub
2026/10/24 [jira] [Commented] (FLINK-41049) CI jobs fail when the downloaded Maven wrapper jar does not pass its SHA-256 check Sergey Nuyanzin (Jira)
2026/10/24 [jira] [Commented] (FLINK-41075) Kill each e2e timeout watchdog when its command ends Sergey Nuyanzin (Jira)
2026/10/24 [jira] [Resolved] (FLINK-41075) Kill each e2e timeout watchdog when its command ends Sergey Nuyanzin (Jira)
2026/10/24 Re: [PR] [FLINK-41075][ci] Kill each e2e timeout watchdog when its command ends [flink] via GitHub
2026/10/24 Re: [PR] [FLINK-41118][tests] Migrate EventTimeWindowCheckpointingITCase to Source V2 and remove FailingSource [flink] via GitHub
2026/10/24 Re: [PR] [docs] Migrate documentation from Hugo to Docusaurus [flink-cdc] via GitHub
2026/10/24 [jira] [Updated] (FLINK-41118) Migrate EventTimeWindowCheckpointingITCase to FailingCheckpointedSource and remove FailingSource ASF GitHub Bot (Jira)
2026/10/24 [PR] [FLINK-41118][tests] Migrate EventTimeWindowCheckpointingITCase to Source V2 and remove FailingSource [flink] via GitHub
2026/10/24 [jira] [Created] (FLINK-41118) Migrate EventTimeWindowCheckpointingITCase to FailingCheckpointedSource and remove FailingSource Martijn Visser (Jira)