issues  

Messages by Date

• 2026/09/01 [jira] [Closed] (FLINK-40017) Introduce Seaweedfs in native-s3-fs Samrat Deb (Jira)
• 2026/09/01 Re: [PR] [FLINK-40197][python] Add sql() to the DataFrame API [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40197][python] Add sql() to the DataFrame API [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
• 2026/09/01 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-39136] [flink-gs-fs-hadoop] bump com.google.cloud:google-cloud-storage from 2.29.1 to 2.62.1 [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40445] Autoscaler: integration test for Kafka/Pulsar source partition-metric detection [flink-kubernetes-operator] via GitHub
• 2026/08/31 [PR] [tools][ci] Fix the bats suite's boundary with the scripts it tests [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [runtime][api] Scope long-term memory operations to the action that obtained the memory set [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [integrations][anthropic] Stop sending rejected sampling parameters [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [runtime][plan][python] Add built-in operational metrics [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [runtime][plan][python] Add built-in operational metrics [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation [flink] via GitHub
• 2026/08/31 [PR] [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40530)  HistoryServerArchiveFetcher.updateJobOverview() aggregates all archived job overviews without per-entry error isolation, causing a single malformed archive to blank out the entire /jobs/overview response ASF GitHub Bot (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40530)  HistoryServerArchiveFetcher.updateJobOverview() aggregates all archived job overviews without per-entry error isolation, causing a single malformed archive to blank out the entire /jobs/overview response Archit Goyal (Jira)
• 2026/08/31 [jira] [Updated] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use Deepyaman Datta (Jira)
• 2026/08/31 Re: [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use ASF GitHub Bot (Jira)
• 2026/08/31 [PR] [FLINK-40529][python] Warn on use of deprecated APIs, not at import time [flink] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40529) PyFlink @Deprecated decorator warns at import time instead of on use Deepyaman Datta (Jira)
• 2026/08/31 [I] [Tech Debt][API][Flink Integration] Simplify Agent output materialization to DataStream and Table [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40416][runtime] Add built-in text AI functions [flink-cdc] via GitHub
• 2026/08/31 [jira] [Commented] (FLINK-40421) Add sorting support in DataFrame API Hirson Zhang (Jira)
• 2026/08/31 Re: [PR] [FLINK-40512][postgres] PostgreSQL source only emits relation schema events matching table filter. [flink-cdc] via GitHub
• 2026/08/31 [jira] [Commented] (FLINK-40424) Add windowing TVF support to DataFrame API Dian Fu (Jira)
• 2026/08/31 [jira] [Assigned] (FLINK-40424) Add windowing TVF support to DataFrame API Dian Fu (Jira)
• 2026/08/31 Re: [PR] [FLINK-40507] Upgrade paimon to 2.0.0 [flink-cdc] via GitHub
• 2026/08/31 Re: [PR] [released] Add Flink-Shaded 22.0 [flink-web] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40528][table] Make codegen tolerat to partial deletes [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40528) Codegen should be tolerate to partial deletes ASF GitHub Bot (Jira)
• 2026/08/31 [PR] [FLINK-40528][table] Make codegen tolerat to partial deletes [flink] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40528) Codegen should be tolerate to partial deletes Sergey Nuyanzin (Jira)
• 2026/08/31 Re: [PR] [FLINK-40527] Update flink-shaded to 22.0 [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40527) Update flink-shaded to 22.0 ASF GitHub Bot (Jira)
• 2026/08/31 [PR] [FLINK-40527] Update flink-shaded to 22.0 [flink] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40527) Update flink-shaded to 22.0 Sergey Nuyanzin (Jira)
• 2026/08/31 [jira] [Resolved] (FLINK-40510) Use Apache Parent POM 39 Sergey Nuyanzin (Jira)
• 2026/08/31 [jira] [Commented] (FLINK-40510) Use Apache Parent POM 39 Sergey Nuyanzin (Jira)
• 2026/08/31 Re: [PR] [FLINK-40510][build] Bump Apache Parent pom to 39 [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40510][build] Bump Apache Parent pom to 39 [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-39837] Reassign retained dynamic Kafka offsets upon readd [flink-connector-kafka] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/08/31 Re: [PR] [integrations][java][python] Apply Ollama native structured output [flink-agents] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40514) [Docs] Doris pipeline connector option table does not match implementation Rango (Jira)
• 2026/08/31 [PR] [FLINK-39570] Bump Netty to 4.1.136.Final (release-20.0) [flink-shaded] via GitHub
• 2026/08/31 Re: [PR] [integrations][anthropic] Update the stale default model to claude-sonnet-4-6 [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered [flink-agents] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40483) Support batch Top-N optimization for ROW_NUMBER() ASF GitHub Bot (Jira)
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 [jira] [Closed] (FLINK-40356) Add MAP_FROM_ENTRIES function Gustavo de Morais (Jira)
• 2026/08/31 [jira] [Updated] (FLINK-39813) [Connectors/Kinesis] Add lineage support to Kinesis Streams connector ASF GitHub Bot (Jira)
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source Ferenc Csaky (Jira)
• 2026/08/31 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40483][table-planner] Convert batch ROW_NUMBER Top-N to two-stage Rank [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 [jira] [Commented] (FLINK-40481) SHOW CREATE MATERIALIZED TABLE displays a future timestamp for FROM_NOW(<interval>) instead of past Arvid Heise (Jira)
• 2026/08/31 [jira] [Resolved] (FLINK-40481) SHOW CREATE MATERIALIZED TABLE displays a future timestamp for FROM_NOW(<interval>) instead of past Arvid Heise (Jira)
• 2026/08/31 Re: [PR] [FLINK-40519][network] Deliver priority barrier to a credited remote reader while the subpartition is blocked during recovery [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40519) Checkpoint-during-recovery barrier is not delivered to a credited remote reader while the subpartition is blocked ASF GitHub Bot (Jira)
• 2026/08/31 [PR] [FLINK-40525][network] Remove residual receivedBuffers lock in finishReadRecoveredState to avoid ABBA deadlock [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40523][network] Compute tracePersist debug string only when trace logging is enabled [flink] via GitHub
• 2026/08/31 Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• 2026/08/31 [PR] [FLINK-40522][network] Deduplicate RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel [flink] via GitHub
• 2026/08/31 [jira] [Reopened] (FLINK-38544) FLIP-547 V2: Filtering record before processing with spilling strategy Rui Fan (Jira)
• 2026/08/31 [PR] [FLINK-40483][table-planner] Convert batch ROW_NUMBER Top-N to two-stage Rank [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40478][runtime-web] Log effective HistoryServer configuration at startup [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40524) LocalInputChannel.getNextBuffer takes the recoveredBuffers monitor on every buffer even when the channel never needed recovery ASF GitHub Bot (Jira)
• 2026/08/31 Re: [PR] [FLINK-34246][runtime] Add option to only archive failed jobs to history server [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40518) CDR is wrongly kept enabled on the aligned path when unaligned checkpoint is disabled ASF GitHub Bot (Jira)
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/08/31 [jira] [Commented] (FLINK-40207) Make NaN and Infinity case-insensitive Sergey Nuyanzin (Jira)
• 2026/08/31 [jira] [Resolved] (FLINK-40382) Serializer test variants in flink-table-type-utils are never executed Sergey Nuyanzin (Jira)
• 2026/08/31 [jira] [Commented] (FLINK-40382) Serializer test variants in flink-table-type-utils are never executed Sergey Nuyanzin (Jira)
• 2026/08/31 Re: [PR] [FLINK-40382][tests] Execute static nested test class variants and guard against regressions [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5 [flink] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40526) Checkpointing-during-recovery crashes a recovering RemoteInputChannel when announcing a stashed timeoutable-aligned barrier Rui Fan (Jira)
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40491) Extend BinaryVariant with primitive codes 17-19 Ramin Gharib (Jira)
• 2026/08/31 [jira] [Commented] (FLINK-40430) Add configuration support to DataFrame API Federico Dolce (Jira)
• 2026/08/31 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/08/31 [PR] [FLINK-40523][network] Compute tracePersist debug string only when trace logging is enabled [flink] via GitHub
• 2026/08/31 [PR] [FLINK-40518][checkpointing] Only enable checkpointing-during-recovery when unaligned checkpoints are enabled [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40510][build] Bump Apache Parent pom to 39 [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40510][build] Bump Apache Parent pom to 39 [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40522][network] Deduplicate RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40518][checkpointing] Only enable checkpointing-during-recovery when unaligned checkpoints are enabled [flink] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40523) NetworkActionsLogger.tracePersist unconditionally builds the buffer debug string Rui Fan (Jira)
• 2026/08/31 Re: [PR] [FLINK-40521][network] Document potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40524][network] Skip the recoveredBuffers monitor on the getNextBuffer hot path for channels that never recover [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40467] Randomise application result store paths [flink-kubernetes-operator] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40522) Deduplicate the RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel ASF GitHub Bot (Jira)
• 2026/08/31 [jira] [Updated] (FLINK-40521) Potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery ASF GitHub Bot (Jira)
• 2026/08/31 Re: [PR] [FLINK-40525][network] Remove residual receivedBuffers lock in finishReadRecoveredState to avoid ABBA deadlock [flink] via GitHub
• 2026/08/31 [PR] [FLINK-40524][network] Skip the recoveredBuffers monitor on the getNextBuffer hot path for channels that never recover [flink] via GitHub
• 2026/08/31 [PR] [FLINK-40521][network] Document potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery [flink] via GitHub
• 2026/08/31 [PR] [FLINK-40519][network] Deliver priority barrier to a credited remote reader while the subpartition is blocked during recovery [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40523) NetworkActionsLogger.tracePersist unconditionally builds the buffer debug string ASF GitHub Bot (Jira)
• 2026/08/31 [jira] [Updated] (FLINK-40525) RecoveredInputChannel.finishReadRecoveredState holds receivedBuffers across notifyChannelNonEmpty, risking an ABBA deadlock ASF GitHub Bot (Jira)
• 2026/08/31 Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/08/31 [jira] [Closed] (FLINK-35500) DynamoDb Table API Sink fails to delete elements due to key not found Ferenc Csaky (Jira)
• 2026/08/31 [jira] [Updated] (FLINK-35500) DynamoDb Table API Sink fails to delete elements due to key not found Ferenc Csaky (Jira)
• 2026/08/31 Re: [PR] [FLINK-35500][Connectors/DynamoDB] DynamoDB Table API sink fails to delete elements due to key not found [flink-connector-aws] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40525) RecoveredInputChannel.finishReadRecoveredState holds receivedBuffers across notifyChannelNonEmpty, risking an ABBA deadlock Rui Fan (Jira)
• 2026/08/31 [jira] [Closed] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source Ferenc Csaky (Jira)
• 2026/08/31 Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub
• 2026/08/31 Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-39137) Add configurable delay between non-empty GetRecords calls in Kinesis source Ferenc Csaky (Jira)
• 2026/08/31 Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40524) LocalInputChannel.getNextBuffer takes the recoveredBuffers monitor on every buffer even when the channel never needed recovery Rui Fan (Jira)
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/08/31 Re: [PR] [hotfix][docs] Fix AzureTableConfiguration class name casing in Azure Table Storage doc [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40019][core][runtime] Support per-job delegation tokens [flink] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40522) Deduplicate the RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel Rui Fan (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40521) Potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery Rui Fan (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40520) Recovered channel-state spill files leak when recovery aborts between fetch and drain Rui Fan (Jira)
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40243] Bump postgresql jdbc driver from 42.5.6 to 42.7.13 [flink-kubernetes-operator] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40449][table] Reject non-temporal streaming sort during planning [flink] via GitHub
• 2026/08/31 [jira] [Commented] (FLINK-40424) Add windowing TVF support to DataFrame API Timo Theusner (Jira)
• 2026/08/31 [jira] [Updated] (FLINK-40491) Extend BinaryVariant with primitive codes 17-19 ASF GitHub Bot (Jira)
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 [PR] [FLINK-40491][core] Extend BinaryVariant with TIME, TIMESTAMP_NS, TIMESTAMP_LTZ_NS primitives [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
• 2026/08/31 [jira] [Commented] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty Martijn Visser (Jira)
• 2026/08/31 [jira] [Comment Edited] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty Efrat Levitan (Jira)
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 [jira] [Commented] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty Efrat Levitan (Jira)
• 2026/08/31 [PR] [plan][java][python] Reject unsafe Bash redirects [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40519) Checkpoint-during-recovery barrier is not delivered to a credited remote reader while the subpartition is blocked Rui Fan (Jira)
• 2026/08/31 [jira] [Comment Edited] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty Martijn Visser (Jira)
• 2026/08/31 [PR] [FLINK-39586][connector-base] Add watermark stall reproduction ITCase [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40518) CDR is wrongly kept enabled on the aligned path when unaligned checkpoint is disabled Rui Fan (Jira)
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 [jira] [Updated] (FLINK-40518) CDR is wrongly kept enabled on the aligned path when unaligned checkpoint is disabled Rui Fan (Jira)
• 2026/08/31 [jira] [Updated] (FLINK-40517) Checkpointing-during-recovery drops cross-channel watermark / watermark-status aggregation on fan-in rescale Rui Fan (Jira)
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40197][python] Add sql() to the DataFrame API [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40517) Checkpointing-during-recovery drops cross-channel watermark / watermark-status aggregation on fan-in rescale Rui Fan (Jira)
• 2026/08/31 Re: [PR] [FLINK-35500][Connectors/DynamoDB] DynamoDB Table API sink fails to delete elements due to key not found [flink-connector-aws] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-39813][Connectors/Kinesis] Add lineage support to Kinesis Streams connector [flink-connector-aws] via GitHub
• 2026/08/31 [jira] [Assigned] (FLINK-40430) Add configuration support to DataFrame API Dian Fu (Jira)
• 2026/08/31 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/31 [PR] [release-0.3][hotfix][runtime][java] Reject raw bytes from PyFlink inputs [flink-agents] via GitHub
• 2026/08/31 [jira] [Commented] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty Martijn Visser (Jira)
• 2026/08/31 [jira] [Commented] (FLINK-40430) Add configuration support to DataFrame API Dian Fu (Jira)
• 2026/08/31 Re: [PR] [FLINK-39586][connector-base] Add watermark stall reproduction ITCase [flink] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/08/31 Re: [I] [Tech Debt] Update the stale Anthropic default model claude-sonnet-4-20250514 to claude-sonnet-4-5 [flink-agents] via GitHub
• 2026/08/31 [jira] [Created] (FLINK-40516) Needed to support network policy in Jobmanager and Task Manager Taranpreet Kaur (Jira)
• 2026/08/31 Re: [PR] [release-0.2][hotfix][runtime][java] Reject raw bytes from PyFlink inputs [flink-agents] via GitHub
• 2026/08/31 [jira] [Closed] (FLINK-40513) Validate forward routing and optimize Fluss sink writer with bucket affinity Mao Jiayi (Jira)
• 2026/08/31 [jira] [Created] (FLINK-40515) Extend BinaryVariant to support UUID (Code 20) Ramin Gharib (Jira)
• 2026/08/31 [jira] [Updated] (FLINK-40491) Extend BinaryVariant with primitive codes 17-19 Ramin Gharib (Jira)
• 2026/08/31 Re: [PR] [release-0.3][hotfix][runtime][java] Reject raw bytes from PyFlink inputs [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink. [flink-cdc] via GitHub
• 2026/08/31 [jira] [Assigned] (FLINK-40491) Extend BinaryVariant with primitive codes 17-19 Ramin Gharib (Jira)
• 2026/08/31 Re: [PR] [FLINK-35500][Connectors/DynamoDB] DynamoDB Table API sink fails to delete elements due to key not found [flink-connector-aws] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink. [flink-cdc] via GitHub
• 2026/08/31 [PR] ci: update checkout, setup-python, and setup-java to current majors [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [FLINK-35500][Connectors/DynamoDB] DynamoDB Table API sink fails to delete elements due to key not found [flink-connector-aws] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40128][connector][static-source] Implement Topic integrity checks [flink-connector-kafka] via GitHub
• 2026/08/31 [PR] [release-0.2][hotfix][runtime][java] Reject raw bytes from PyFlink inputs [flink-agents] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink. [flink-cdc] via GitHub
• 2026/08/31 Re: [PR] [FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink. [flink-cdc] via GitHub
• 2026/08/31 Re: [PR] [hotfix][runtime] Reject raw bytes from PyFlink inputs [flink-agents] via GitHub
• 2026/08/30 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub

• Earlier messages
• Later messages