issues  

Messages by Date

• 2026/08/28 Re: [PR] [FLINK-40503][core] Document effective idleness detection timing [flink] via GitHub
• 2026/08/28 [jira] [Assigned] (FLINK-40499) Final MAX_WATERMARK is dropped at drain when the source's last announced status is IDLE Martijn Visser (Jira)
• 2026/08/28 Re: [PR] [FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40505][runtime] Prune failed subtasks from watermark alignment [flink] via GitHub
• 2026/08/28 [jira] [Updated] (FLINK-40503) WatermarksWithIdleness effective timeout is idleTimeout plus up to 3 probe intervals, contradicting the withIdleness documentation Martijn Visser (Jira)
• 2026/08/28 [jira] [Updated] (FLINK-40503) WatermarksWithIdleness effective timeout is idleTimeout plus up to 3 probe intervals, contradicting the withIdleness documentation ASF GitHub Bot (Jira)
• 2026/08/28 [PR] [FLINK-40503][core] Document effective idleness detection timing [flink] via GitHub
• 2026/08/28 [jira] [Updated] (FLINK-40499) Final MAX_WATERMARK is dropped at drain when the source's last announced status is IDLE ASF GitHub Bot (Jira)
• 2026/08/28 [jira] [Updated] (FLINK-40505) SourceCoordinator never removes failed or reset subtasks from watermark-alignment aggregation ASF GitHub Bot (Jira)
• 2026/08/28 [PR] [FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain [flink] via GitHub
• 2026/08/28 [jira] [Updated] (FLINK-37666) Address CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation Roman Khachatryan (Jira)
• 2026/08/28 [jira] [Closed] (FLINK-37666) Address CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation Roman Khachatryan (Jira)
• 2026/08/28 Re: [PR] [FLINK-37666] CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40197][python] Add sql() to the DataFrame API [flink] via GitHub
• 2026/08/28 [jira] [Updated] (FLINK-40197) Add sql bindings to DataFrame API ASF GitHub Bot (Jira)
• 2026/08/28 [PR] [FLINK-40197][python] Add sql() to the DataFrame API [flink] via GitHub
• 2026/08/28 [jira] [Updated] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances Martijn Visser (Jira)
• 2026/08/28 [jira] [Assigned] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness Martijn Visser (Jira)
• 2026/08/28 [jira] [Commented] (FLINK-40475) StatusWatermarkValve loses or stalls watermarks when subpartitions realign after idleness Martijn Visser (Jira)
• 2026/08/28 Re: [PR] [FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness [flink] via GitHub
• 2026/08/28 [jira] [Commented] (FLINK-40371) Watermark alignment does not consistently bound cross-subtask event-time drift after restoring from a savepoint Martijn Visser (Jira)
• 2026/08/28 Re: [PR] [FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction [flink] via GitHub
• 2026/08/28 [jira] [Created] (FLINK-40503) WatermarksWithIdleness effective timeout is idleTimeout plus up to 2× the periodic probe interval, contradicting the withIdleness documentation Martijn Visser (Jira)
• 2026/08/28 [jira] [Commented] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty Martijn Visser (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40505) SourceCoordinator never removes failed or reset subtasks from watermark-alignment aggregation Martijn Visser (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances Martijn Visser (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40502) scan.watermark.idle-timeout is silently ignored for connectors without watermark pushdown; SOURCE_WATERMARK() ignores idle-timeout entirely Martijn Visser (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40500) DataStream V2 idleness detection is not backpressure-aware - FLIP-471 was never applied to ExtractEventTimeProcessFunction Martijn Visser (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40501) WatermarkStatus overtakes queued watermarks in AsyncWaitOperator, causing watermark loss downstream Martijn Visser (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40499) Final MAX_WATERMARK is dropped at drain when the source's last announced status is IDLE Martijn Visser (Jira)
• 2026/08/28 Re: [PR] [FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5 [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40357][table] Add ARRAY_FLATTEN function to Flink SQL [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40357][table] Add ARRAY_FLATTEN function to Flink SQL [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40498][tests] Adjust LateralSnapshotJoin tests for optional TABLE keyword [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5 [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40444][table-common] Preserve attribute order in OBJECT_UPDATE [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40449][table] Reject non-temporal streaming sort during planning [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40498][tests] Adjust LateralSnapshotJoin tests for optional TABLE keyword [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40496][table-planner] CREATE OR ALTER MATERIALIZED TABLE honors query column position [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40498][tests] Adjust LateralSnapshotJoin tests for optional TABLE keyword [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5 [flink] via GitHub
• 2026/08/28 [jira] [Updated] (FLINK-40498) Adjust tests to call SNAPSHOT without TABLE keyword ASF GitHub Bot (Jira)
• 2026/08/28 [PR] [FLINK-40498][tests] Adjust LateralSnapshotJoin tests for optional TABLE keyword [flink] via GitHub
• 2026/08/28 [jira] [Updated] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE ignores query column position, silently producing a schema whose column order disagrees with the query (ALTER ... AS is correct) ASF GitHub Bot (Jira)
• 2026/08/28 Re: [PR] [FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40232][table-runtime] Handle null rowtime in OutputConversionOperator [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5 [flink] via GitHub
• 2026/08/28 [PR] [FLINK-40496][table-planner] CREATE OR ALTER MATERIALIZED TABLE honors query column position [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40422][python] Add slicing APIs to DataFrame API [flink] via GitHub
• 2026/08/28 [jira] [Created] (FLINK-40498) Adjust tests to call SNAPSHOT without TABLE keyword Fabian Hueske (Jira)
• 2026/08/28 [jira] [Commented] (FLINK-40197) Add sql bindings to DataFrame API Federico Dolce (Jira)
• 2026/08/28 Re: [PR] [FLINK-39789] AvroSchemaConverter updates for local-timestamp-* and timestamp-nanos logical types [flink] via GitHub
• 2026/08/28 [jira] [Assigned] (FLINK-40497) Allow materialized tables to default to ON CONFLICT DO ERROR Gustavo de Morais (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40497) Allow materialized tables to default to ON CONFLICT DO ERROR Gustavo de Morais (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40496) CREATE OR ALTER MATERIALIZED TABLE ignores query column position, silently producing a schema whose column order disagrees with the query (ALTER ... AS is correct) Arvid Heise (Jira)
• 2026/08/28 [jira] [Resolved] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser (Jira)
• 2026/08/28 [jira] [Updated] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser (Jira)
• 2026/08/28 Re: [PR] [FLINK-40459][build] Bump Maven from 3.8.6 to 3.9.16 [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-39780] Make TABLE keyword optional in LATERAL context [flink] via GitHub
• 2026/08/28 [jira] [Resolved] (FLINK-39780) Make TABLE keyword optional in LATERAL context Fabian Hueske (Jira)
• 2026/08/28 Re: [PR] [hotfix][docs] Fix OPTIONS hint key in time attributes docs [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink] via GitHub
• 2026/08/28 [jira] [Updated] (FLINK-40422) Add slicing APIs to DataFrame API ASF GitHub Bot (Jira)
• 2026/08/28 Re: [PR] [FLINK-40422][python] Add slicing APIs to DataFrame API [flink] via GitHub
• 2026/08/28 [PR] [FLINK-40422][python] Add slicing APIs to DataFrame API [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40431][python] Add scalar UDF support to DataFrame API [flink] via GitHub
• 2026/08/28 Re: [PR] [ci][integrations] Consolidate vector store tests [flink-agents] via GitHub
• 2026/08/28 Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
• 2026/08/28 Re: [I] [Feature] Multimodal content blocks in ChatMessage [flink-agents] via GitHub
• 2026/08/28 Re: [PR] [FLINK-37666] CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation [flink] via GitHub
• 2026/08/27 [PR] Multimodal content blocks [flink-agents] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5 [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40431][python] Add scalar UDF support to DataFrame API [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5 [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40431][python] Add scalar UDF support to DataFrame API [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5 [flink] via GitHub
• 2026/08/27 [PR] [ci][integrations] Consolidate vector store tests [flink-agents] via GitHub
• 2026/08/27 Re: [D] [Discuss][API] Multimodal content parts in ChatMessage [flink-agents] via GitHub
• 2026/08/27 [I] [Feature] Multimodal content blocks in ChatMessage [flink-agents] via GitHub
• 2026/08/27 [jira] [Commented] (FLINK-40422) Add slicing APIs to DataFrame API Dian Fu (Jira)
• 2026/08/27 [jira] [Commented] (FLINK-40422) Add slicing APIs to DataFrame API Dian Fu (Jira)
• 2026/08/27 [jira] [Assigned] (FLINK-40422) Add slicing APIs to DataFrame API Dian Fu (Jira)
• 2026/08/27 Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
• 2026/08/27 Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/08/27 Re: [D] [Discuss][API] Multimodal content parts in ChatMessage [flink-agents] via GitHub
• 2026/08/27 [jira] [Commented] (FLINK-39986) Support Common Sub-Expression Elimination (CSE) for Python UDFs Dian Fu (Jira)
• 2026/08/27 Re: [PR] [hotfix][runtime][python] Close every component when an earlier close fails [flink-agents] via GitHub
• 2026/08/27 Re: [PR] [FLINK-39179][mysql] Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing [flink-cdc] via GitHub
• 2026/08/27 Re: [PR] [FLINK-39020][pipeline][doris] Fix the bug When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) [flink-cdc] via GitHub
• 2026/08/27 [PR] [FLINK-39020][pipeline][doris] Fix the bug When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) [flink-cdc] via GitHub
• 2026/08/27 Re: [PR] [FLINK-39020][pipeline][doris] Fix the bug When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) [flink-cdc] via GitHub
• 2026/08/27 Re: [PR] [FLINK-38236][mongodb] Add metadata support for full document in MongoDB CDC connector [flink-cdc] via GitHub
• 2026/08/27 Re: [PR] [FLINK-39020][pipeline][doris] Fix the bug When synchronizing MySQL to Doris, data of type java.time.LocalTime is serialized or deserialized, but by default, Jackson does not support the handling of Java 8 time types (such as LocalTime, LocalDateTime, etc.) [flink-cdc] via GitHub
• 2026/08/27 Re: [PR] [FLINK-38236][mongodb] Add metadata support for full document in MongoDB CDC connector [flink-cdc] via GitHub
• 2026/08/27 Re: [PR] [FLINK-39179][mysql] Add REPLACE INTO filtering in handleQueryEvent to fix pt-table-checksum DML parsing [flink-cdc] via GitHub
• 2026/08/27 [jira] [Assigned] (FLINK-40483) Support batch Top-N optimization for ROW_NUMBER() Dian Fu (Jira)
• 2026/08/27 [jira] [Commented] (FLINK-23758) PyFlink __invert__ has wrong semantics Dian Fu (Jira)
• 2026/08/27 Re: [PR] [hotfix][runtime][python] Close every component when an earlier close fails [flink-agents] via GitHub
• 2026/08/27 Re: [PR] [FLINK-39009] Support PostgreSQL unnest insert in dynamic table. [flink-connector-jdbc] via GitHub
• 2026/08/27 [jira] [Resolved] (FLINK-39889) Convert table sqlnode to operation Hao Li (Jira)
• 2026/08/27 [jira] [Assigned] (FLINK-39889) Convert table sqlnode to operation Hao Li (Jira)
• 2026/08/27 [jira] [Commented] (FLINK-39889) Convert table sqlnode to operation Hao Li (Jira)
• 2026/08/27 [jira] [Commented] (FLINK-38411) Array index overflow in enumerator with continuous file source Li Guo (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40495) Limit concurrent shared-state disposal to prevent JobManager I/O starvation Tianji Li (Jira)
• 2026/08/27 Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40232][table-runtime] Handle null rowtime in OutputConversionOperator [flink] via GitHub
• 2026/08/27 [jira] [Created] (FLINK-40484) Run UnalignedCheckpointTestBase with DefaultScheduler instead of skipping it under AdaptiveScheduler Rui Fan (Jira)
• 2026/08/27 Re: [PR] [FLINK-40482][runtime] Abort checkpoint when a task is FAILED or CANCELED [flink] via GitHub
• 2026/08/27 [jira] [Created] (FLINK-40489) Add UUID_V4() & UUID_V7() functions Ramin Gharib (Jira)
• 2026/08/27 [jira] [Updated] (FLINK-40486) Introduce the UUID logical type Ramin Gharib (Jira)
• 2026/08/27 [jira] [Resolved] (FLINK-40484) Run UnalignedCheckpointTestBase with DefaultScheduler instead of skipping it under AdaptiveScheduler Rui Fan (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40486) Introduce the UUID logical type Ramin Gharib (Jira)
• 2026/08/27 [jira] [Updated] (FLINK-40491) Extend BinaryVariant with primitive codes 17-20 Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40491) Decode/accessor support in BinaryVariant for codes 17-20 Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40485) FLIP 604: Complete VARIANT primitive coverage with UUID and timestamps Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40488) Comparison and ordering for UUID Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40493) VARIANT CAST for UUID (code 20) Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40494) Document UUID and extended VARIANT type Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40492) VARIANT CAST for TIME and nanosecond timestamps (17-19) Ramin Gharib (Jira)
• 2026/08/27 [jira] [Updated] (FLINK-40491) Extend BinaryVariant with primitive codes 17-20 Ramin Gharib (Jira)
• 2026/08/27 Re: [PR] [hotfix][runtime][python] Close every component when an earlier close fails [flink-agents] via GitHub
• 2026/08/27 [jira] [Created] (FLINK-40490) Runtime serialization and codegen for UUID Ramin Gharib (Jira)
• 2026/08/27 [jira] [Updated] (FLINK-40487) CAST between UUID and STRING / BINARY(16) Ramin Gharib (Jira)
• 2026/08/27 [jira] [Updated] (FLINK-40487) CAST between UUID and STRING / BINARY(16) Ramin Gharib (Jira)
• 2026/08/27 [jira] [Created] (FLINK-40487) CAST between UUID and STRING / BINARY(16) Ramin Gharib (Jira)
• 2026/08/27 Re: [PR] [FLINK-40484][tests] Run UnalignedCheckpointTestBase with the DefaultScheduler instead of skipping it under AdaptiveScheduler [flink] via GitHub
• 2026/08/27 [jira] [Assigned] (FLINK-40485) FLIP 604: Complete VARIANT primitive coverage with UUID and timestamps Ramin Gharib (Jira)
• 2026/08/27 [jira] [Resolved] (FLINK-40482) DefaultCheckpointPlanCalculator misclassifies FAILED/CANCELED tasks as finished Rui Fan (Jira)
• 2026/08/27 [PR] Fix Derby upgrade for Java 17 [flink-connector-jdbc] via GitHub
• 2026/08/27 Re: [PR] Fix Derby upgrade for Java 17 [flink-connector-jdbc] via GitHub
• 2026/08/27 [jira] [Commented] (FLINK-38411) Array index overflow in enumerator with continuous file source Simon Frei (Jira)
• 2026/08/27 [PR] [FLINK-39697] Support Flink 2.0.x and Pulsar Client 4.0.9 [flink-connector-pulsar] via GitHub
• 2026/08/27 Re: [PR] [DO_NOT_MERGE][FLINK-38544] Checkpointing during recovery enabled [flink] via GitHub
• 2026/08/27 Re: [PR] [DO_NOT_MERGE][FLINK-38544] Checkpointing during recovery disabled [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-38544][checkpoint] Support spilling for checkpointing during recovery [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40484][tests] Run UnalignedCheckpointTestBase with the DefaultScheduler instead of skipping it under AdaptiveScheduler [flink] via GitHub
• 2026/08/27 [jira] [Updated] (FLINK-40484) Run UnalignedCheckpointTestBase with DefaultScheduler instead of skipping it under AdaptiveScheduler ASF GitHub Bot (Jira)
• 2026/08/27 [PR] [FLINK-40484][tests] Run UnalignedCheckpointTestBase with the DefaultScheduler instead of skipping it under AdaptiveScheduler [flink] via GitHub
• 2026/08/27 [jira] [Updated] (FLINK-40484) Run UnalignedCheckpointTestBase with DefaultScheduler instead of skipping it under AdaptiveScheduler Rui Fan (Jira)
• 2026/08/27 Re: [PR] [released] Add Flink-Shaded 22.0 [flink-web] via GitHub
• 2026/08/27 [jira] [Comment Edited] (FLINK-26755) Cleanup inprogressfileRecoverable for FileSink on restoring Li Guo (Jira)
• 2026/08/27 [jira] [Commented] (FLINK-26755) Cleanup inprogressfileRecoverable for FileSink on restoring Li Guo (Jira)
• 2026/08/27 Re: [PR] [FLINK-40482][runtime] Abort checkpoint when a task is FAILED or CANCELED [flink] via GitHub
• 2026/08/27 Re: [D] [Discuss][API] Multimodal content parts in ChatMessage [flink-agents] via GitHub
• 2026/08/27 Re: [PR] [FLINK-36434][Connectors/Kafka] Create the KafkaConsumer lazily on the split fetcher thread [flink-connector-kafka] via GitHub
• 2026/08/27 Re: [D] [Discuss][API] Multimodal content parts in ChatMessage [flink-agents] via GitHub
• 2026/08/27 Re: [D] [Discuss][API] Multimodal content parts in ChatMessage [flink-agents] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/08/27 [jira] [Commented] (FLINK-40454) java.lang.NoSuchMethodError: '...Configuration.getInteger(..)' in FlinkConfigManager Dennis-Mircea Ciupitu (Jira)
• 2026/08/27 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40128][connector][static-source] Implement Topic integrity checks [flink-connector-kafka] via GitHub
• 2026/08/27 Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40218][core] Allow building a Variant from a token source [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40482][runtime] Abort checkpoint when a task is FAILED or CANCELED [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
• 2026/08/27 [jira] [Created] (FLINK-40483) Support batch Top-N optimization for ROW_NUMBER() Timo Theusner (Jira)
• 2026/08/27 Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40482][runtime] Abort checkpoint when a task is FAILED or CANCELED [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction [flink] via GitHub
• 2026/08/27 [jira] [Updated] (FLINK-40482) DefaultCheckpointPlanCalculator misclassifies FAILED/CANCELED tasks as finished ASF GitHub Bot (Jira)
• 2026/08/27 [PR] [FLINK-40482][runtime] Abort checkpoint when a task is FAILED or CANCELED [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
• 2026/08/27 [jira] [Created] (FLINK-40482) DefaultCheckpointPlanCalculator misclassifies FAILED/CANCELED tasks as finished Rui Fan (Jira)
• 2026/08/27 Re: [PR] [FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction [flink] via GitHub
• 2026/08/27 [jira] [Updated] (FLINK-40482) DefaultCheckpointPlanCalculator misclassifies FAILED/CANCELED tasks as finished Rui Fan (Jira)
• 2026/08/27 Re: [PR] [FLINK-40431][python] Add scalar UDF support to DataFrame API [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40431][python] Add scalar UDF support to DataFrame API [flink] via GitHub
• 2026/08/27 [jira] [Updated] (FLINK-40481) SHOW CREATE MATERIALIZED TABLE displays a future timestamp for FROM_NOW(<interval>) instead of past ASF GitHub Bot (Jira)
• 2026/08/27 [PR] [FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction [flink] via GitHub
• 2026/08/27 [jira] [Created] (FLINK-40481) SHOW CREATE MATERIALIZED TABLE displays a future timestamp for FROM_NOW(<interval>) instead of past Arvid Heise (Jira)
• 2026/08/27 Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/08/27 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/08/27 [jira] [Comment Edited] (FLINK-40197) Add sql bindings to DataFrame API Dian Fu (Jira)
• 2026/08/27 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/08/27 [jira] [Comment Edited] (FLINK-40197) Add sql bindings to DataFrame API Dian Fu (Jira)
• 2026/08/27 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/08/27 [jira] [Commented] (FLINK-40197) Add sql bindings to DataFrame API Dian Fu (Jira)
• 2026/08/27 Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink] via GitHub
• 2026/08/27 [jira] [Commented] (FLINK-23758) PyFlink __invert__ has wrong semantics Bettle (Jira)

• Earlier messages
• Later messages