issues  

Messages by Date

• 2026/08/30 [jira] [Created] (FLINK-40511) Track and speed up slow integration tests (KafkaSinkITCase and friends) Sylwester Lachiewicz (Jira)
• 2026/08/30 Re: [PR] [FLINK-40139] Add default JUnit test timeout to fail hung tests fast [flink-connector-kafka] via GitHub
• 2026/08/30 Re: [PR] [api][runtime][java][python] Require HTTPS and add digest pinning for URL skill sources [flink-agents] via GitHub
• 2026/08/30 Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
• 2026/08/30 Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
• 2026/08/30 [PR] [hotfix][opensearch3] Converge HttpClient 5.6.3 dependency [flink-connector-opensearch] via GitHub
• 2026/08/30 [jira] [Updated] (FLINK-40510) Use Apache Parent POM 39 ASF GitHub Bot (Jira)
• 2026/08/30 Re: [PR] [FLINK-40510][build] Bump Apache Parent pom to 39 [flink] via GitHub
• 2026/08/30 Re: [PR] [FLINK-40422][python] Add slicing APIs to DataFrame API [flink] via GitHub
• 2026/08/30 [jira] [Created] (FLINK-40510) Use Apache Parent POM 39 Sergey Nuyanzin (Jira)
• 2026/08/30 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/08/30 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/08/30 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/08/30 Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink] via GitHub
• 2026/08/30 Re: [PR] [hotfix][opensearch3] Converge HttpClient 5.6.3 dependency [flink-connector-opensearch] via GitHub
• 2026/08/30 Re: [I] [Bug][security][skills] Bound download and extraction size for URL skill sources [flink-agents] via GitHub
• 2026/08/30 Re: [PR] [hotfix][runtime] Fix getOrinalTypeSerializerSnapshot typo [flink] via GitHub
• 2026/08/30 [jira] [Commented] (FLINK-39586) CombinedWatermarkStatus.updateCombinedWatermark() fails to mark idle when partialWatermarks is empty Efrat Levitan (Jira)
• 2026/08/30 Re: [PR] [FLINK-39977][runtime] Recovery of merged channel state handles [flink] via GitHub
• 2026/08/30 Re: [PR] [tools][test][e2e] Make the bats suite fail on assertions that stop holding [flink-agents] via GitHub
• 2026/08/30 Re: [I] [Tech Debt] The tools script suite loses failures and coverage at its boundary with install.sh [flink-agents] via GitHub
• 2026/08/30 Re: [PR] [integrations][anthropic] Stop sending rejected sampling parameters [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [integrations][anthropic] Stop sending rejected sampling parameters [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [integrations][anthropic] Stop sending rejected sampling parameters [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [FLINK-39283][Formats/avro] Upgrade `org.apache.avro:avro` to 1.12.1 [flink] via GitHub
• 2026/08/29 Re: [PR] [FLINK-39283][Formats/avro] Upgrade `org.apache.avro:avro` to 1.12.1 [flink] via GitHub
• 2026/08/29 Re: [PR] [integrations][anthropic] Update the stale default model to claude-sonnet-4-5 [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [integrations][java][python] Apply Ollama native structured output [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [integrations][java][python] Apply Ollama native structured output [flink-agents] via GitHub
• 2026/08/29 Re: [I] [Feature] Apply structured output to an agent's final output only [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [runtime][api] Scope long-term memory operations to the action that obtained the memory set [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [runtime][api] Scope long-term memory operations to the action that obtained the memory set [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [runtime][api] Scope long-term memory operations to the action that obtained the memory set [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
• 2026/08/29 Re: [PR] [hotfix][runtime] Fix getOrinalTypeSerializerSnapshot typo [flink] via GitHub
• 2026/08/29 Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
• 2026/08/29 [PR] [hotfix][runtime] Fix getOrinalTypeSerializerSnapshot typo [flink] via GitHub
• 2026/08/29 Re: [PR] [FLINK-38477][runtime] Add FINISHED watermark status to support proper watermark aggregation [flink] via GitHub
• 2026/08/29 Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
• 2026/08/29 [I] [Bug][security][skills] Bound download and extraction size for URL skill sources [flink-agents] via GitHub
• 2026/08/29 Re: [I] [Bug][security][skills] Protect URL skill sources with secure transport and integrity verification [flink-agents] via GitHub
• 2026/08/29 [PR] [plan][runtime] Do not retry or persist interrupted chat calls on cancellation [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [FLINK-40172][table-runtime] Support processing-time early fire on a row-time interval join [flink] via GitHub
• 2026/08/29 Re: [PR] [FLINK-40173][table-planner] Add restore coverage for early-fire interval join [flink] via GitHub
• 2026/08/29 [jira] [Updated] (FLINK-40173) Add restore coverage for early-fire interval join ASF GitHub Bot (Jira)
• 2026/08/29 [PR] [FLINK-40173][table-planner] Add restore coverage for early-fire interval join [flink] via GitHub
• 2026/08/29 Re: [PR] [FLINK-40172][table-runtime] Support processing-time early fire on a row-time interval join [flink] via GitHub
• 2026/08/29 Re: [PR] Flink Kubernetes Operator 1.16.0 [flink-web] via GitHub
• 2026/08/29 [jira] [Created] (FLINK-40509) Move operator defaults out of the Helm chart so config.yaml carries only user-supplied content Gerk Elznik (Jira)
• 2026/08/29 Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• 2026/08/29 Re: [PR] fix(planner): add missing flink-table-code-splitter test dependency [flink] via GitHub
• 2026/08/29 Re: [PR] [FLINK-40478][runtime-web] Log effective HistoryServer configuration at startup [flink] via GitHub
• 2026/08/29 Re: [PR] [FLINK-40503][core] Document effective idleness detection timing [flink] via GitHub
• 2026/08/29 [jira] [Closed] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies Gabor Somogyi (Jira)
• 2026/08/29 [jira] [Commented] (FLINK-40506) Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies Gabor Somogyi (Jira)
• 2026/08/29 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/29 Re: [PR] [hotfix][docs] Fix AzureTableConfiguration class name casing in Azure Table Storage doc [flink] via GitHub
• 2026/08/29 [PR] [hotfix][docs] Fix AzureTableConfiguration class name casing in Azure Table Storage doc [flink] via GitHub
• 2026/08/29 [PR] Db2 pipeline [flink-cdc] via GitHub
• 2026/08/29 Re: [PR] Db2 pipeline [flink-cdc] via GitHub
• 2026/08/29 Re: [PR] [Feature][api][runtime] Support auto resolve memory reference for passing data across actions. [flink-agents] via GitHub
• 2026/08/29 [jira] [Created] (FLINK-40508) Support DB2 pipeline connector suntectec (Jira)
• 2026/08/29 Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [FLINK-39977][runtime] Recovery of merged channel state handles [flink] via GitHub
• 2026/08/29 Re: [D] [Discussion] Memory Observation Capability Design [flink-agents] via GitHub
• 2026/08/29 Re: [D] [Feature] Per-Event-Type Configurable Log Levels for Event Log [flink-agents] via GitHub
• 2026/08/29 Re: [D] Introduce YAML API [flink-agents] via GitHub
• 2026/08/29 Re: [D] Agent Skills Integration Design [flink-agents] via GitHub
• 2026/08/29 [jira] [Updated] (FLINK-39977) Recovery of merged channel state in Unified File Merging Framework ASF GitHub Bot (Jira)
• 2026/08/29 [PR] [FLINK-39977][runtime] Recovery of merged channel state handles [flink] via GitHub
• 2026/08/29 Re: [PR] [FLINK-40397][mysql] Add binlog position lag metrics for MySQL binlog reader [flink-cdc] via GitHub
• 2026/08/29 [I] [Bug][runtime] Do not retry or persist interrupted chat calls during job cancellation [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [runtime][python] Release bridge-owned Pemja objects during cleanup [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [runtime][plan][python] Add built-in operational metrics [flink-agents] via GitHub
• 2026/08/29 Re: [PR] [runtime][plan][python] Add built-in operational metrics [flink-agents] via GitHub
• 2026/08/29 [PR] [FLINK-39218] Add CLI tool to manage lingering Kafka transactions [flink-connector-kafka] via GitHub
• 2026/08/29 Re: [I] [Feature] Dry-run / replay mode for validating agent behavior against production-shaped state before deploying [flink-agents] via GitHub
• 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

• Earlier messages
• Later messages