issues  

Messages by Date

• 2026/08/29 [D] Design proposal for #1066: dry-run / replay via savepoints [flink-agents] via GitHub
• 2026/08/28 Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents] via GitHub
• 2026/08/28 Re: [I] [Feature] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/08/28 Re: [D] Planning Flink Agents 0.4 [flink-agents] via GitHub
• 2026/08/28 Re: [I] [Feature] Add Agent Trace recording to Event Log [flink-agents] via GitHub
• 2026/08/28 [I] [Feature] Add Agent Trace recording to Event Log [flink-agents] via GitHub
• 2026/08/28 Re: [I] [Feature] Dry-run / replay mode for validating agent behavior against production-shaped state before deploying [flink-agents] via GitHub
• 2026/08/28 Re: [D] Planning Flink Agents 0.4 [flink-agents] via GitHub
• 2026/08/28 Re: [I] [Feature] Human-in-the-loop approval as a first-class, checkpointed Action primitive [flink-agents] via GitHub
• 2026/08/28 Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/08/28 Re: [PR] [integrations][java][python] Update stale Anthropic default model to claude-sonnet-4-5 [flink-agents] via GitHub
• 2026/08/28 Re: [PR] [integrations][java][python] Update stale Anthropic default model to claude-sonnet-4-5 [flink-agents] via GitHub
• 2026/08/28 [I] [Feature] Per-agent token/cost budget guardrail (enforcement, not just reporting) [flink-agents] via GitHub
• 2026/08/28 [I] [Feature] Dry-run / replay mode for validating agent behavior against production-shaped state before deploying [flink-agents] via GitHub
• 2026/08/28 [I] [Feature] Human-in-the-loop approval as a first-class, checkpointed Action primitive [flink-agents] via GitHub
• 2026/08/28 [I] [Feature] Cross-language (Java/Python) agent spec parity test harness [flink-agents] via GitHub
• 2026/08/28 [PR] [integrations][java][python] Update stale Anthropic default model to claude-sonnet-4-5 [flink-agents] via GitHub
• 2026/08/28 Re: [PR] [FLINK-39438][MaxCompute] Add support for sink operation types in MaxCompute options [flink-cdc] via GitHub
• 2026/08/28 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/08/28 [jira] [Resolved] (FLINK-40498) Adjust tests to call SNAPSHOT without TABLE keyword Fabian Hueske (Jira)
• 2026/08/28 [jira] [Updated] (FLINK-36605) Upgrade Debezium version to 2.7.x ASF GitHub Bot (Jira)
• 2026/08/28 [PR] [FLINK-36605] Bump debezium to last 2.x version [flink-cdc] via GitHub
• 2026/08/28 [PR] [FLINK-40507] Upgrade paimon to 2.0.0 [flink-cdc] 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-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
• 2026/08/28 [PR] [hotfix] Remove redundant autoscaler Plugin discovery [flink-kubernetes-operator] via GitHub
• 2026/08/28 [I] [Umbrella] Pluggable model routing (MODEL_ROUTER): delivery status, Python parity, documentation, and follow-ups [flink-agents] via GitHub
• 2026/08/28 [jira] [Commented] (FLINK-40467) Flink 2.3 Application Mode managed by the kubernetes operator can start without submitting the new job after savepoint redeploy Dale Lane (Jira)
• 2026/08/28 Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction [flink] via GitHub
• 2026/08/28 [jira] [Updated] (FLINK-40507) upgrade paimon to 2.0.0 ASF GitHub Bot (Jira)
• 2026/08/28 [jira] [Updated] (FLINK-40467) Flink 2.3 Application Mode managed by the kubernetes operator can start without submitting the new job after savepoint redeploy ASF GitHub Bot (Jira)
• 2026/08/28 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/08/28 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/08/28 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] 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-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/08/28 Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• 2026/08/28 Re: [PR] [FLINK-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40422][python] Add slicing APIs to DataFrame API [flink] via GitHub
• 2026/08/28 [jira] [Commented] (FLINK-40463) Widen JSON_VALUE and JSON_QUERY RETURNING type support Nithish (Jira)
• 2026/08/28 [jira] [Commented] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 Sylwester Lachiewicz (Jira)
• 2026/08/28 Re: [PR] [FLINK-40444][table-common] Preserve attribute order in OBJECT_UPDATE [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink] via GitHub
• 2026/08/28 [jira] [Commented] (FLINK-20578) Cannot create empty array using ARRAY[] Nithish (Jira)
• 2026/08/28 [PR] [FLINK-40467] Randomise application result store paths [flink-kubernetes-operator] via GitHub
• 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-33484][Connectors/Kafka] Fix offsets committed to Kafka [flink-connector-kafka] via GitHub
• 2026/08/28 [jira] [Resolved] (FLINK-40241) Support VARIANT as column type in the 'raw' format Sergey Nuyanzin (Jira)
• 2026/08/28 [jira] [Commented] (FLINK-40121) Update Flink Connector Kafka to use Flink 2.3 James Kan (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40507) upgrade paimon to 2.0.0 peiyu (Jira)
• 2026/08/28 Re: [PR] [FLINK-40506][s3] Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies [flink] via GitHub
• 2026/08/28 [jira] [Updated] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies Gabor Somogyi (Jira)
• 2026/08/28 Re: [PR] [FLINK-40486][table] Introduce the UUID logical type [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40506][s3] Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies [flink] via GitHub
• 2026/08/28 [PR] [hotfix] Replace deprecated Flink, JOSDK, and fabric8 APIs [flink-kubernetes-operator] via GitHub
• 2026/08/28 Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink] via GitHub
• 2026/08/28 [PR] [FLINK-40506][s3] Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies [flink] via GitHub
• 2026/08/28 [jira] [Updated] (FLINK-40486) Introduce the UUID logical type ASF GitHub Bot (Jira)
• 2026/08/28 [jira] [Updated] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies ASF GitHub Bot (Jira)
• 2026/08/28 [PR] [FLINK-40486][table] Introduce the UUID logical type [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] [FLINK-40431][python] Add scalar UDF support 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 [jira] [Closed] (FLINK-40366) INSERT INTO with a column list or static partition fails for set-semantic PTFs Gustavo de Morais (Jira)
• 2026/08/28 Re: [PR] [FLINK-40431][python] Add scalar UDF support to DataFrame API [flink] via GitHub
• 2026/08/28 [jira] [Commented] (FLINK-40241) Support VARIANT as column type in the 'raw' format Sergey Nuyanzin (Jira)
• 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-40431][python] Add scalar UDF support to DataFrame API [flink] via GitHub
• 2026/08/28 Re: [PR] [FLINK-39837] Reassign retained dynamic Kafka offsets upon readd [flink-connector-kafka] 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-40497][table] Allow materialized tables to default to ON CONFLICT DO ERROR [flink] via GitHub
• 2026/08/28 [jira] [Updated] (FLINK-40497) Allow materialized tables to default to ON CONFLICT DO ERROR ASF GitHub Bot (Jira)
• 2026/08/28 Re: [PR] [FLINK-40497][table] Allow materialized tables to default to ON CONFLICT DO ERROR [flink] via GitHub
• 2026/08/28 [jira] [Assigned] (FLINK-40505) SourceCoordinator never removes failed or reset subtasks from watermark-alignment aggregation Martijn Visser (Jira)
• 2026/08/28 [PR] [FLINK-40497][table] Allow materialized tables to default to ON CONFLICT DO ERROR [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-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies Gabor Somogyi (Jira)
• 2026/08/28 [jira] [Created] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies Gabor Somogyi (Jira)
• 2026/08/28 [jira] [Assigned] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies Gabor Somogyi (Jira)
• 2026/08/28 [PR] [FLINK-40505][runtime] Prune failed subtasks from watermark alignment [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] [Commented] (FLINK-40197) Add sql bindings to DataFrame API Federico Dolce (Jira)
• 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

• Earlier messages
• Later messages