issues  

Messages by Date

• 2026/10/03 Re: [PR] [FLINK-40664][tests] Ignore Freeing inactive slots log in JobIDLoggingITCase [flink] via GitHub
• 2026/10/03 Re: [PR] [FLINK-40776][table-runtime] Cache query-parameter pattern in PARSE_URL [flink] via GitHub
• 2026/10/03 [jira] [Comment Edited] (FLINK-40776) PARSE_URL compiles the query-parameter pattern on every row Utkarsh Vashishtha (Jira)
• 2026/10/03 [jira] [Updated] (FLINK-40776) PARSE_URL compiles the query-parameter pattern on every row ASF GitHub Bot (Jira)
• 2026/10/03 [PR] [FLINK-40776][table-runtime] Cache query-parameter pattern in PARSE_URL [flink] via GitHub
• 2026/10/03 Re: [PR] Add Flink Community Update for Q2 2026 [flink-web] via GitHub
• 2026/10/03 Re: [PR] [FLINK-40780][runtime] Make FORWARD-to-REBALANCE downgrade on parallelism mismatch configurable [flink] via GitHub
• 2026/10/03 Re: [PR] [FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/10/03 Re: [PR] [FLINK-30481][Connectors/AWS] Add AWS Glue Data Catalog implementation (FLIP-277) [flink-connector-aws] via GitHub
• 2026/10/03 Re: [PR] FLINK-40245 Wire parquet.page.size.row.check.min/max conf keys in FlinkParquetBui… [flink] via GitHub
• 2026/10/03 Re: [PR] [FLINK-30481][Connectors/AWS] Add AWS Glue Data Catalog implementation (FLIP-277) [flink-connector-aws] via GitHub
• 2026/10/03 Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
• 2026/10/03 [jira] [Commented] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered Kaustubh Butte (Jira)
• 2026/10/03 Re: [PR] [FLINK-40895][table] Use cache in code splitter [flink] via GitHub
• 2026/10/03 [jira] [Commented] (FLINK-40405) [FLINK-autoscaler] Add reason tags to `autoscaler.balanced` counter to distinguish genuinely balanced from blocked scaling Kaustubh Butte (Jira)
• 2026/10/03 [jira] [Resolved] (FLINK-40895) Make use cache in code splitter Sergey Nuyanzin (Jira)
• 2026/10/02 Re: [PR] [FLINK-29549]- Flink Glue Catalog integration [flink-connector-aws] via GitHub
• 2026/10/02 Re: [PR] [hotfix] Fix flaky tests [flink] via GitHub
• 2026/10/02 Re: [PR] [hotfix] Fix flaky tests [flink] via GitHub
• 2026/10/02 [jira] [Comment Edited] (FLINK-40293) Add UDF metric config options and instrument sync scalar and table UDF calls Peter Huang (Jira)
• 2026/10/02 [jira] [Comment Edited] (FLINK-40293) Add UDF metric config options and instrument sync scalar and table UDF calls Peter Huang (Jira)
• 2026/10/02 [jira] [Comment Edited] (FLINK-40293) Add UDF metric config options and instrument sync scalar and table UDF calls Peter Huang (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-40293) Add UDF metric config options and instrument sync scalar and table UDF calls Peter Huang (Jira)
• 2026/10/02 [jira] [Assigned] (FLINK-40293) Add UDF metric config options and instrument sync scalar and table UDF calls Peter Huang (Jira)
• 2026/10/02 Re: [PR] [FLINK-40293][table] Add UDF metric config options and instrument sync scalar and table UDF calls [flink] via GitHub
• 2026/10/02 [PR] [api][plan][runtime][java][python] Support bounded internal sub-agent batches [flink-agents] via GitHub
• 2026/10/02 [I] [Tech Debt][API][Integrations] Use DashScope naming consistently across public integration APIs [flink-agents] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40655][runtime] Fix flaky partition release test [flink] via GitHub
• 2026/10/02 [I] [Tech Debt][API][RunnerContext] Add a non-durable asynchronous execution API [flink-agents] via GitHub
• 2026/10/02 [I] [Tech Debt][API][Event] Enforce framework-owned lineage at the event emission boundary [flink-agents] via GitHub
• 2026/10/02 [I] [Tech Debt][API][ChatMessage] Add raw-bytes factory methods for media blocks [flink-agents] via GitHub
• 2026/10/02 [PR] [api][plan][java][python] Separate cross-language resource declarations from wrappers [flink-agents] via GitHub
• 2026/10/02 Re: [PR] [FLINK-39834] Fix Oracle UNISTR parsing with embedded concat operator [flink-cdc] via GitHub
• 2026/10/02 [I] [Tech Debt][API][Model Routing] Unify handling of runtime non-candidate selections [flink-agents] via GitHub
• 2026/10/02 [I] [Tech Debt][API][Skills] Validate source schemes against the target runtime before execution [flink-agents] via GitHub
• 2026/10/02 [I] [Tech Debt][API][ReActAgent] Support Skills directly in Java and Python constructors [flink-agents] via GitHub
• 2026/10/02 Re: [PR] [FLINK-39840][pipeline-connector/oracle] Fix Oracle pipeline table identifiers [flink-cdc] via GitHub
• 2026/10/02 Re: [PR] [FLINK-39841][oracle-cdc] Add option to skip analyze table before chunk planning [flink-cdc] via GitHub
• 2026/10/02 Re: [PR] [FLINK-39842][oracle-cdc] Support timestamp startup by resolving SCN [flink-cdc] via GitHub
• 2026/10/02 Re: [PR] [FLINK-39843][oracle-cdc] Support Oracle XStream streaming [flink-cdc] via GitHub
• 2026/10/02 Re: [PR] [FLINK-38262][table] describe connection operation [flink] via GitHub
• 2026/10/02 [jira] [Commented] (FLINK-38262) Convert connection sqlnode to operations Hao Li (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-34224) ChangelogStorageMetricsTest.testAttemptsPerUpload(ChangelogStorageMetricsTest timed out Rakesh kumar (Jira)
• 2026/10/02 Re: [PR] [FLINK-40904][runtime] Detect FORWARD parallelism mismatch with the actual consumer parallelism [flink] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-40904) FORWARD-to-REBALANCE downgrade compares producer parallelism with the number of subpartitions instead of the consumer parallelism ASF GitHub Bot (Jira)
• 2026/10/02 [PR] [FLINK-40904][runtime] Detect FORWARD parallelism mismatch with the actual consumer parallelism [flink] via GitHub
• 2026/10/02 [jira] [Created] (FLINK-40904) FORWARD-to-REBALANCE downgrade compares producer parallelism with the number of subpartitions instead of the consumer parallelism Rui Fan (Jira)
• 2026/10/02 Re: [PR] [FLINK-40895][table] Use cache in code splitter [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40808] Add PyPI publishing support for apache-flink-connector-aws [flink-connector-aws] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40808] Add PyPI publishing support for apache-flink-connector-aws [flink-connector-aws] via GitHub
• 2026/10/02 [jira] [Resolved] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-40670) MultiJoinSemanticTests[four-way-mixed-join-multi-key-types-shuffled] loses a row on release-2.3 Martijn Visser (Jira)
• 2026/10/02 Re: [PR] [BP-2.3][FLINK-40670][tests] Use different keys for different data [flink] via GitHub
• 2026/10/02 Re: [PR] [BP-2.2][FLINK-40670][tests] Use different keys for different data [flink] via GitHub
• 2026/10/02 [jira] [Commented] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances Martijn Visser (Jira)
• 2026/10/02 [jira] [Resolved] (FLINK-40504) FLIP-27 source never re-emits WatermarkStatus.ACTIVE after idleness unless its watermark strictly advances Martijn Visser (Jira)
• 2026/10/02 Re: [PR] [BP-2.2][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/10/02 Re: [PR] [BP-2.3][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40895][table] Use cache in code splitter [flink] via GitHub
• 2026/10/02 [jira] [Resolved] (FLINK-40761) Add AI disclosure to the flink-connector-prometheus PR template Rui Fan (Jira)
• 2026/10/02 [jira] [Resolved] (FLINK-40760) Add AI disclosure to the flink-connector-pulsar PR template Rui Fan (Jira)
• 2026/10/02 [jira] [Resolved] (FLINK-40762) Add a PR template with AI disclosure for flink-connector-hive Rui Fan (Jira)
• 2026/10/02 [jira] [Resolved] (FLINK-40755) Add a PR template with AI disclosure for flink-web Rui Fan (Jira)
• 2026/10/02 [jira] [Resolved] (FLINK-40773) Add a PR template with AI disclosure for flink-playgrounds Rui Fan (Jira)
• 2026/10/02 [jira] [Resolved] (FLINK-40759) Add a PR template with AI disclosure for flink-connector-shared-utils Rui Fan (Jira)
• 2026/10/02 [jira] [Resolved] (FLINK-40775) Add a PR template with AI disclosure for flink-ci-docker Rui Fan (Jira)
• 2026/10/02 [jira] [Resolved] (FLINK-40754) Add a PR template with AI disclosure for flink-docker Rui Fan (Jira)
• 2026/10/02 [I] [Bug] [runtime][python] ChatMessage argument digests change across processes and re-execute persisted durable calls [flink-agents] via GitHub
• 2026/10/02 [I] [Bug] [runtime][python] Successful durable calls swallow Java state persistence failures [flink-agents] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/10/02 [jira] [Created] (FLINK-40903) Add source host info in TM disconnect error Peter Huang (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-40830) Reuse jdk getBytes for StringUtf8Utils Sergey Nuyanzin (Jira)
• 2026/10/02 [jira] [Resolved] (FLINK-40830) Reuse jdk getBytes for StringUtf8Utils Sergey Nuyanzin (Jira)
• 2026/10/02 Re: [PR] [FLINK-40830][table] Reuse java's getBytes in StringUtf8Utils [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40833] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40830][table] Reuse java's getBytes in StringUtf8Utils [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40368][table] Deduplicate output should only be insert-only when ordered by time attribute [flink] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-40833) JobManager and TaskManager logs are rolled at startup with log4j 2.25.2 and later ASF GitHub Bot (Jira)
• 2026/10/02 [PR] [FLINK-40833] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction [flink] via GitHub
• 2026/10/02 [jira] [Commented] (FLINK-13871) Consolidate isRunning, canceled, isFinished fields in StreamTask and SourceStreamTask Yuepeng Pan (Jira)
• 2026/10/02 [jira] [Created] (FLINK-40902) LATERAL SNAPSHOT join wrongly rejected when a local filter targets the join key column Fabian Hueske (Jira)
• 2026/10/02 [jira] [Assigned] (FLINK-40902) LATERAL SNAPSHOT join wrongly rejected when a local filter targets the join key column Fabian Hueske (Jira)
• 2026/10/02 Re: [PR] [FLINK-40871][table] Avoid the UTF-8 round trip when casting strings and decimals to VARIANT [flink] via GitHub
• 2026/10/02 [jira] [Assigned] (FLINK-40890) LATERAL SNAPSHOT build side passes TRY_RESOLVE with non-deterministic columns Fabian Hueske (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created Martijn Visser (Jira)
• 2026/10/02 [jira] [Assigned] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created Martijn Visser (Jira)
• 2026/10/02 Re: [PR] [FLINK-40871][table] Avoid the UTF-8 round trip when casting strings and decimals to VARIANT [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/10/02 [jira] [Created] (FLINK-40901) JSON functions return the result of a previous row when JSON_TYPE or JSON_LENGTH is skipped Moritz Manner (Jira)
• 2026/10/02 Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40368][table] Deduplicate output should only be insert-only when ordered by time attribute [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40627][clients] Protect against partially fetched or incorrect artifacts [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40368][table-planner] Fix deduplication changelog inference [flink] via GitHub
• 2026/10/02 [PR] [FLINK-40368][table] Deduplicate output should only be insert-only when ordered by time attribute [flink] via GitHub
• 2026/10/02 Re: [PR] Bump brace-expansion from 1.1.18 to 1.1.21 in /flink-runtime-web/web-dashboard [flink] via GitHub
• 2026/10/02 [PR] [FLINK-40627][clients] [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40871][table] Avoid the UTF-8 round trip when casting strings and decimals to VARIANT [flink] via GitHub
• 2026/10/02 [jira] [Assigned] (FLINK-40368) Deduplicate output should only be insert-only when ordered by time attribute Gustavo de Morais (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts ASF GitHub Bot (Jira)
• 2026/10/02 Re: [PR] [FLINK-40871][table] Avoid the UTF-8 round trip when casting strings and decimals to VARIANT [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40871][table] Avoid the UTF-8 round trip when casting strings and decimals to VARIANT [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40871][table] Avoid the UTF-8 round trip when casting strings and decimals to VARIANT [flink] via GitHub
• 2026/10/02 [jira] [Commented] (FLINK-40708) Support ValueView in PTFs Timo Walther (Jira)
• 2026/10/02 Re: [PR] [FLINK-40708][table] Add semantic test for ValueView state in onTimer [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-28737) NDU analyzer skips the Calc condition once the upsert key covers the sink key Martijn Visser (Jira)
• 2026/10/02 Re: [PR] [FLINK-40897][table] `TIMESTAMPDIFF` returns wrong results and fails for `TIME` [flink] via GitHub
• 2026/10/02 [jira] [Created] (FLINK-40900) NDU analyzer does not check predicates pushed into a CDC source Martijn Visser (Jira)
• 2026/10/02 Re: [PR] [FLINK-40882][table] Janino should compile same class only once [flink] via GitHub
• 2026/10/02 [jira] [Created] (FLINK-40899) ON CONFLICT validation masks the NDU error for lookup joins Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-35341) Retraction stop working with Clock dependent function in Filter Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-28737) NDU analyzer skips the Calc condition once the upsert key covers the sink key Martijn Visser (Jira)
• 2026/10/02 [jira] [Comment Edited] (FLINK-28737) NDU analyzer skips the Calc condition once the upsert key covers the sink key Martijn Visser (Jira)
• 2026/10/02 [jira] [Comment Edited] (FLINK-28737) NDU analyzer skips the Calc condition once the upsert key covers the sink key Martijn Visser (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-28737) NDU analyzer skips the Calc condition once the upsert key covers the sink key Martijn Visser (Jira)
• 2026/10/02 [jira] [Created] (FLINK-40898) TRY_RESOLVE wrongly rejects non-deterministic filters inside ChangelogNormalize Martijn Visser (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-28737) NDU analyzer skips the Calc condition once the upsert key covers the sink key Martijn Visser (Jira)
• 2026/10/02 Re: [PR] [FLINK-40871][table] Avoid the UTF-8 round trip when casting strings and decimals to VARIANT [flink] via GitHub
• 2026/10/02 [jira] [Assigned] (FLINK-28737) FlinkRelMdUpsertKeys should consider the case when the condition of a calc node is non-deterministic Martijn Visser (Jira)
• 2026/10/02 [jira] [Assigned] (FLINK-40892) Stale IGNORE override on the changelog PTF tests Gustavo de Morais (Jira)
• 2026/10/02 Re: [PR] [FLINK-40855][filesystems] Shut down STS clients after S3 delegation-token acquisition [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40830][table] Reuse java's getBytes in StringUtf8Utils [flink] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-40871) Avoid the UTF-8 round trip when casting strings and decimals to VARIANT ASF GitHub Bot (Jira)
• 2026/10/02 [PR] [FLINK-40871][table] Avoid the UTF-8 round trip when casting strings and decimals to VARIANT [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40897][table] `TIMESTAMPDIFF` returns wrong results and fails for `TIME` [flink] via GitHub
• 2026/10/02 [PR] [FLINK-40405] Add reason tags to the autoscaler.balanced counter [flink-kubernetes-operator] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-40407) [FLINK-autoscaler] Add reason tags to `autoscaler.scalings` counter to explain why scaling was triggered ASF GitHub Bot (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-40405) [FLINK-autoscaler] Add reason tags to `autoscaler.balanced` counter to distinguish genuinely balanced from blocked scaling ASF GitHub Bot (Jira)
• 2026/10/02 [PR] [FLINK-40407] Add reason tags to the autoscaler.scalings counter [flink-kubernetes-operator] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/02 [jira] [Commented] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created Alexandru (Jira)
• 2026/10/02 Re: [PR] [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API [flink] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-40826) Support casting constructed types to VARIANT ASF GitHub Bot (Jira)
• 2026/10/02 [PR] [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40852][table] Return NULL from PARSE_JSON and TRY_PARSE_JSON for NULL allowDuplicateKeys [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-28737][table-planner] Check Calc filter on updating input in the NDU analyzer [flink] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-39954) SinkV2ITCase over-asserts commit multiplicity under unaligned checkpoints Martijn Visser (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-40885) Support LATERAL SNAPSHOT join in the Table API ASF GitHub Bot (Jira)
• 2026/10/02 [PR] [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40897][table] TIMESTAMPDIFF returns wrong results and fails for TIME operands [flink] via GitHub
• 2026/10/02 [jira] [Commented] (FLINK-35341) Retraction stop working with Clock dependent function in Filter Martijn Visser (Jira)
• 2026/10/02 Re: [PR] [FLINK-40470] Record spec before deployment attempt in savepoint redeploy [flink-kubernetes-operator] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-28737) FlinkRelMdUpsertKeys should consider the case when the condition of a calc node is non-deterministic ASF GitHub Bot (Jira)
• 2026/10/02 [PR] [FLINK-28737][table-planner] Check Calc filter on updating input in the NDU analyzer [flink] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-40897) TIMESTAMPDIFF returns wrong results and fails with scala.MatchError for TIME operands ASF GitHub Bot (Jira)
• 2026/10/02 [PR] [FLINK-40897][table] TIMESTAMPDIFF returns wrong results and fails for TIME operands [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/02 [jira] [Commented] (FLINK-40123) heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh Martijn Visser (Jira)
• 2026/10/02 [jira] [Created] (FLINK-40893) Update the determinism page for the current state of the NDU handling Martijn Visser (Jira)
• 2026/10/02 [PR] [FLINK-40896][table]Deduplicate keep first implementation [flink] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-40896) FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF ASF GitHub Bot (Jira)
• 2026/10/02 Re: [PR] [FLINK-40708][table] Add semantic test for ValueView state in onTimer [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40470] Record spec before deployment attempt in savepoint redeploy [flink-kubernetes-operator] via GitHub
• 2026/10/02 [jira] [Created] (FLINK-40897) TIMESTAMPDIFF returns wrong results and fails with scala.MatchError for TIME operands sepuri sai krishna (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-40897) TIMESTAMPDIFF returns wrong results and fails with scala.MatchError for TIME operands sepuri sai krishna (Jira)
• 2026/10/02 [PR] [FLINK-40708][table] Add semantic test for ValueView state in onTimer [flink] via GitHub
• 2026/10/02 [jira] [Comment Edited] (FLINK-40805) FLIP-612: Native XML Functions for Flink SQL Moritz Manner (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-40470) Savepoint redeploy loops forever when the deployment attempt fails Robert Metzger (Jira)
• 2026/10/02 Re: [PR] [FLINK-40895][table] Use cache in code splitter [flink] via GitHub
• 2026/10/02 [PR] [FLINK-40895][table] Use cache in code splitter [flink] via GitHub
• 2026/10/02 [jira] [Created] (FLINK-40896) Add built-in DEDUPLICATE_KEEP_FIRST PTF Gustavo de Morais (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-40896) FLIP-614: Add built-in DEDUPLICATE_KEEP_FIRST PTF Gustavo de Morais (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-40805) FLIP-612: Native XML Functions for Flink SQL Mika Naylor (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-32212) Job restarting indefinitely after an IllegalStateException from BlobLibraryCacheManager Robert Metzger (Jira)
• 2026/10/02 Re: [PR] [FLINK-40830][table] Reuse java's getBytes in StringUtf8Utils [flink] via GitHub
• 2026/10/02 [jira] [Created] (FLINK-40895) Make use cache in code splitter Sergey Nuyanzin (Jira)
• 2026/10/02 Re: [PR] [FLINK-40470] Record spec before deployment attempt in savepoint redeploy [flink-kubernetes-operator] via GitHub
• 2026/10/02 [jira] [Updated] (FLINK-40895) Make use cache in code splitter ASF GitHub Bot (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-40627) Partially fetched user artifacts are reused on subsequent starts Robert Metzger (Jira)
• 2026/10/02 Re: [PR] [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty [flink] via GitHub
• 2026/10/02 [jira] [Resolved] (FLINK-40602) JobManager silently omits running jobs whose JobMaster fails or times out on GET /jobs/overview Robert Metzger (Jira)
• 2026/10/02 [PR] [FLINK-40888][table] Improve MATCH_RECOGNIZE performance: lazily eval… [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40602][runtime] JobManager silently omits running jobs whose JobMaster fails or times out on GET /jobs/overview [flink] via GitHub
• 2026/10/02 [jira] [Commented] (FLINK-40805) FLIP-612: Native XML Functions for Flink SQL Moritz Manner (Jira)
• 2026/10/02 [jira] [Created] (FLINK-40891) NDU plan visitor does not propagate determinism requirements through PTFs without REQUIRE_UPDATE_BEFORE Martijn Visser (Jira)
• 2026/10/02 Re: [PR] [FLINK-40808] Add PyPI publishing support for apache-flink-connector-aws [flink-connector-aws] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40830][table] Reuse java's getBytes in StringUtf8Utils [flink] via GitHub
• 2026/10/02 Re: [PR] [FLINK-40882][table] Janino should compile same class only once [flink] via GitHub
• 2026/10/02 [jira] [Commented] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline Martijn Visser (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-40888) Improve MATCH_RECOGNIZE performance: lazily evaluate DEFINE aggregations and avoid extracting all matched pattern events ASF GitHub Bot (Jira)
• 2026/10/02 [jira] [Updated] (FLINK-28737) FlinkRelMdUpsertKeys should consider the case when the condition of a calc node is non-deterministic Martijn Visser (Jira)
• 2026/10/02 [jira] [Comment Edited] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline Martijn Visser (Jira)
• 2026/10/02 [jira] [Comment Edited] (FLINK-27849) Harden correctness for non-deterministic updates present in the changelog pipeline Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-24666) Add job level "table.exec.state-stale.error-handling" option and apply to related stateful stream operators Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-29225) Delete message incorrectly ignored in SinkUpsertMaterializer Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-29967) Optimize determinism requirements from sink node with considering that SinkUpsertMaterializer already supports upsertKey Martijn Visser (Jira)
• 2026/10/02 [jira] [Commented] (FLINK-28737) FlinkRelMdUpsertKeys should consider the case when the condition of a calc node is non-deterministic Martijn Visser (Jira)
• 2026/10/02 [jira] [Created] (FLINK-40894) Expose counters for unmatched retractions in SinkUpsertMaterializer and KeyedLookupJoinWrapper Martijn Visser (Jira)
• 2026/10/02 [jira] [Created] (FLINK-40892) Stale IGNORE override on the changelog PTF tests Martijn Visser (Jira)
• 2026/10/02 [jira] [Created] (FLINK-40890) LATERAL SNAPSHOT build side passes TRY_RESOLVE with non-deterministic columns Martijn Visser (Jira)

• Earlier messages
• Later messages