issues  

Messages by Date

• 2026/07/03 [jira] [Resolved] (FLINK-39916) Incorrect placeholder used in MySqlDataSourceFactory exception message Yanquan Lv (Jira)
• 2026/07/03 Re: [PR] [FLINK-39916][mysql] Fix MySQL batch startup option validation error [flink-cdc] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40060] Remove redundant org.postgresql dependency in flink-connector-jdbc-backward-compatibility [flink-connector-jdbc] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• 2026/07/03 [jira] [Created] (FLINK-40063) Tests: migrate JUnit 5 (Jupiter) to JUnit 6 Purushottam Sinha (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized ASF GitHub Bot (Jira)
• 2026/07/03 [PR] [FLINK-40062][table] Allow `BridgingSqlAggFunction` being instantiated from `BuiltInFunctionDefinitions`, fix `$WELFORD_M2$1` function deserialization [flink] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-40061) Update parent version and flink.version in flink-connector-jdbc pom.xml ASF GitHub Bot (Jira)
• 2026/07/03 [jira] [Commented] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• 2026/07/03 [jira] [Created] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40062) Compiled plans with WELFORD function are not able to be loaded/deserialized Sergey Nuyanzin (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40060) Remove redundant org.postgresql dependency in flink-connector-jdbc-backward-compatibility ASF GitHub Bot (Jira)
• 2026/07/03 [PR] [FLINK-40060] Remove redundant org.postgresql dependency in flink-connector-jdbc-backward-compatibility [flink-connector-jdbc] via GitHub
• 2026/07/03 [PR] [FLINK-40061] Update parent version and flink.version in flink-connector-jdbc pom.xml [flink-connector-jdbc] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/07/03 [jira] [Created] (FLINK-40061) Update parent version and flink.version in flink-connector-jdbc pom.xml ChanBin OH (Jira)
• 2026/07/03 [PR] [python] Remove PyFlink gateway fallback from AgentConfigOptions [flink-agents] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39859][table] Upgrade Calcite to 1.41.0 [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-20746][csv] Add csv.ignore-first-line for filesystem CSV connector [flink] via GitHub
• 2026/07/03 [jira] [Commented] (FLINK-39953) AbstractFlinkService.deleteBlocking() swallows KubernetesClientTimeoutException allowing cluster upgrade to proceed on top of still-running cluster Gyula Fora (Jira)
• 2026/07/03 [jira] [Commented] (FLINK-39953) AbstractFlinkService.deleteBlocking() swallows KubernetesClientTimeoutException allowing cluster upgrade to proceed on top of still-running cluster Lucas Borges (Jira)
• 2026/07/03 Re: [PR] [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api [flink] via GitHub
• 2026/07/03 Re: [PR] [hotfix] Mark Hadoop 3.4.3 runs correctly [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40039] Fix CTAS/RTAS when used with set-semantic PTFs [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-38647] Support changelog-mode=upsert + null-tolerance [flink-cdc] via GitHub
• 2026/07/03 [PR] [hotfix] Mark Hadoop 3.4.3 runs correctly [flink] via GitHub
• 2026/07/03 [jira] [Assigned] (FLINK-40060) Remove redundant org.postgresql dependency in flink-connector-jdbc-backward-compatibility Yuepeng Pan (Jira)
• 2026/07/03 [jira] [Created] (FLINK-40060) Remove redundant org.postgresql dependency in flink-connector-jdbc-backward-compatibility Sumin Joo (Jira)
• 2026/07/03 Re: [PR] [FLINK-38647] Support changelog-mode=upsert + null-tolerance [flink-cdc] via GitHub
• 2026/07/03 Re: [PR] [FLINK-38647] Support changelog-mode=upsert + null-tolerance [flink-cdc] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39481][task] Execute deferrable mails when finishing an operator [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-38647] Support changelog-mode=upsert + null-tolerance [flink-cdc] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39715][table] Sync SQL and table api behavior for queries with sort [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40057][runtime] Avoid over-picking slots in DefaultSlotAssigner [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40039] Fix CTAS/RTAS when used with set-semantic PTFs [flink] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-40057) DefaultSlotAssigner over-picks slots from the boundary TaskManager when minimal-TaskManager placement is enabled ASF GitHub Bot (Jira)
• 2026/07/03 Re: [PR] [FLINK-40057][runtime] Avoid over-picking slots in DefaultSlotAssigner [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40059][examples] Bump flink-connector-kafka to 5.0.0-2.2 [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40059][runtime] Avoid over-picking slots in DefaultSlotAssigner [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/07/03 [PR] [FLINK-40059][runtime] Avoid over-picking slots in DefaultSlotAssigner [flink] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-40059) StateMachineExample.jar bundles a Kafka connector incompatible with Flink 2.x ASF GitHub Bot (Jira)
• 2026/07/03 [PR] [FLINK-40059][examples] Bump flink-connector-kafka to 5.0.0-2.2 [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-40058][ci] Free up disk space in nightly dist deployment jobs [flink] via GitHub
• 2026/07/03 [jira] [Updated] (FLINK-40059) StateMachineExample.jar bundles a Kafka connector incompatible with Flink 2.x Purushottam Sinha (Jira)
• 2026/07/03 [jira] [Created] (FLINK-40059) StateMachineExample.jar bundles a Kafka connector incompatible with Flink 2.x Purushottam Sinha (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40058) cron_snapshot_deployment nightly jobs run out of disk space on hosted agents ASF GitHub Bot (Jira)
• 2026/07/03 Re: [PR] [FLINK-40056][docs] Support configuration anchor navigation in PyFlink [flink] via GitHub
• 2026/07/03 [PR] [FLINK-40058][ci] Free up disk space in nightly dist deployment jobs [flink] via GitHub
• 2026/07/03 [jira] [Created] (FLINK-40058) cron_snapshot_deployment nightly jobs run out of disk space on hosted agents Martijn Visser (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40058) cron_snapshot_deployment nightly jobs run out of disk space on hosted agents Martijn Visser (Jira)
• 2026/07/03 [jira] [Updated] (FLINK-40056) Support anchor navigation for pyflink configuration options ASF GitHub Bot (Jira)
• 2026/07/03 [PR] [FLINK-40056][docs] Support configuration anchor navigation in PyFlink [flink] via GitHub
• 2026/07/03 [jira] [Created] (FLINK-40057) DefaultSlotAssigner over-picks slots from the boundary TaskManager when minimal-TaskManager placement is enabled ericzeng (Jira)
• 2026/07/03 Re: [PR] [FLINK-39341][jdbc-driver] Implement DatabaseMetaData methods for DBeaver [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39176][runtime] Introduce NodeHealthManager abstraction [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink] via GitHub
• 2026/07/03 Re: [PR] [FLINK-39176][runtime] Introduce NodeHealthManager abstraction [flink] via GitHub
• 2026/07/03 [jira] [Created] (FLINK-40056) Support anchor navigation for pyflink configuration options chenzihao (Jira)
• 2026/07/03 [I] [Bug] Python AgentConfigOptions starts PyFlink gateway during Pemja worker initialization [flink-agents] via GitHub
• 2026/07/02 Re: [PR] [FLINK-39934][postgres] Fix invalid tables format error message [flink-cdc] via GitHub
• 2026/07/02 [jira] [Resolved] (FLINK-40048) Refactor and re-enable flink-sql-client-test E2E test Martijn Visser (Jira)
• 2026/07/02 [jira] [Resolved] (FLINK-40054) Update aircompressor to 2.0.3 Martijn Visser (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-39791) Helm chart silently ignores defaultConfiguration.config.yaml; always mounts flink-conf.yaml from chart defaults Gerk Elznik (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-40055) Operator serializes managed-deployment config in its own YAML dialect, breaking Flink 1.x deployments when the operator itself runs on standard config.yaml Gerk Elznik (Jira)
• 2026/07/02 [jira] [Created] (FLINK-40055) Operator serializes managed-deployment config in its own YAML dialect, breaking Flink 1.x deployments when the operator itself runs on standard config.yaml Gerk Elznik (Jira)
• 2026/07/02 [jira] [Comment Edited] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Rui Fan (Jira)
• 2026/07/02 [jira] [Resolved] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Rui Fan (Jira)
• 2026/07/02 [jira] [Created] (FLINK-40054) Update aircompressor to 2.0.3 Martijn Visser (Jira)
• 2026/07/02 [jira] [Assigned] (FLINK-40054) Update aircompressor to 2.0.3 Martijn Visser (Jira)
• 2026/07/02 [jira] [Created] (FLINK-40053) Log4j 2.26.1 bump Martijn Visser (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-28583) make flink dist log4j dependency simple and clear Martijn Visser (Jira)
• 2026/07/02 [jira] [Resolved] (FLINK-40031) Exceptions view crashes (NG04008) navigating to an unassigned TaskManager Martijn Visser (Jira)
• 2026/07/02 [jira] [Resolved] (FLINK-40044) Replace dagre with @dagrejs/dagre 3.x Martijn Visser (Jira)
• 2026/07/02 [jira] [Assigned] (FLINK-40044) Replace dagre with @dagrejs/dagre 3.x Martijn Visser (Jira)
• 2026/07/02 [jira] [Assigned] (FLINK-40031) Exceptions view crashes (NG04008) navigating to an unassigned TaskManager Martijn Visser (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40037) Local RocksDB working directory leaked (with all file handles held open) when an async-state-v2 task is redeployed onto the same TaskManager after a job restart Stepan Stepanishchev (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40027) Align SavepointKeyFilter with the State Processor API generic convention Gabor Somogyi (Jira)
• 2026/07/02 [jira] [Resolved] (FLINK-40027) Align SavepointKeyFilter with the State Processor API generic convention Gabor Somogyi (Jira)
• 2026/07/02 [jira] [Closed] (FLINK-40027) Align SavepointKeyFilter with the State Processor API generic convention Gabor Somogyi (Jira)
• 2026/07/02 [jira] [Closed] (FLINK-39938) FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler Gyula Fora (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40037) Local RocksDB working directory leaked (with all file handles held open) when an async-state-v2 task is redeployed onto the same TaskManager after a job restart Kartikey Pant (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-39384) PyFlink load_plan() CompiledPlans cannot be executed Gustavo de Morais (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-39384) PyFlink load_plan() CompiledPlans cannot be executed Gustavo de Morais (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-39384) PyFlink load_plan() CompiledPlans cannot be executed Gustavo de Morais (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-39384) PyFlink load_plan() CompiledPlans cannot be executed Gustavo de Morais (Jira)
• 2026/07/02 [jira] [Created] (FLINK-40052) NullPointerException in MySqlHybridSplitAssigner.createBinlogSplit when snapshot split reader fails after assigner status has reached FINISHED SkylerLin (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40035) Add smoke-level component specs for the web-dashboard Purushottam Sinha (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40036) Support injecting a custom MockEnvironment into multi-input operator test harnesses Kaivalya Apte (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Martijn Visser (Jira)
• 2026/07/02 [jira] [Closed] (FLINK-39839) FLIP-580:AsyncTableFunction supports user-defined timeout handling logic lincoln lee (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Martijn Visser (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Martijn Visser (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Martijn Visser (Jira)
• 2026/07/02 [jira] [Assigned] (FLINK-39481) Watermark deferred by interruptible timers is lost at end of input, dropping window results Martijn Visser (Jira)
• 2026/07/02 [jira] [Comment Edited] (FLINK-40035) Add smoke-level component specs for the web-dashboard Purushottam Sinha (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40035) Add smoke-level component specs for the web-dashboard Purushottam Sinha (Jira)
• 2026/07/02 [jira] [Assigned] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type. Yuepeng Pan (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type. Yuepeng Pan (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type. Yuepeng Pan (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40031) Exceptions view crashes (NG04008) navigating to an unassigned TaskManager Purushottam Sinha (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40003) IOMetrics not visible to ExecutionStateUpdateListeners during FINISHED/FAILED transitions Matthias Pohl (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Rui Fan (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-40016) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fails with "Corrupt stream, found tag" (in-flight stream desync) on rescale recovery Rui Fan (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type. ouyangwulin (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-39969) use the same SSL protcol and algorithms on all the flink services and all clients Jira
• 2026/07/02 [jira] [Updated] (FLINK-39969) use the same SSL protcol and algorithms on all the flink services and all clients Jira
• 2026/07/02 [jira] [Commented] (FLINK-39795) MongoDB CDC does not use index when reading shard collection chunks lisa (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40036) Support injecting a custom MockEnvironment into multi-input operator test harnesses Bettle (Jira)
• 2026/07/02 [jira] [Resolved] (FLINK-40050) flink-ci/flink-mirror isn't mirroring commits anymore Qingsheng Ren (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40050) flink-ci/flink-mirror isn't mirroring commits anymore Qingsheng Ren (Jira)
• 2026/07/02 [jira] [Assigned] (FLINK-40050) flink-ci/flink-mirror isn't mirroring commits anymore Qingsheng Ren (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-40018) PTF changelog inference silently drops an unsatisfiable table input, causing IndexOutOfBoundsException Gustavo de Morais (Jira)
• 2026/07/02 [jira] [Created] (FLINK-40051) erorr: No coordinator registered for operator when set operator.uid.prefix in mysql to hudi pipeline yaml lisa (Jira)
• 2026/07/02 [jira] [Closed] (FLINK-40018) PTF changelog inference silently drops an unsatisfiable table input, causing IndexOutOfBoundsException Gustavo de Morais (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-40047) Kubernetes Operator: Standalone mode "--host" usage breaks Flink 2.0+ Marc Demierre (Jira)
• 2026/07/02 [jira] [Updated] (FLINK-40047) Kubernetes Operator: Standalone mode "--host" usage breaks Flink 2.0+ Marc Demierre (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40018) PTF changelog inference silently drops an unsatisfiable table input, causing IndexOutOfBoundsException Gustavo de Morais (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-40034) Refresh web-dashboard lint tooling to prettier 3 and stylelint 17 Purushottam Sinha (Jira)
• 2026/07/02 [jira] [Comment Edited] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Piotr Nowojski (Jira)
• 2026/07/02 [jira] [Comment Edited] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Piotr Nowojski (Jira)
• 2026/07/02 [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Piotr Nowojski (Jira)
• 2026/07/02 Re: [PR] [FLINK-39938] FLIP-586: Composable Parallelism Alignment Modes for Flink Autoscaler [flink-kubernetes-operator] via GitHub
• 2026/07/02 Re: [PR] [FLINK-40031][runtime-web] Fix Exceptions view crash navigating to an unassigned TaskManager [flink] via GitHub
• 2026/07/02 Re: [PR] [FLINK-31849] Adds basic CRD validations [flink-kubernetes-operator] via GitHub
• 2026/07/02 [jira] [Assigned] (FLINK-40043) Paimon pipeline job couldn’t increase job parallelism Leonard Xu (Jira)
• 2026/07/02 Re: [PR] [FLINK-39969][runtime] use the same SSL protcol and algorithms in flink [flink] via GitHub
• 2026/07/02 [jira] [Commented] (FLINK-40033) Modernize web-dashboard visualization libraries Purushottam Sinha (Jira)
• 2026/07/02 Re: [PR] [FLINK-39059][models] Add unified inference metrics for model functions [flink] via GitHub
• 2026/07/02 Re: [PR] [FLINK-39059][models] Add unified inference metrics for model functions [flink] via GitHub
• 2026/07/02 Re: [PR] [FLINK-34610] Migrate `StreamPhysicalLimitRule` from Scala to Java [flink] via GitHub
• 2026/07/02 Re: [PR] [FLINK-34610] Migrate `StreamPhysicalLimitRule` from Scala to Java [flink] via GitHub
• 2026/07/02 Re: [PR] [FLINK-37501][runtime/web] Fix incorrect job ID in url for logs in history server [flink] via GitHub
• 2026/07/02 [jira] [Created] (FLINK-40050) flink-ci/flink-mirror isn't mirroring commits anymore Martijn Visser (Jira)
• 2026/07/02 Re: [PR] [FLINK-37448] Report actual TaskManager count in status.taskManager.replicas [flink-kubernetes-operator] via GitHub
• 2026/07/01 Re: [PR] [Feature] Support tool parameter injection [flink-agents] via GitHub
• 2026/07/01 [jira] [Commented] (FLINK-40007) Fix Postgres CDC snapshot fetch size conf does not take effect Hongshun Wang (Jira)
• 2026/07/01 [jira] [Comment Edited] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type. Chanhae Oh (Jira)
• 2026/07/01 [jira] [Commented] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type. Chanhae Oh (Jira)
• 2026/07/01 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40039] Fix CTAS/RTAS when used with set-semantic PTFs [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39957][table] Support EXPLAIN of CREATE [OR ALTER] MATERIALIZED TABLE [flink] via GitHub
• 2026/07/01 [jira] [Created] (FLINK-40049) Changes for Flink-connector-Prometheus for Flink2.x Taranpreet Kaur (Jira)
• 2026/07/01 Re: [PR] [FLINK-40027][state] Align SavepointKeyFilter with the State Processor API generic convention [flink] via GitHub
• 2026/07/01 [jira] [Commented] (FLINK-36812) The flink jdbc connector's 'scan.partition.column' supports the varchar field type. Chanhae Oh (Jira)
• 2026/07/01 Re: [PR] [Feature] Support tool parameter injection [flink-agents] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39968] [core] Reduce redundant AtomicBoolean allocation in MemorySegment to improve construction performance [flink] via GitHub
• 2026/07/01 Re: [D] Planning Flink Agents 0.4 [flink-agents] via GitHub
• 2026/07/01 Re: [D] Planning Flink Agents 0.4 [flink-agents] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39839][table] Supports timeout in AsyncTableFunction [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39839][table] Supports timeout in AsyncTableFunction [flink] via GitHub
• 2026/07/01 Re: [D] Planning Flink Agents 0.4 [flink-agents] via GitHub
• 2026/07/01 [I] [Tech Debt] Avoid using reflection to load implementation classes of resources during the compilation phase. [flink-agents] via GitHub
• 2026/07/01 [I] [Tech Debt] Update install.sh after releasing 0.3.0 [flink-agents] via GitHub
• 2026/07/01 [jira] [Updated] (FLINK-40038) [mysql][pipeline] Incremental sync throughput is low in hotspot UPDATE workloads due to deserialization overhead ASF GitHub Bot (Jira)
• 2026/07/01 [PR] [FLINK-40038][pipeline-connector/mysql] Cache inferred row DataType in MySQL deserialization [flink-cdc] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40007][postgres] Fix snapshot fetch size conf does not take effect [flink-cdc] via GitHub
• 2026/07/01 Re: [PR] [FLINK-39198] Fix data loss during restoration from checkpoint in TIMESTAMP startup mode. [flink-cdc] via GitHub
• 2026/07/01 [jira] [Updated] (FLINK-40044) Replace dagre with @dagrejs/dagre 3.x Purushottam Sinha (Jira)
• 2026/07/01 [jira] [Updated] (FLINK-40045) Upgrade d3-flame-graph to v5 Purushottam Sinha (Jira)
• 2026/07/01 Re: [PR] [dist] Add Flink 2.3 distribution and make it the default [flink-agents] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40016][checkpoint] Prevent recovered buffers from being persisted twice in LocalInputChannel [flink] via GitHub
• 2026/07/01 Re: [PR] [FLINK-40016][checkpoint] Prevent recovered buffers from being persisted twice in LocalInputChannel [flink] via GitHub
• 2026/07/01 [jira] [Created] (FLINK-40048) Refactor and re-enable flink-sql-client-test E2E test Martijn Visser (Jira)
• 2026/07/01 [jira] [Assigned] (FLINK-40048) Refactor and re-enable flink-sql-client-test E2E test Martijn Visser (Jira)
• 2026/07/01 [jira] [Updated] (FLINK-40048) Refactor and re-enable flink-sql-client-test E2E test Martijn Visser (Jira)
• 2026/07/01 [jira] [Closed] (FLINK-39930) Fix the flaky test case WindowDistinctAggregateITCase#testHopWindow_Cube Martijn Visser (Jira)
• 2026/07/01 [jira] [Comment Edited] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Martijn Visser (Jira)
• 2026/07/01 [jira] [Commented] (FLINK-39481) ⁠[tests] Fix flaky WindowDistinctAggregateITCase#testCumulateWindow_GroupingSets⁠ Martijn Visser (Jira)
• 2026/07/01 Re: [PR] [FLINK-40016][checkpoint] Prevent recovered buffers from being persisted twice in LocalInputChannel [flink] via GitHub
• 2026/07/01 Re: [PR] Bump ip-address and socks in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump fast-uri from 3.0.3 to 3.1.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump lodash from 4.17.21 to 4.18.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump fast-uri from 3.0.3 to 3.1.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump node-forge from 1.3.1 to 1.4.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump node-forge from 1.3.1 to 1.4.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @babel/plugin-transform-modules-systemjs from 7.27.1 to 7.29.4 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump ip-address and socks in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @babel/plugin-transform-modules-systemjs from 7.27.1 to 7.29.4 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump @babel/plugin-transform-modules-systemjs from 7.27.1 to 7.29.4 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump follow-redirects from 1.15.9 to 1.16.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump lodash from 4.17.21 to 4.18.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump follow-redirects from 1.15.9 to 1.16.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump idna from 3.11 to 3.15 in /flink-python/docs [flink] via GitHub
• 2026/07/01 Re: [PR] Bump urllib3 from 2.6.3 to 2.7.0 in /flink-python/docs [flink] via GitHub
• 2026/07/01 Re: [PR] Bump ip-address and socks in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump fast-uri from 3.0.3 to 3.1.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump follow-redirects from 1.15.9 to 1.16.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump lodash from 4.17.21 to 4.18.1 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump pygments from 2.19.2 to 2.20.0 in /flink-python/docs [flink] via GitHub
• 2026/07/01 Re: [PR] Bump node-forge from 1.3.1 to 1.4.0 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump tar and @angular/cli in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump flatted from 3.3.2 to 3.4.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump flatted from 3.3.2 to 3.4.2 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/07/01 Re: [PR] Bump immutable from 5.1.3 to 5.1.5 in /flink-runtime-web/web-dashboard [flink] via GitHub

• Earlier messages
• Later messages