issues  

Messages by Thread

• • Re: [PR] [FLINK-40469] Checkpoint during recovery window silently loses partitions [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40469] Checkpoint during recovery window silently loses partitions [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40469] Checkpoint during recovery window silently loses partitions [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40469] Checkpoint during recovery window silently loses partitions [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40469] Checkpoint during recovery window silently loses partitions [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40469] Checkpoint during recovery window silently loses partitions [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-40469] Checkpoint during recovery window silently loses partitions [flink-connector-kafka] via GitHub
• [PR] [python] Reject unknown constructor arguments on chat model connections/setups [flink-agents] via GitHub
  • Re: [PR] [python] Reject unknown constructor arguments on chat model connections/setups [flink-agents] via GitHub
  • Re: [PR] [python] Reject unknown constructor arguments on chat model connections/setups [flink-agents] via GitHub
  • Re: [PR] [python] Reject unknown constructor arguments on chat model connections/setups [flink-agents] via GitHub
  • Re: [PR] [python] Reject unknown constructor arguments on chat model connections/setups [flink-agents] via GitHub
  • Re: [PR] [python] Reject unknown constructor arguments on chat model connections/setups [flink-agents] via GitHub
  • Re: [PR] [python] Reject unknown constructor arguments on chat model connections/setups [flink-agents] via GitHub
• [I] [Bug][python] Chat model connections/setups silently ignore unknown constructor arguments [flink-agents] via GitHub
  • Re: [I] [Bug][python] Chat model connections/setups silently ignore unknown constructor arguments [flink-agents] via GitHub
  • Re: [I] [Bug][python] Chat model connections/setups silently ignore unknown constructor arguments [flink-agents] via GitHub
  • Re: [I] [Tech Debt][python] Chat model connections/setups silently ignore unknown constructor arguments [flink-agents] via GitHub
• [jira] [Created] (FLINK-40469) DynamicKafkaSource can lose splits when checkpointing during recovery reassignment Aleksandr Savonin (Jira)
• [jira] [Assigned] (FLINK-40468) Partial deletes cause NPE if value type is declared as NOT NULL Fabian Hueske (Jira)
• [jira] [Created] (FLINK-40468) Partial deletes cause NPE if value type is declared as NOT NULL Fabian Hueske (Jira)
• [jira] [Resolved] (FLINK-37977) Variant implements Serializable Sergey Nuyanzin (Jira)
• [jira] [Created] (FLINK-40467) Flink 2.3 Application Mode managed by the kubernetes operator can start without submitting the new job after savepoint redeploy Josh Keegan (Jira)
• [jira] [Commented] (FLINK-37977) Variant implements Serializable Sergey Nuyanzin (Jira)
• [PR] [FLINK-40459][Build/Shaded] Bump Maven from 3.8.6 to 3.9.16 [flink-shaded] via GitHub
  • Re: [PR] [FLINK-40459][Build/Shaded] Bump Maven from 3.8.6 to 3.9.16 [flink-shaded] via GitHub
• [PR] [runtime][python] Release per-action Pemja objects [flink-agents] via GitHub
• [I] [Bug] PythonActionExecutor leaks per-action Pemja PyObject references [flink-agents] via GitHub
• [jira] [Updated] (FLINK-40466) Refactor defining table arguments in PTF Test Harness builder for more complex table arguments ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40466) Refactor defining table arguments in PTF Test Harness builder for more complex table arguments Mika Naylor (Jira)
• [PR] [FLINK-40466][table] Refactor defining table arguments in PTF Test Harness for more complex table arguments [flink] via GitHub
  • Re: [PR] [FLINK-40466][table] Refactor defining table arguments in PTF Test Harness for more complex table arguments [flink] via GitHub
  • Re: [PR] [FLINK-40466][table] Refactor defining table arguments in PTF Test Harness for more complex table arguments [flink] via GitHub
  • Re: [PR] [FLINK-40466][table] Refactor defining table arguments in PTF Test Harness for more complex table arguments [flink] via GitHub
  • Re: [PR] [FLINK-40466][table] Refactor defining table arguments in PTF Test Harness for more complex table arguments [flink] via GitHub
• [PR] [FLINK-39031][python] Build pyflink wheels for Python 3.13 [flink] via GitHub
  • Re: [PR] [FLINK-39031][python] Build pyflink wheels for Python 3.13 [flink] via GitHub
  • Re: [PR] [FLINK-39031][python] Build pyflink wheels for Python 3.13 [flink] via GitHub
  • Re: [PR] [FLINK-39031][python] Build pyflink wheels for Python 3.13 [flink] via GitHub
• [jira] [Updated] (FLINK-39031) [PyFlink] support Python 3.13 and 3.14 ASF GitHub Bot (Jira)
• [jira] [Updated] (FLINK-40464) [CI][Release][Python] Drop support for manylinux 2014 ASF GitHub Bot (Jira)
• [PR] [FLINK-40464][python] Build pyflink wheels on manylinux_2_28 [flink] via GitHub
  • Re: [PR] [FLINK-40464][python] Build pyflink wheels on manylinux_2_28 [flink] via GitHub
  • Re: [PR] [FLINK-40464][python] Build pyflink wheels on manylinux_2_28 [flink] via GitHub
  • Re: [PR] [FLINK-40464][python] Build pyflink wheels on manylinux_2_28 [flink] via GitHub
• [PR] [FLINK-40465] Add version-independent classes to parse job config [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40465] Add version-independent classes to parse job config [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40465] Add version-independent classes to parse job config [flink-kubernetes-operator] via GitHub
  • Re: [PR] [FLINK-40465] Add version-independent classes to parse job config [flink-kubernetes-operator] via GitHub
• [jira] [Updated] (FLINK-40465) Flink 2.0 job configuration response cannot be parsed by the operator Mate Czagany (Jira)
  • [jira] [Updated] (FLINK-40465) Flink 2.0 job configuration response cannot be parsed by the operator ASF GitHub Bot (Jira)
• [jira] [Created] (FLINK-40465) Flink 2.0 job configuration response cannot be parsed by the operator Mate Czagany (Jira)
• Re: [PR] [FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink. [flink-cdc] via GitHub
  • Re: [PR] [FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink. [flink-cdc] via GitHub
• [jira] [Commented] (FLINK-40464) [CI][Release][Python] Drop support for manylinux 2014 Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-37327] [Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows [flink] via GitHub
  • Re: [PR] [FLINK-37327] [Formats (JSON, Avro, Parquet, ORC, SequenceFile)] Debezium Avro Format: Add FormatOption to Optionally Skip emitting UPDATE_BEFORE Rows [flink] via GitHub
• [jira] [Commented] (FLINK-40420) Add set operations to DataFrame API Bettle (Jira)
• [jira] [Created] (FLINK-40464) [CI][Release][Python] Drop support for manylinux 2014 Florian Vazelle (Jira)
• [jira] [Commented] (FLINK-23758) PyFlink __invert__ has wrong semantics Bettle (Jira)
  • [jira] [Commented] (FLINK-23758) PyFlink __invert__ has wrong semantics Dian Fu (Jira)
  • [jira] [Commented] (FLINK-23758) PyFlink __invert__ has wrong semantics Bettle (Jira)
  • [jira] [Commented] (FLINK-23758) PyFlink __invert__ has wrong semantics Bettle (Jira)
  • [jira] [Commented] (FLINK-23758) PyFlink __invert__ has wrong semantics Dian Fu (Jira)
• Re: [PR] [FLINK-38825][table] Add SQL/Table API integration for AsyncBatch inference [flink] via GitHub
  • Re: [PR] [FLINK-38825][table] Add SQL/Table API integration for AsyncBatch inference [flink] via GitHub
• Re: [PR] [FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction [flink] via GitHub
  • Re: [PR] [FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction [flink] via GitHub
• Re: [PR] [FLINK-39176][Runtime] Add expiration cleanup scheduler for NodeHealthManager [flink] via GitHub
  • Re: [PR] [FLINK-39176][Runtime] Add expiration cleanup scheduler for NodeHealthManager [flink] via GitHub
• Re: [PR] [FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator [flink] via GitHub
  • Re: [PR] [FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator [flink] via GitHub
• [jira] [Updated] (FLINK-40232) NullPointerException in OutputConversionOperator.processElement when rowtime attribute is null Fan Deng (Jira)
  • [jira] [Updated] (FLINK-40232) NullPointerException in OutputConversionOperator.processElement when rowtime attribute is null ASF GitHub Bot (Jira)
• [jira] [Assigned] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch Yuepeng Pan (Jira)
• Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
  • Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
  • Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
  • Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
  • Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
  • Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink] via GitHub
• [jira] [Updated] (FLINK-34246) Allow only archive failed job to history server ASF GitHub Bot (Jira)
• [PR] [FLINK-34246][runtime] Add option to only archive failed jobs to history server [flink] via GitHub
  • Re: [PR] [FLINK-34246][runtime] Add option to only archive failed jobs to history server [flink] via GitHub
  • Re: [PR] [FLINK-34246][runtime] Add option to only archive failed jobs to history server [flink] via GitHub
• [jira] [Commented] (FLINK-34246) Allow only archive failed job to history server Archit Goyal (Jira)
• Re: [PR] [integrations][java][python] Apply Ollama native structured output [flink-agents] via GitHub
  • Re: [PR] [integrations][java][python] Apply Ollama native structured output [flink-agents] via GitHub
  • Re: [PR] [integrations][java][python] Apply Ollama native structured output [flink-agents] via GitHub
  • Re: [PR] [integrations][java][python] Apply Ollama native structured output [flink-agents] via GitHub
• Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
  • Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
  • Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
  • Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
  • Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
  • Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
  • Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
  • Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
  • Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
  • Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
  • Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
  • Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
  • Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink] via GitHub
• [jira] [Assigned] (FLINK-40453) [postgres] Avoid eagerly loading all table schemas when initializing PostgresPipelineRecordEmitter Hongshun Wang (Jira)
• [jira] [Resolved] (FLINK-40453) [postgres] Avoid eagerly loading all table schemas when initializing PostgresPipelineRecordEmitter Hongshun Wang (Jira)
• [jira] [Closed] (FLINK-40346) Triton array deserialization silently replaces JSON nulls with 0 / false / "null" Dian Fu (Jira)
• [jira] [Assigned] (FLINK-39578) Missing py.typed in PyFlink wheel prevents type checking with mypy Dian Fu (Jira)
• [jira] [Closed] (FLINK-39578) Missing py.typed in PyFlink wheel prevents type checking with mypy Dian Fu (Jira)
• [jira] [Updated] (FLINK-40417) Add with_columns/drop_columns/rename_columns to DataFrame API Dian Fu (Jira)
• [jira] [Closed] (FLINK-40417) Add remaining basic functionality to DataFrame API Dian Fu (Jira)
• [PR] [api][java][python] Record embedding token usage metrics [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Record embedding token usage metrics [flink-agents] via GitHub
  • Re: [PR] [api][java][python] Record embedding token usage metrics [flink-agents] via GitHub
• [jira] [Created] (FLINK-40463) Widen JSON_VALUE and JSON_QUERY RETURNING type support Chris Johnson (Jira)
• [jira] [Resolved] (FLINK-40462) Nightly "Build Python Wheels on linux" fails building pillow from source (glibc_version_fix.h not found) Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-40462) Nightly "Build Python Wheels on linux" fails building pillow from source (glibc_version_fix.h not found) Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-40457) Bump pekko to 1.7.0 Sergey Nuyanzin (Jira)
• Re: [D] [Feature] Sub-agent Resource for Flink Agents - Framework part [flink-agents] via GitHub
  • Re: [D] [Feature] Sub-agent Resource for Flink Agents - Framework part [flink-agents] via GitHub
  • Re: [D] [Feature] Sub-agent Resource for Flink Agents - Framework part [flink-agents] via GitHub
• [PR] [BP-2.3][FLINK-40346][model-triton] Preserve null array elements when deserializing Triton responses [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40346][model-triton] Preserve null array elements when deserializing Triton responses [flink] via GitHub
  • Re: [PR] [BP-2.3][FLINK-40346][model-triton] Preserve null array elements when deserializing Triton responses [flink] via GitHub
• [PR] [FLINK-39617] [runtime] Add batch aggregated subtask metrics endpoints [flink] via GitHub
  • Re: [PR] [FLINK-39617] [runtime] Add batch aggregated subtask metrics endpoints [flink] via GitHub
• [jira] [Created] (FLINK-40462) Nightly "Build Python Wheels on linux" fails building pillow from source (glibc_version_fix.h not found) Sergey Nuyanzin (Jira)
• [jira] [Resolved] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry Sergey Nuyanzin (Jira)
• [PR] [FLINK-40462][ci] Fix Build Python Wheels for GHA [flink] via GitHub
  • Re: [PR] [FLINK-40462][ci] Fix Build Python Wheels for GHA [flink] via GitHub
  • Re: [PR] [FLINK-40462][ci] Fix Build Python Wheels for GHA [flink] via GitHub
• [jira] [Updated] (FLINK-40462) Nightly "Build Python Wheels on linux" fails building pillow from source (glibc_version_fix.h not found) ASF GitHub Bot (Jira)
• Re: [PR] [FLINK-39578][python] Include py.typed in PyFlink distribution [flink] via GitHub
  • Re: [PR] [FLINK-39578][python] Include py.typed in PyFlink distribution [flink] via GitHub
• Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] via GitHub
  • Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka] via GitHub
• [jira] [Resolved] (FLINK-40296) Add an object-level migrate hook to TypeSerializerSnapshot Yuepeng Pan (Jira)
• [jira] [Assigned] (FLINK-40296) Add an object-level migrate hook to TypeSerializerSnapshot Yuepeng Pan (Jira)
• [jira] [Commented] (FLINK-40457) Bump pekko to 1.7.0 Sergey Nuyanzin (Jira)
• [jira] [Commented] (FLINK-37925) Support type casting between variant and primitive type Sergey Nuyanzin (Jira)
• Re: [PR] [FLINK-37925][table] Define CAST and TRY_CAST from VARIANT to scalar types [flink] via GitHub
• [jira] [Commented] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x Sergey Nuyanzin (Jira)
  • [jira] [Commented] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x Martijn Visser (Jira)
  • [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

• Earlier messages
• Later messages