issues  

Messages by Thread

• • [jira] [Commented] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser (Jira)
• [jira] [Created] (FLINK-40461) Add config option for labels on operator generated events Jira
• [PR] Add config option for labels on operator generated events [flink-kubernetes-operator] via GitHub
• [PR] [FLINK-40179] Support windowed states in state catalog [flink] via GitHub
  • Re: [PR] [FLINK-40179] Support windowed states in state catalog [flink] via GitHub
• [jira] [Updated] (FLINK-40179) Support windowed states in state catalog ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40241) Support VARIANT as column type in the 'raw' format ASF GitHub Bot (Jira)
• [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
  • Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink] via GitHub
• [jira] [Created] (FLINK-40460) Upgrade archive-producing Maven plugins to reproducible-capable versions Martijn Visser (Jira)
• Re: [I] [Feature] Track token usage metrics for embedding models [flink-agents] via GitHub
• Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink] via GitHub
  • Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink] via GitHub
  • Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink] via GitHub
  • Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink] via GitHub
  • Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink] via GitHub
  • Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink] via GitHub
• Re: [I] [Feature] [integration] Integrate built-in IBM watsonx.ai chat model [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x ASF GitHub Bot (Jira)
  • [jira] [Updated] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser (Jira)
  • [jira] [Updated] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser (Jira)
• [PR] [FLINK-40459][build] Bump Maven from 3.8.6 to 3.9.16 [flink] via GitHub
  • Re: [PR] [FLINK-40459][build] Bump Maven from 3.8.6 to 3.9.16 [flink] via GitHub
  • Re: [PR] [FLINK-40459][build] Bump Maven from 3.8.6 to 3.9.16 [flink] via GitHub
  • Re: [PR] [FLINK-40459][build] Bump Maven from 3.8.6 to 3.9.16 [flink] via GitHub
  • Re: [PR] [FLINK-40459][build] Bump Maven from 3.8.6 to 3.9.16 [flink] via GitHub
• [jira] [Updated] (FLINK-30252) Publish flink-shaded pom Sergey Nuyanzin (Jira)
• [PR] [released] Add Flink-Shaded 22.0 [flink-web] via GitHub
  • Re: [PR] [released] Add Flink-Shaded 22.0 [flink-web] via GitHub
  • Re: [PR] [released] Add Flink-Shaded 22.0 [flink-web] via GitHub
• Re: [I] [Bug] Refresh Python import state when Flink replaces dependency directories [flink-agents] via GitHub
• [jira] [Created] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser (Jira)
• [jira] [Closed] (FLINK-40178) Keyed state cataloging integration test Gyula Fora (Jira)
• [jira] [Closed] (FLINK-40177) Support reading Keyed and Flattened Keyed states in StateCatalog Gyula Fora (Jira)
• [jira] [Closed] (FLINK-40176) Introduce basic StateCatalog functionality Gyula Fora (Jira)
• [jira] [Assigned] (FLINK-40381) Fix thread leak in Elasticsearch8AsyncWriter by closing HTTP transport on sink close Wenjin Xie (Jira)
• Re: [PR] [runtime][api] Scope long-term memory operations to the action that obtained the memory set [flink-agents] via GitHub
  • Re: [PR] [runtime][api] Scope long-term memory operations to the action that obtained the memory set [flink-agents] via GitHub
  • Re: [PR] [runtime][api] Scope long-term memory operations to the action that obtained the memory set [flink-agents] via GitHub
  • Re: [PR] [runtime][api] Scope long-term memory operations to the action that obtained the memory set [flink-agents] via GitHub
  • Re: [PR] [runtime][api] Scope long-term memory operations to the action that obtained the memory set [flink-agents] via GitHub
  • Re: [PR] [runtime][api] Scope long-term memory operations to the action that obtained the memory set [flink-agents] via GitHub
• [PR] [FLINK-XXXXX][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
  • Re: [PR] [FLINK-XXXXX][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
  • Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
  • Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink] via GitHub
• [jira] [Updated] (FLINK-40458) Shade commons-lang and commons-lang3 in flink-sql-connector-hive ASF GitHub Bot (Jira)
• [PR] [FLINK-40458][hive] Shade commons-lang dependencies [flink-connector-hive] via GitHub
  • Re: [PR] [FLINK-40458][hive] Shade commons-lang dependencies [flink-connector-hive] via GitHub
• [jira] [Created] (FLINK-40458) Shade commons-lang and commons-lang3 in flink-sql-connector-hive liting liu (Jira)
• Re: [PR] [FLINK-39889][table] Thread USING CONNECTION clause into CatalogTable and CreateTableOperation [flink] via GitHub
  • Re: [PR] [FLINK-39889][table] Thread USING CONNECTION clause into CatalogTable and CreateTableOperation [flink] via GitHub
• [jira] [Commented] (FLINK-40406) CI: Maven build has no retry on transient Central failures, causing spurious PR failures Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-40406) CI: Maven build has no retry on transient Central failures, causing spurious PR failures Sergey Nuyanzin (Jira)
• [jira] [Updated] (FLINK-37732) FLIP-527: State Schema Evolution for RowData Weiqing Yang (Jira)
• [jira] [Commented] (FLINK-40418) Support attribute-based column access on DataFrame Bettle (Jira)
• [PR] [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered [flink-agents] via GitHub
  • Re: [PR] [api][integrations][java][python] Raise a clear error for an output schema that cannot be rendered [flink-agents] via GitHub
• [I] [Tech Debt] The tools script suite loses failures and coverage at its boundary with install.sh [flink-agents] via GitHub
  • Re: [I] [Tech Debt] The tools script suite loses failures and coverage at its boundary with install.sh [flink-agents] via GitHub
  • Re: [I] [Tech Debt] The tools script suite loses failures and coverage at its boundary with install.sh [flink-agents] via GitHub
• [I] [Bug] edit_plan_quote produces invalid shell on bash 3.2, corrupting the plan state file [flink-agents] via GitHub
  • Re: [I] [Bug] edit_plan_quote produces invalid shell on bash 3.2, corrupting the plan state file [flink-agents] via GitHub
• [PR] [tools][test][e2e] Make the bats suite fail on assertions that stop holding [flink-agents] via GitHub
  • Re: [PR] [tools][test][e2e] Make the bats suite fail on assertions that stop holding [flink-agents] via GitHub
  • Re: [PR] [tools][test][e2e] Make the bats suite fail on assertions that stop holding [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40294) Instrument async scalar and table UDF calls with metrics ASF GitHub Bot (Jira)
• [PR] [FLINK-40294][table-planner] Instrument async scalar and table UDF calls with metrics [flink] via GitHub
  • Re: [PR] [FLINK-40294][table-planner] Instrument async scalar and table UDF calls with metrics [flink] via GitHub
• Re: [PR] [FLINK-40293][table] Add UDF metric config options and instrument sync scalar and table UDF calls [flink] via GitHub
  • Re: [PR] [FLINK-40293][table] Add UDF metric config options and instrument sync scalar and table UDF calls [flink] via GitHub
  • Re: [PR] [FLINK-40293][table] Add UDF metric config options and instrument sync scalar and table UDF calls [flink] via GitHub
  • Re: [PR] [FLINK-40293][table] Add UDF metric config options and instrument sync scalar and table UDF calls [flink] via GitHub
• Re: [PR] [FLINK-40171][table-runtime] Emit and retract early-fire results in the interval join operator [flink] via GitHub
  • Re: [PR] [FLINK-40171][table-runtime] Emit and retract early-fire results in the interval join operator [flink] via GitHub
• [jira] [Comment Edited] (FLINK-40422) Add slicing APIs to DataFrame API Hirson Zhang (Jira)
  • [jira] [Comment Edited] (FLINK-40422) Add slicing APIs to DataFrame API Hirson Zhang (Jira)
  • [jira] [Comment Edited] (FLINK-40422) Add slicing APIs to DataFrame API Hirson Zhang (Jira)
• [jira] [Commented] (FLINK-40422) Add slicing APIs to DataFrame API Hirson Zhang (Jira)
  • [jira] [Commented] (FLINK-40422) Add slicing APIs to DataFrame API Hirson Zhang (Jira)
  • [jira] [Commented] (FLINK-40422) Add slicing APIs to DataFrame API Dian Fu (Jira)
  • [jira] [Commented] (FLINK-40422) Add slicing APIs to DataFrame API Dian Fu (Jira)
• [PR] [hotfix][ci] Bump setup maven action to v5 [flink-shaded] via GitHub
  • Re: [PR] [hotfix][ci] Bump setup maven action to v5 [flink-shaded] via GitHub
• [PR] [hotfix][ci] Bump checkout action to v7 [flink-shaded] via GitHub
  • Re: [PR] [hotfix][ci] Bump checkout action to v7 [flink-shaded] via GitHub
• [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
  • Re: [PR] [api][plan][python][examples] Framework-managed LLM-as-judge routing (Strategies.llm) [flink-agents] via GitHub
• [jira] [Commented] (FLINK-40292) Add UdfMetrics helper for UDF metrics Yuepeng Pan (Jira)
• [jira] [Resolved] (FLINK-40292) Add UdfMetrics helper for UDF metrics Yuepeng Pan (Jira)
• [PR] [hotfix] Update to 22.0 version [flink-shaded] via GitHub
  • Re: [PR] [hotfix] Update version to 22.0 [flink-shaded] via GitHub
  • Re: [PR] [hotfix] Update version to 22.0 [flink-shaded] via GitHub
• Re: [PR] [FLINK-40139] Add default JUnit test timeout to fail hung tests fast [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40139] Add default JUnit test timeout to fail hung tests fast [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40137] Extract ReaderRecoveryGate from DynamicKafkaSourceEnumerator [flink-connector-kafka] via GitHub
• Re: [PR] [FLINK-39404][runtime] HardwareDescription reports incorrect CPU cores in containerized environments with fractional CPU limits [flink] via GitHub
  • Re: [PR] [FLINK-39404][runtime] HardwareDescription reports incorrect CPU cores in containerized environments with fractional CPU limits [flink] via GitHub
• Re: [PR] [FLINK-36472][table] Preserve right-side projections when converting Correlate to physical [flink] via GitHub
• Re: [PR] [FLINK-38075][table] Fix data loss in tumble/hop/cumulate windows with LTZ for non-DST timezones [flink] via GitHub
  • Re: [PR] [FLINK-38075][table] Fix data loss in tumble/hop/cumulate windows with LTZ for non-DST timezones [flink] via GitHub
• Re: [PR] [FLINK-37981][table] TableAsyncExecutionController sends Long.MAX watermark downstream in endInput [flink] via GitHub
  • Re: [PR] [FLINK-37981][table] TableAsyncExecutionController sends Long.MAX watermark downstream in endInput [flink] via GitHub
• Re: [PR] [FLINK-38397][table] Fix stale sort trait on BatchPhysicalLocalHashAggregate causing ArrayIndexOutOfBoundsException [flink] via GitHub
  • Re: [PR] [FLINK-38397][table] Fix stale sort trait on BatchPhysicalLocalHashAggregate causing ArrayIndexOutOfBoundsException [flink] via GitHub
• [PR] [hotfix][e2e] Derive recovery test version from project [flink-agents] via GitHub
  • Re: [PR] [hotfix][e2e] Derive recovery test version from project [flink-agents] via GitHub
• [PR] [python][java][integrations][plan] Handle finish_reason in OpenAI-family connections [flink-agents] via GitHub
  • Re: [PR] [integrations][plan] Handle finish_reason in OpenAI-family connections [flink-agents] via GitHub
  • Re: [PR] [integrations][plan] Handle finish_reason in OpenAI-family connections [flink-agents] via GitHub
  • Re: [PR] [integrations][plan] Handle finish_reason in OpenAI-family connections [flink-agents] via GitHub
• [PR] [integrations][anthropic] Update the stale default model to claude-sonnet-4-5 [flink-agents] via GitHub
  • Re: [PR] [integrations][anthropic] Update the stale default model to claude-sonnet-4-5 [flink-agents] via GitHub
  • Re: [PR] [integrations][anthropic] Update the stale default model to claude-sonnet-4-5 [flink-agents] via GitHub
  • Re: [PR] [integrations][anthropic] Update the stale default model to claude-sonnet-4-6 [flink-agents] via GitHub
• [I] [Tech Debt] Update the stale Anthropic default model claude-sonnet-4-20250514 to claude-sonnet-4-5 [flink-agents] via GitHub
  • Re: [I] [Tech Debt] Update the stale Anthropic default model claude-sonnet-4-20250514 to claude-sonnet-4-5 [flink-agents] via GitHub
• [PR] [integrations][java][python] Stop sending temperature to Anthropic models that reject it [flink-agents] via GitHub
  • Re: [PR] [integrations][anthropic] Stop sending rejected sampling parameters [flink-agents] via GitHub
  • Re: [PR] [integrations][anthropic] Stop sending rejected sampling parameters [flink-agents] via GitHub
  • Re: [PR] [integrations][anthropic] Stop sending rejected sampling parameters [flink-agents] via GitHub
  • Re: [PR] [integrations][anthropic] Stop sending rejected sampling parameters [flink-agents] via GitHub
  • Re: [PR] [integrations][anthropic] Stop sending rejected sampling parameters [flink-agents] via GitHub
  • Re: [PR] [integrations][anthropic] Stop sending rejected sampling parameters [flink-agents] via GitHub
• [I] [Bug] [integrations][anthropic] temperature defaults to 0.1 and is always sent, returning HTTP 400 on Claude 4.7 and later [flink-agents] via GitHub
• [I] [Tech Debt] bats test bodies run under bash 3.2, so non-final [[ ]] assertions never fail [flink-agents] via GitHub
  • Re: [I] [Tech Debt] bats test bodies run under bash 3.2, so non-final [[ ]] assertions never fail [flink-agents] via GitHub
  • Re: [I] [Tech Debt] bats test bodies run under bash 3.2, so non-final [[ ]] assertions never fail [flink-agents] via GitHub
• [jira] [Commented] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure Sergey Nuyanzin (Jira)
• [jira] [Assigned] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-36298) NullPointerException in Calcite causes a PyFlink test failure Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-36298][table-planner] Re-establish Calcite metadata provider on foreign threads [flink] via GitHub
• [jira] [Resolved] (FLINK-40451) E2E test timeout keeps CI running until the timeout ends, even after the test passes Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-40451) E2E test timeout keeps CI running until the timeout ends, even after the test passes Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-39741][python] Add type hints and fix docstrings in datastream/functions.py [flink] via GitHub
• Re: [PR] [FLINK-39028][state] Use ByteBuffer API to reduce GC pressure in RocksDB state backend [flink] via GitHub
• [jira] [Updated] (FLINK-40457) Bump pekko to 1.7.0 ASF GitHub Bot (Jira)
• [PR] [FLINK-40457][rpc] Bump Pekko to 1.7.0 [flink] via GitHub
  • Re: [PR] [FLINK-40457][rpc] Bump Pekko to 1.7.0 [flink] via GitHub
  • Re: [PR] [FLINK-40457][rpc] Bump Pekko to 1.7.0 [flink] via GitHub
• [jira] [Created] (FLINK-40457) Bump pekko to 1.7.0 Sergey Nuyanzin (Jira)
• [PR] [FLINK-40456][datastream] `AsyncWaitOperator` can permanently drop an element's result when timeout races with a retry [flink] via GitHub
  • Re: [PR] [FLINK-40456][datastream] `AsyncWaitOperator` can permanently drop an element's result when timeout races with a retry [flink] via GitHub
  • Re: [PR] [FLINK-40456][datastream] `AsyncWaitOperator` can permanently drop an element's result when timeout races with a retry [flink] via GitHub
  • Re: [PR] [FLINK-40456][datastream] `AsyncWaitOperator` can permanently drop an element's result when timeout races with a retry [flink] via GitHub
  • Re: [PR] [FLINK-40456][datastream] `AsyncWaitOperator` can permanently drop an element's result when timeout races with a retry [flink] via GitHub
  • Re: [PR] [FLINK-40456][datastream] `AsyncWaitOperator` can permanently drop an element's result when timeout races with a retry [flink] via GitHub
• Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents] via GitHub
  • Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents] via GitHub
  • Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents] via GitHub
  • Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents] via GitHub
  • Re: [PR] [api][runtime][python] Add opt-in Kafka tombstones for pruned action state [flink-agents] via GitHub
• [I] [Feature] Add checkpoint-aligned cleanup for Kafka action state [flink-agents] via GitHub
  • Re: [I] [Feature] Add checkpoint-aligned cleanup for Kafka action state [flink-agents] via GitHub
  • Re: [I] [Feature] Add checkpoint-aligned cleanup for Kafka action state [flink-agents] via GitHub
• Re: [PR] [FLINK-39604][table] Show state and PTF capabilities in DESCRIBE FUNCTION EXTENDED [flink] via GitHub
• [jira] [Created] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry Sergey Nuyanzin (Jira)
• [jira] [Closed] (FLINK-40447) Keyless upsert sink can silently drop retract semantics when upsert-key metadata is empty or mixed Gustavo de Morais (Jira)
• [PR] [runtime] Resolve relative file: URLs when loading classpath skills (#966) [flink-agents] via GitHub

• Earlier messages
• Later messages