issues  

Messages by Date

• 2026/09/24 [jira] [Updated] (FLINK-40793) DefaultSchedulerTest is unstable across many test methods ASF GitHub Bot (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40794) CAST in Table API ignores input nullability when the target type is NOT NULL Ramin Gharib (Jira)
• 2026/09/24 [jira] [Updated] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Martijn Visser (Jira)
• 2026/09/24 Re: [PR] [FLINK-40727][security] Support comma-separated security.ssl.protocol and fix internal SSL hostname verification regression [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-34673][test] Fix SessionRelatedITCase#testTouchSession failure on GitHub Actions [flink] via GitHub
• 2026/09/24 [jira] [Updated] (FLINK-40785) Nightly snapshot deployment fails in spotless because google-java-format 1.28.0 does not run on JDK 11 Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-34673) SessionRelatedITCase#testTouchSession failure on GitHub Actions Martijn Visser (Jira)
• 2026/09/24 Re: [PR] [FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest [flink] via GitHub
• 2026/09/24 [jira] [Reopened] (FLINK-39998) RocksDBStateDownloader loses parallel download failures, surfacing a misleading ClosedChannelException instead of the real root cause Martijn Visser (Jira)
• 2026/09/24 [jira] [Reopened] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP Martijn Visser (Jira)
• 2026/09/24 Re: [PR] [FLINK-40263][format/avro] Validate enum symbols when serializing CHAR/VARCHAR [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40693][table] Align floating-point IN predicates with equality for signed zero [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40445] Autoscaler: integration test for Kafka/Pulsar source partition-metric detection [flink-kubernetes-operator] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40584][state/rocksdb] Bound MapState and timer prefix iterators [flink] via GitHub
• 2026/09/24 [PR] [FLINK-40785][build] Pick google-java-format by the JDK that runs Maven [flink] via GitHub
• 2026/09/24 [jira] [Created] (FLINK-40789) RescaleTimelineITCase.testRecordRescaleForNewAvailableResource records three rescales instead of two Martijn Visser (Jira)
• 2026/09/24 Re: [PR] [FLINK-40445] Autoscaler: integration test for Kafka/Pulsar source partition-metric detection [flink-kubernetes-operator] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40445] Autoscaler: integration test for Kafka/Pulsar source partition-metric detection [flink-kubernetes-operator] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40445] Autoscaler: integration test for Kafka/Pulsar source partition-metric detection [flink-kubernetes-operator] via GitHub
• 2026/09/24 [jira] [Commented] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Martijn Visser (Jira)
• 2026/09/24 Re: [PR] [FLINK-40792][core] Render UTC offset as `Z` in `Variant.toJson()` for `TIMESTAMP_LTZ` [flink] via GitHub
• 2026/09/24 [jira] [Commented] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-35012) ChangelogNormalizeRestoreTest.testRestore failure Martijn Visser (Jira)
• 2026/09/24 Re: [PR] [FLINK-40785][build] Pick google-java-format by the JDK that runs Maven [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40785][build] Pick google-java-format by the JDK that runs Maven [flink] via GitHub
• 2026/09/24 [PR] align action recovery model [flink-agents] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40792][core] Render UTC offset as `Z` in `Variant.toJson()` for `TIMESTAMP_LTZ` [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40785][build] Pick google-java-format by the JDK that runs Maven [flink] via GitHub
• 2026/09/24 [PR] [FLINK-40792][core] Render UTC offset as `Z` in `Variant.toJson()` for `TIMESTAMP_LTZ` [flink] via GitHub
• 2026/09/24 [jira] [Updated] (FLINK-40792) Emit "Z" instead of "+00:00" for UTC in Variant.toJson() ASF GitHub Bot (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40792) Emit "Z" instead of "+00:00" for UTC in Variant.toJson() Ramin Gharib (Jira)
• 2026/09/24 Re: [PR] [FLINK-40785][build] Pick google-java-format by the JDK that runs Maven [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40785][build] Pick google-java-format by the JDK that runs Maven [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40785][build] Pick google-java-format by the JDK that runs Maven [flink] via GitHub
• 2026/09/24 [jira] [Updated] (FLINK-40785) Nightly snapshot deployment fails in spotless because google-java-format 1.28.0 does not run on JDK 11 ASF GitHub Bot (Jira)
• 2026/09/24 [jira] [Updated] (FLINK-40727) Support comma-separated security.ssl.protocol and fix internal SSL hostname verification regression Gabor Somogyi (Jira)
• 2026/09/24 [jira] [Resolved] (FLINK-40727) Support comma-separated security.ssl.protocol and fix internal SSL hostname verification regression Gabor Somogyi (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-40727) Support comma-separated security.ssl.protocol and fix internal SSL hostname verification regression Gabor Somogyi (Jira)
• 2026/09/24 [jira] [Closed] (FLINK-40263) Enum symbol validation Gyula Fora (Jira)
• 2026/09/24 [jira] [Updated] (FLINK-21834) org.apache.flink.core.fs.AbstractRecoverableWriterTest.testResumeWithWrongOffset fail Martijn Visser (Jira)
• 2026/09/24 [jira] [Updated] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-21834) org.apache.flink.core.fs.AbstractRecoverableWriterTest.testResumeWithWrongOffset fail Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Purushottam Sinha (Jira)
• 2026/09/24 [jira] [Reopened] (FLINK-39107) OpenTelemetryEventReporterITCase fails with ContainerLaunch Container startup failed for image Martijn Visser (Jira)
• 2026/09/24 [jira] [Reopened] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-38643) UnalignedCheckpointRescaleITCase stuck in test_ci tests Martijn Visser (Jira)
• 2026/09/24 [jira] [Updated] (FLINK-38727) Unstable test cases EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow Martijn Visser (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40791) OpenTelemetryMetricReporterITCase.testCounterDelta fails with expected 1234 but was 25 Martijn Visser (Jira)
• 2026/09/24 [jira] [Reopened] (FLINK-40068) KeyedComplexChainTest.testMigrationAndRestore fails with NoResourceAvailableException when the window apply-assertion crashes the MiniCluster TaskManager Martijn Visser (Jira)
• 2026/09/24 [jira] [Reopened] (FLINK-38534) Fix flaky LocalRecoveryTest by waiting for tasks to reach RUNNING state Martijn Visser (Jira)
• 2026/09/24 Re: [PR] [FLINK-40116][state] Support more predicates for filter pushdown during savepoint scan [flink] via GitHub
• 2026/09/24 [jira] [Commented] (FLINK-40663) WindowDistinctAggregateStressITCase.testCumulateWindowRollupUnderBackpressure times out after 600s Martijn Visser (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40785) Nightly snapshot deployment fails in spotless because google-java-format 1.28.0 does not run on JDK 11 Martijn Visser (Jira)
• 2026/09/24 [jira] [Reopened] (FLINK-40568) ProcessTableFunctionSemanticTests[process-updating-multi-input] is flaky on master Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-40655) ExecutionVertexTest.testResetForNewExecutionReleasesPartitions is unstable Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Martijn Visser (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40790) DefaultDeclarativeSlotPoolTest.testIncreasingResourceRequirementsWillSendResourceRequirementNotification receives the first increment alone Martijn Visser (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40788) 'Heavy deployment end-to-end test' fails because all TaskManagers run out of memory on Java 11 Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-35315) MemoryManagerConcurrentModReleaseTest executes more than 15 minutes Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-40109) YARNSessionFIFOSecuredITCase.testDetachedMode is flaky: Kerberos keytab check runs before the YARN application is killed Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-40664) JobIDLoggingITCase.testJobIDLogging fails on a "Freeing inactive slots" log line without the job id Martijn Visser (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40787) 'Flink CLI end-to-end test' fails with "Unexpected task manager slot count" Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239) Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• 2026/09/24 [jira] [Commented] (FLINK-40673) INTERSECT ALL and EXCEPT ALL fail with mixed INT/BIGINT inputs Dian Fu (Jira)
• 2026/09/24 [jira] [Created] (FLINK-40786) compile_cron_azure fails with OutOfMemoryError in japicmp on flink-s3-fs-presto Martijn Visser (Jira)
• 2026/09/24 [jira] [Assigned] (FLINK-40673) INTERSECT ALL and EXCEPT ALL fail with mixed INT/BIGINT inputs Dian Fu (Jira)
• 2026/09/24 [jira] [Assigned] (FLINK-40439) Add model provider management to DataFrame API Dian Fu (Jira)
• 2026/09/24 Re: [PR] [FLINK-40427][python] Add catalog management and catalog table I/O to DataFrame API [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40427][python] Add catalog management and catalog table I/O to DataFrame API [flink] via GitHub
• 2026/09/24 [jira] [Commented] (FLINK-40198) Add Kafka source and sink APIs to DataFrame API Dian Fu (Jira)
• 2026/09/24 [jira] [Assigned] (FLINK-40198) Add Kafka source and sink APIs to DataFrame API Dian Fu (Jira)
• 2026/09/24 Re: [PR] [FLINK-39200][mysql] Skip insert/update/delete binlog deserialization of unsubscribed tables in MySql CDC binary log client. [flink-cdc] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40574][build] Update SLF4J from 1.7.36 to 2.0.20 [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40427][python] Add catalog management and catalog table I/O to DataFrame API [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40681][table] Reproducer: streaming outer join drops the null-padded row after an inner-side update followed by delete [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-39721] Support flink 1.18 compatibility for cdc runtime. [flink-cdc] via GitHub
• 2026/09/24 Re: [I] [Feature] Expose sub-agents to chat models as callable tools [flink-agents] via GitHub
• 2026/09/24 Re: [I] [Feature] Expose sub-agents to chat models as callable tools [flink-agents] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40647][runtime] Support best-effort schema expansion for existing sink tables during table creation [flink-cdc] via GitHub
• 2026/09/24 Re: [PR] [api][plan][python] Expose sub-agents to chat models as callable tools [flink-agents] via GitHub
• 2026/09/24 Re: [PR] [FLINK-38835][postgres] Fix timestamp conversion to LocalDateTime for dates before 1970-01-01. [flink-cdc] via GitHub
• 2026/09/24 Re: [PR] [FLINK-38835][postgres] Fix timestamp conversion to LocalDateTime for dates before 1970-01-01. [flink-cdc] via GitHub
• 2026/09/24 [jira] [Commented] (FLINK-40198) Add Kafka source and sink APIs to DataFrame API niliushall (Jira)
• 2026/09/24 Re: [PR] [BP-2.3][FLINK-40683][table] Assert materialized data in the anti-join-on-nested semantic test [flink] via GitHub
• 2026/09/24 [jira] [Resolved] (FLINK-40683) JoinSemanticTests[anti-join-on-nested] asserts the raw changelog on release-2.3 and release-2.2 Martijn Visser (Jira)
• 2026/09/24 Re: [PR] [BP-2.2][FLINK-40683][table] Assert materialized data in the anti-join-on-nested semantic test [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-36581][cli] Allow passing Flink configuration by yaml job file [flink-cdc] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40426][python] Add Parquet and JSON filesystem I/O to DataFrame API [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40647][runtime] Support best-effort schema expansion for existing sink tables during table creation [flink-cdc] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40647][runtime] Support best-effort schema expansion for existing sink tables during table creation [flink-cdc] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40005][cdc-cli] CliExecutor application mode resolves pipeline definition from local path (k8s), remote path or inline content [flink-cdc] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40647][runtime] Support best-effort schema expansion for existing sink tables during table creation [flink-cdc] via GitHub
• 2026/09/24 [jira] [Closed] (FLINK-40426) Add Parquet and JSON filesystem I/O APIs to DataFrame API Dian Fu (Jira)
• 2026/09/24 [jira] [Closed] (FLINK-38253) Allow usage of vertx/jdk/jetty/okhttp clients in fabric8 in flink-kubernetes Martijn Visser (Jira)
• 2026/09/24 [jira] [Closed] (FLINK-23989) Flink SQL visibility Martijn Visser (Jira)
• 2026/09/24 [jira] [Comment Edited] (FLINK-38253) Allow usage of vertx/jdk/jetty/okhttp clients in fabric8 in flink-kubernetes Martijn Visser (Jira)
• 2026/09/24 Re: [PR] [FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion [flink] via GitHub
• 2026/09/24 Re: [PR] [FLINK-40427][python] Add catalog management and catalog table I/O to DataFrame API [flink] via GitHub
• 2026/09/24 [jira] [Assigned] (FLINK-30975) Enable AWS SDK V2 Support for Flink's S3 FileSystem Modules Martijn Visser (Jira)
• 2026/09/23 [jira] [Updated] (FLINK-40538) [Postgres] Connector never starts streaming on a database with no publication traffic Leonard Xu (Jira)
• 2026/09/23 [jira] [Updated] (FLINK-39721) Flink CDC YAML framework should be compatibility with Flink 1.18. Leonard Xu (Jira)
• 2026/09/23 [jira] [Resolved] (FLINK-40331) [FLINK CDC][fluss] Add an opt-in forward routing mode for fluss sink Leonard Xu (Jira)
• 2026/09/23 [jira] [Updated] (FLINK-40349) Add Fluss sink schema compatibility option to avoid silent data loss Leonard Xu (Jira)
• 2026/09/23 [jira] [Assigned] (FLINK-40331) [FLINK CDC][fluss] Add an opt-in forward routing mode for fluss sink Leonard Xu (Jira)
• 2026/09/23 [jira] [Updated] (FLINK-39833) Special characters in column comment and default value are not escaped when building DDL Leonard Xu (Jira)
• 2026/09/23 [jira] [Updated] (FLINK-40331) [FLINK CDC][fluss] Add an opt-in forward routing mode for fluss sink Leonard Xu (Jira)
• 2026/09/23 [jira] [Updated] (FLINK-39391) scan.snapshot.fetch.size is not propagated to Debezium properties in Oracle/SqlServer/DB2/Postgres connectors, causing severe snapshot performance degradation Leonard Xu (Jira)
• 2026/09/23 Re: [PR] [FLINK-40647][runtime] Support best-effort schema expansion for existing sink tables during table creation [flink-cdc] via GitHub
• 2026/09/23 Re: [PR] Upgrade Avro Dependency to 1.12.1 [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40575][pipeline-connector/fluss] Support dynamic table unsubscription and re-subscription [flink-cdc] via GitHub
• 2026/09/23 [jira] [Resolved] (FLINK-40575) Support dynamic table unsubscription and re-subscription in Fluss pipeline source Leonard Xu (Jira)
• 2026/09/23 [jira] [Assigned] (FLINK-40575) Support dynamic table unsubscription and re-subscription in Fluss pipeline source Leonard Xu (Jira)
• 2026/09/23 [jira] [Updated] (FLINK-40575) Support dynamic table unsubscription and re-subscription in Fluss pipeline source Leonard Xu (Jira)
• 2026/09/23 [jira] [Updated] (FLINK-40575) Support dynamic table unsubscription and re-subscription in Fluss pipeline source Leonard Xu (Jira)
• 2026/09/23 [jira] [Updated] (FLINK-40575) Support dynamic table unsubscription and re-subscription in Fluss pipeline source Leonard Xu (Jira)
• 2026/09/23 Re: [PR] [FLINK-40575][pipeline-connector/fluss] Support dynamic table unsubscription and re-subscription [flink-cdc] via GitHub
• 2026/09/23 Re: [PR] [FLINK-38835][postgres] Fix timestamp conversion to LocalDateTime for dates before 1970-01-01. [flink-cdc] via GitHub
• 2026/09/23 [jira] [Commented] (FLINK-39610) Mongo CDC connector supports specifying SSL context Ruan Hang (Jira)
• 2026/09/23 [jira] [Updated] (FLINK-40646) [Postgres CDC] Pooled JDBC connections use the default application name Ruan Hang (Jira)
• 2026/09/23 [jira] [Resolved] (FLINK-39410) The `flink-cdc-pipeline-connector-elasticsearch` module offers better compatibility with Flink 1.20 and Flink 2.x. Ruan Hang (Jira)
• 2026/09/23 [jira] [Resolved] (FLINK-40741) [Flink cdc]After the full snapshot read of the newly added table completes, the newly added table is no longer synchronized, while the existing (old) tables continue reading Ruan Hang (Jira)
• 2026/09/23 Re: [PR] [FLINK-40727][security] Support comma-separated security.ssl.protocol and fix internal SSL hostname verification regression [flink] via GitHub
• 2026/09/23 [jira] [Resolved] (FLINK-39315) MySql cdc connector could get stuck in backfill binlog reading after a failover within snapshot phase when the MySql table is being continuously written Ruan Hang (Jira)
• 2026/09/23 Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc] via GitHub
• 2026/09/23 Re: [PR] [FLINK-35756][tests] Make file writing atomically in tests [flink] via GitHub
• 2026/09/23 [jira] [Commented] (FLINK-35756) FileSystemTableSourceStreamingITCase.testSourceWithRegexPattern produced no output for 900 seconds Sergey Nuyanzin (Jira)
• 2026/09/23 [jira] [Resolved] (FLINK-35756) FileSystemTableSourceStreamingITCase.testSourceWithRegexPattern produced no output for 900 seconds Sergey Nuyanzin (Jira)
• 2026/09/23 Re: [PR] [FLINK-40751][state-processor-api] Use task io/memory manager in SavepointEnvironment [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40426][python] Add Parquet and JSON filesystem I/O to DataFrame API [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40426][python] Add Parquet and JSON filesystem I/O to DataFrame API [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40426][python] Add Parquet and JSON filesystem I/O to DataFrame API [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40426][python] Add Parquet and JSON filesystem I/O to DataFrame API [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40426][python] Add Parquet and JSON filesystem I/O to DataFrame API [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40595][s3] Preserve multipart uploads during recoverable stream disposal [flink] via GitHub
• 2026/09/23 Re: [PR] [runtime][api][python] Add checkpoint-aligned Kafka action-state cleanup [flink-agents] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40647][runtime] Support best-effort schema expansion for existing sink tables during table creation [flink-cdc] via GitHub
• 2026/09/23 [jira] [Updated] (FLINK-40646) [Postgres CDC] Pooled JDBC connections use the default application name Leonard Xu (Jira)
• 2026/09/23 [jira] [Assigned] (FLINK-40646) [Postgres CDC] Pooled JDBC connections use the default application name Leonard Xu (Jira)
• 2026/09/23 [jira] [Resolved] (FLINK-40646) [Postgres CDC] Pooled JDBC connections use the default application name Leonard Xu (Jira)
• 2026/09/23 Re: [PR] [FLINK-40646][Postgres] Pooled JDBC connections use the default application name. [flink-cdc] via GitHub
• 2026/09/23 Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40681][table] Reproducer: streaming outer join drops the null-padded row after an inner-side update followed by delete [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc] via GitHub
• 2026/09/23 Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40594][cdc-common] Preserve TIME precision in the pipeline runtime [flink-cdc] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40594][cdc-common] Preserve TIME precision in the pipeline runtime [flink-cdc] via GitHub
• 2026/09/23 Re: [PR] [FLINK-39315][mysql] Unregister listeners of BinaryLogClient to prevent snapshot reader hang during backfill [flink-cdc] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40753][table-planner] Fix decorrelation of subqueries over VALUES [flink] via GitHub
• 2026/09/23 [jira] [Updated] (FLINK-40753) Correlated subqueries over SQL VALUES fail during decorrelation ASF GitHub Bot (Jira)
• 2026/09/23 [PR] [FLINK-40753][table-planner] Fix decorrelation of subqueries over VALUES [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40426][python] Add Parquet and JSON filesystem I/O to DataFrame API [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40419][python] Add regular join support to DataFrame API [flink] via GitHub
• 2026/09/23 [jira] [Assigned] (FLINK-40753) Correlated subqueries over SQL VALUES fail during decorrelation Dian Fu (Jira)
• 2026/09/23 [jira] [Commented] (FLINK-40425) Add OVER window aggregation support to DataFrame API Dian Fu (Jira)
• 2026/09/23 [jira] [Assigned] (FLINK-40425) Add OVER window aggregation support to DataFrame API Dian Fu (Jira)
• 2026/09/23 [jira] [Assigned] (FLINK-40437) Add iteration and bounded retrieval to DataFrame API Dian Fu (Jira)
• 2026/09/23 [jira] [Commented] (FLINK-40437) Add iteration and bounded retrieval to DataFrame API Dian Fu (Jira)
• 2026/09/23 [I] [Tech Debt][Observability] Replace Event Log with a Unified Trace Log [flink-agents] via GitHub
• 2026/09/23 Re: [PR] [FLINK-39228][starrocks] Escape quoted default/comment literals in DDL [flink-cdc] via GitHub
• 2026/09/23 Re: [I] [Feature] OpenTelemetry GenAI exporter for Agent Traces (Phase 1: Java, spans-only) [flink-agents] via GitHub
• 2026/09/23 Re: [PR] [FLINK-38413] Adding support for append only tables to MySQL Pipeline connector [flink-cdc] via GitHub
• 2026/09/23 Re: [PR] [FLINK-38413] Adding support for append only tables to MySQL Pipeline connector [flink-cdc] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40780][runtime] Make FORWARD-to-REBALANCE downgrade on parallelism mismatch configurable [flink] via GitHub
• 2026/09/23 Re: [PR] [api][plan][python] Expose sub-agents to chat models as callable tools [flink-agents] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40685][state/forst] Reclaim cached files after checkpoint ownership handoff [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-30975][filesystems] Upgrade to Hadoop to 3.4.3 and support AWS SDK v2 in flink-filesystem [flink] via GitHub
• 2026/09/23 [jira] [Resolved] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest Martijn Visser (Jira)
• 2026/09/23 [jira] [Updated] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest Martijn Visser (Jira)
• 2026/09/23 [jira] [Commented] (FLINK-39712) Fix flaky DynamicKafkaSourceITTest Martijn Visser (Jira)
• 2026/09/23 Re: [PR] [BP-4.0][FLINK-39712][Connectors/Kafka] Avoid duplicate bounded-source completion notifications [flink-connector-kafka] via GitHub
• 2026/09/23 [jira] [Commented] (FLINK-35756) FileSystemTableSourceStreamingITCase.testSourceWithRegexPattern produced no output for 900 seconds Sergey Nuyanzin (Jira)
• 2026/09/23 Re: [PR] [FLINK-40559][clients] Honor --claimMode in application mode [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] via GitHub
• 2026/09/23 Re: [PR] [FLINK-35756][tests] Make file writing atomically in tests [flink] via GitHub
• 2026/09/23 [jira] [Updated] (FLINK-35756) FileSystemTableSourceStreamingITCase.testSourceWithRegexPattern produced no output for 900 seconds ASF GitHub Bot (Jira)
• 2026/09/23 [PR] [FLINK-35756][tests] Make file writing atomically in tests [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
• 2026/09/23 [jira] [Commented] (FLINK-40701) Upgrade ArchUnit to 1.5.0 Sergey Nuyanzin (Jira)
• 2026/09/23 [jira] [Commented] (FLINK-40701) Upgrade ArchUnit to 1.5.0 Sergey Nuyanzin (Jira)
• 2026/09/23 [jira] [Comment Edited] (FLINK-40701) Upgrade ArchUnit to 1.5.0 Sergey Nuyanzin (Jira)
• 2026/09/23 [jira] [Assigned] (FLINK-35756) FileSystemTableSourceStreamingITCase.testSourceWithRegexPattern produced no output for 900 seconds Sergey Nuyanzin (Jira)
• 2026/09/23 [jira] [Commented] (FLINK-40688) flink-model-openai NOTICE lists httpcomponents artifacts it no longer bundles Purushottam Sinha (Jira)
• 2026/09/23 [jira] [Commented] (FLINK-40784) Upgrade ArchUnit to 1.5.0 in flink-connector-kafka Purushottam Sinha (Jira)
• 2026/09/23 [jira] [Commented] (FLINK-40784) Upgrade ArchUnit to 1.5.0 in flink-connector-kafka Sergey Nuyanzin (Jira)
• 2026/09/23 [jira] [Commented] (FLINK-40784) Upgrade ArchUnit to 1.5.0 in flink-connector-kafka Sergey Nuyanzin (Jira)
• 2026/09/23 Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub
• 2026/09/23 [jira] [Created] (FLINK-40784) Upgrade ArchUnit to 1.5.0 in flink-connector-kafka Purushottam Sinha (Jira)
• 2026/09/23 Re: [PR] [FLINK-40574][build] Update SLF4J from 1.7.36 to 2.0.20 [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40327][state/forst] Close ReadOptions in ForStGeneralMultiGetOperation to fix native memory leak [flink] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40714] Add MongoDB 8.0 to the multi-version integration and update test matrices [flink-connector-mongodb] via GitHub
• 2026/09/23 Re: [PR] [FLINK-37288] Add Google Cloud Spanner dialect and catalog [flink-connector-jdbc] via GitHub
• 2026/09/23 [PR] [api][java] Include the memory type in MemoryRef equality and reject null fields [flink-agents] via GitHub
• 2026/09/23 [I] [Bug][api] MemoryRef equality ignores the memory type [flink-agents] via GitHub
• 2026/09/23 Re: [PR] [FLINK-40617][build] Prune and bump dependency versions in the root pom [flink-connector-kafka] via GitHub

• Earlier messages
• Later messages