issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/08/25
Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws]
via GitHub
2026/08/25
Re: [PR] [FLINK-40196][python] Add missing-value handling to DataFrame API [flink]
via GitHub
2026/08/25
Re: [D] [Feature] Sub-agent Resource for Flink Agents - Framework part [flink-agents]
via GitHub
2026/08/25
[jira] [Assigned] (FLINK-40469) DynamicKafkaSource can lose splits when checkpointing during recovery reassignment
Jim Hughes (Jira)
2026/08/25
Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink]
via GitHub
2026/08/25
Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents]
via GitHub
2026/08/25
[jira] [Updated] (FLINK-40469) DynamicKafkaSource can lose splits when checkpointing during recovery reassignment
ASF GitHub Bot (Jira)
2026/08/25
[PR] [DRAFT][FLINK-40469] Checkpoint during recovery window silently loses partitions [flink-connector-kafka]
via GitHub
2026/08/25
Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents]
via GitHub
2026/08/25
[PR] [python] Reject unknown constructor arguments on chat model connections/setups [flink-agents]
via GitHub
2026/08/25
[I] [Bug][python] Chat model connections/setups silently ignore unknown constructor arguments [flink-agents]
via GitHub
2026/08/25
Re: [PR] [FLINK-40277][connector-http] Add HTTP sink response classification and retries [flink-connector-http]
via GitHub
2026/08/25
Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents]
via GitHub
2026/08/25
[jira] [Created] (FLINK-40469) DynamicKafkaSource can lose splits when checkpointing during recovery reassignment
Aleksandr Savonin (Jira)
2026/08/25
Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws]
via GitHub
2026/08/25
Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws]
via GitHub
2026/08/25
Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws]
via GitHub
2026/08/25
[jira] [Assigned] (FLINK-40468) Partial deletes cause NPE if value type is declared as NOT NULL
Fabian Hueske (Jira)
2026/08/25
[jira] [Created] (FLINK-40468) Partial deletes cause NPE if value type is declared as NOT NULL
Fabian Hueske (Jira)
2026/08/25
[jira] [Resolved] (FLINK-37977) Variant implements Serializable
Sergey Nuyanzin (Jira)
2026/08/25
[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)
2026/08/25
[jira] [Commented] (FLINK-37977) Variant implements Serializable
Sergey Nuyanzin (Jira)
2026/08/25
[PR] [FLINK-40459][Build/Shaded] Bump Maven from 3.8.6 to 3.9.16 [flink-shaded]
via GitHub
2026/08/25
Re: [PR] [FLINK-40355][table] Add new MAP_CONTAINS_KEY function [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-39722][pipeline-connector][fluss] Support Fluss CDC Yaml Source. [flink-cdc]
via GitHub
2026/08/25
Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink]
via GitHub
2026/08/25
[PR] [runtime][python] Release per-action Pemja objects [flink-agents]
via GitHub
2026/08/25
[I] [Bug] PythonActionExecutor leaks per-action Pemja PyObject references [flink-agents]
via GitHub
2026/08/25
Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink]
via GitHub
2026/08/25
[jira] [Updated] (FLINK-40466) Refactor defining table arguments in PTF Test Harness builder for more complex table arguments
ASF GitHub Bot (Jira)
2026/08/25
Re: [PR] [FLINK-40466][table] Refactor defining table arguments in PTF Test Harness for more complex table arguments [flink]
via GitHub
2026/08/25
[jira] [Created] (FLINK-40466) Refactor defining table arguments in PTF Test Harness builder for more complex table arguments
Mika Naylor (Jira)
2026/08/25
Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink]
via GitHub
2026/08/25
[PR] [FLINK-40466][table] Refactor defining table arguments in PTF Test Harness for more complex table arguments [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-40464][python] Build pyflink wheels on manylinux_2_28 [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-39031][python] Build pyflink wheels for Python 3.13 [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-40464][python] Build pyflink wheels on manylinux_2_28 [flink]
via GitHub
2026/08/25
[PR] [FLINK-39031][python] Build pyflink wheels for Python 3.13 [flink]
via GitHub
2026/08/25
[jira] [Updated] (FLINK-39031) [PyFlink] support Python 3.13 and 3.14
ASF GitHub Bot (Jira)
2026/08/25
Re: [PR] [FLINK-40464][python] Build pyflink wheels on manylinux_2_28 [flink]
via GitHub
2026/08/25
[jira] [Updated] (FLINK-40464) [CI][Release][Python] Drop support for manylinux 2014
ASF GitHub Bot (Jira)
2026/08/25
[PR] [FLINK-40464][python] Build pyflink wheels on manylinux_2_28 [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
2026/08/25
Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink]
via GitHub
2026/08/25
[jira] [Updated] (FLINK-40465) Flink 2.0 job configuration response cannot be parsed by the operator
ASF GitHub Bot (Jira)
2026/08/25
[PR] [FLINK-40465] Add version-independent classes to parse job config [flink-kubernetes-operator]
via GitHub
2026/08/25
Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink]
via GitHub
2026/08/25
Re: [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents]
via GitHub
2026/08/25
[jira] [Updated] (FLINK-40465) Flink 2.0 job configuration response cannot be parsed by the operator
Mate Czagany (Jira)
2026/08/25
[jira] [Created] (FLINK-40465) Flink 2.0 job configuration response cannot be parsed by the operator
Mate Czagany (Jira)
2026/08/25
Re: [I] [Bug][security][skills] Protect URL skill sources with secure transport and integrity verification [flink-agents]
via GitHub
2026/08/25
Re: [PR] [FLINK-40331][cdc-connect][fluss] Support forward shuffle in fluss sink. [flink-cdc]
via GitHub
2026/08/25
[jira] [Updated] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x
Martijn Visser (Jira)
2026/08/25
[jira] [Commented] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x
Martijn Visser (Jira)
2026/08/25
Re: [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents]
via GitHub
2026/08/25
[jira] [Commented] (FLINK-40464) [CI][Release][Python] Drop support for manylinux 2014
Sergey Nuyanzin (Jira)
2026/08/25
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
2026/08/25
[jira] [Commented] (FLINK-40420) Add set operations to DataFrame API
Bettle (Jira)
2026/08/25
Re: [PR] Flink Kubernetes Operator 1.16.0 [flink-web]
via GitHub
2026/08/25
[jira] [Created] (FLINK-40464) [CI][Release][Python] Drop support for manylinux 2014
Florian Vazelle (Jira)
2026/08/25
Re: [PR] Flink Kubernetes Operator 1.16.0 [flink-web]
via GitHub
2026/08/25
Re: [PR] Flink Kubernetes Operator 1.16.0 [flink-web]
via GitHub
2026/08/25
Re: [PR] [hotfix][vector-store][java] Update Elasticsearch filters documentation [flink-agents]
via GitHub
2026/08/25
Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws]
via GitHub
2026/08/25
[jira] [Commented] (FLINK-23758) PyFlink __invert__ has wrong semantics
Bettle (Jira)
2026/08/25
Re: [PR] [integrations][anthropic] Update the stale default model to claude-sonnet-4-5 [flink-agents]
via GitHub
2026/08/24
Re: [PR] [integrations][anthropic] Stop sending rejected sampling parameters [flink-agents]
via GitHub
2026/08/24
Re: [PR] [FLINK-38023][formats] Fix GenericRecord Avro state migration [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-38825][table] Add SQL/Table API integration for AsyncBatch inference [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-38825][table] Add SQL/Table API integration for AsyncBatch inference [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-39176][Runtime] Add expiration cleanup scheduler for NodeHealthManager [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-39176][Runtime] Add expiration cleanup scheduler for NodeHealthManager [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator [flink]
via GitHub
2026/08/24
[jira] [Updated] (FLINK-40232) NullPointerException in OutputConversionOperator.processElement when rowtime attribute is null
Fan Deng (Jira)
2026/08/24
Re: [PR] [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-39722][pipeline-connector][fluss] Support Fluss CDC Yaml Source. [flink-cdc]
via GitHub
2026/08/24
Re: [PR] [FLINK-39722][pipeline-connector][fluss] Support Fluss CDC Yaml Source. [flink-cdc]
via GitHub
2026/08/24
[jira] [Commented] (FLINK-40346) Triton array deserialization silently replaces JSON nulls with 0 / false / "null"
sepuri sai krishna (Jira)
2026/08/24
[jira] [Assigned] (FLINK-37155) FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch
Yuepeng Pan (Jira)
2026/08/24
Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40293][table] Add UDF metric config options and instrument sync scalar and table UDF calls [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40293][table] Add UDF metric config options and instrument sync scalar and table UDF calls [flink]
via GitHub
2026/08/24
Re: [PR] Flink Kubernetes Operator 1.16.0 [flink-web]
via GitHub
2026/08/24
Re: [PR] [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook [flink]
via GitHub
2026/08/24
Re: [PR] Flink Kubernetes Operator 1.16.0 [flink-web]
via GitHub
2026/08/24
Re: [PR] [FLINK-34246][runtime] Add option to only archive failed jobs to history server [flink]
via GitHub
2026/08/24
[jira] [Updated] (FLINK-34246) Allow only archive failed job to history server
ASF GitHub Bot (Jira)
2026/08/24
[PR] [FLINK-34246][runtime] Add option to only archive failed jobs to history server [flink]
via GitHub
2026/08/24
[jira] [Commented] (FLINK-34246) Allow only archive failed job to history server
Archit Goyal (Jira)
2026/08/24
Re: [PR] [integrations][java][python] Apply Ollama native structured output [flink-agents]
via GitHub
2026/08/24
[jira] [Comment Edited] (FLINK-40422) Add slicing APIs to DataFrame API
Hirson Zhang (Jira)
2026/08/24
Re: [PR] [FLINK-39986][table-planner][python] Support Python UDF deduplication in projection and condition [flink]
via GitHub
2026/08/24
Re: [D] [Discuss][API] Multimodal content parts in ChatMessage [flink-agents]
via GitHub
2026/08/24
[jira] [Assigned] (FLINK-40453) [postgres] Avoid eagerly loading all table schemas when initializing PostgresPipelineRecordEmitter
Hongshun Wang (Jira)
2026/08/24
[jira] [Resolved] (FLINK-40453) [postgres] Avoid eagerly loading all table schemas when initializing PostgresPipelineRecordEmitter
Hongshun Wang (Jira)
2026/08/24
Re: [PR] [FLINK-40453][postgres] Not load table schema when initializing record emitter [flink-cdc]
via GitHub
2026/08/24
[jira] [Closed] (FLINK-40346) Triton array deserialization silently replaces JSON nulls with 0 / false / "null"
Dian Fu (Jira)
2026/08/24
[jira] [Commented] (FLINK-40346) Triton array deserialization silently replaces JSON nulls with 0 / false / "null"
Dian Fu (Jira)
2026/08/24
Re: [PR] [BP-2.3][FLINK-40346][model-triton] Preserve null array elements when deserializing Triton responses [flink]
via GitHub
2026/08/24
[jira] [Assigned] (FLINK-39578) Missing py.typed in PyFlink wheel prevents type checking with mypy
Dian Fu (Jira)
2026/08/24
[jira] [Closed] (FLINK-39578) Missing py.typed in PyFlink wheel prevents type checking with mypy
Dian Fu (Jira)
2026/08/24
Re: [PR] [FLINK-39578][python] Include py.typed in PyFlink distribution [flink]
via GitHub
2026/08/24
[jira] [Updated] (FLINK-40417) Add with_columns/drop_columns/rename_columns to DataFrame API
Dian Fu (Jira)
2026/08/24
[jira] [Closed] (FLINK-40417) Add remaining basic functionality to DataFrame API
Dian Fu (Jira)
2026/08/24
Re: [PR] [FLINK-40417][python] Add remaining basic functionality to DataFrame API [flink]
via GitHub
2026/08/24
[PR] [api][java][python] Record embedding token usage metrics [flink-agents]
via GitHub
2026/08/24
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40350][table-runtime] LPAD/RPAD split supplementary-plane characters into unpaired surrogates [flink]
via GitHub
2026/08/24
[jira] [Created] (FLINK-40463) Widen JSON_VALUE and JSON_QUERY RETURNING type support
Chris Johnson (Jira)
2026/08/24
Re: [PR] [api][runtime] Replay newObject memory updates as object creations during durable recovery [flink-agents]
via GitHub
2026/08/24
[jira] [Resolved] (FLINK-40462) Nightly "Build Python Wheels on linux" fails building pillow from source (glibc_version_fix.h not found)
Sergey Nuyanzin (Jira)
2026/08/24
[jira] [Commented] (FLINK-40462) Nightly "Build Python Wheels on linux" fails building pillow from source (glibc_version_fix.h not found)
Sergey Nuyanzin (Jira)
2026/08/24
Re: [PR] [FLINK-40462][ci] Fix Build Python Wheels for GHA [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40459][build] Bump Maven from 3.8.6 to 3.9.16 [flink]
via GitHub
2026/08/24
[jira] [Resolved] (FLINK-40457) Bump pekko to 1.7.0
Sergey Nuyanzin (Jira)
2026/08/24
Re: [PR] [FLINK-40417][python] Add remaining basic functionality to DataFrame API [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40459][build] Bump Maven from 3.8.6 to 3.9.16 [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40296][core] Add object-level migrate hook to TypeSerializerSnapshot [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40457][rpc] Bump Pekko to 1.7.0 [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws]
via GitHub
2026/08/24
Re: [PR] [BP-2.3][FLINK-40346][model-triton] Preserve null array elements when deserializing Triton responses [flink]
via GitHub
2026/08/24
Re: [D] [Feature] Sub-agent Resource for Flink Agents - Framework part [flink-agents]
via GitHub
2026/08/24
[jira] [Commented] (FLINK-40346) Triton array deserialization silently replaces JSON nulls with 0 / false / "null"
sepuri sai krishna (Jira)
2026/08/24
[PR] [BP-2.3][FLINK-40346][model-triton] Preserve null array elements when deserializing Triton responses [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-25802][FLINK-30499][table-planner] Fix TIMESTAMP codegen for RANGE OVER window bounds [flink]
via GitHub
2026/08/24
[jira] [Commented] (FLINK-30499) Over window codegen error when member code incorrectly used in method body
Sergey Nuyanzin (Jira)
2026/08/24
Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40296][core] Add object-level migrate hook to TypeSerializerSnapshot [flink]
via GitHub
2026/08/24
[PR] [FLINK-39617] [runtime] Add batch aggregated subtask metrics endpoints [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40462][ci] Fix Build Python Wheels for GHA [flink]
via GitHub
2026/08/24
[jira] [Created] (FLINK-40462) Nightly "Build Python Wheels on linux" fails building pillow from source (glibc_version_fix.h not found)
Sergey Nuyanzin (Jira)
2026/08/24
[jira] [Resolved] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry
Sergey Nuyanzin (Jira)
2026/08/24
[jira] [Updated] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry
Sergey Nuyanzin (Jira)
2026/08/24
[jira] [Commented] (FLINK-40456) AsyncWaitOperator can permanently drop an element's result when a timeout races with a retry
Sergey Nuyanzin (Jira)
2026/08/24
Re: [PR] [FLINK-40456][datastream] `AsyncWaitOperator` can permanently drop an element's result when timeout races with a retry [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40456][datastream] `AsyncWaitOperator` can permanently drop an element's result when timeout races with a retry [flink]
via GitHub
2026/08/24
[PR] [FLINK-40462][ci] Fix Build Python Wheels for GHA [flink]
via GitHub
2026/08/24
[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)
2026/08/24
Re: [PR] [FLINK-39617] [runtime] Add batch aggregated subtask metrics endpoints [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-39578][python] Include py.typed in PyFlink distribution [flink]
via GitHub
2026/08/24
[jira] [Updated] (FLINK-39617) Add batch REST endpoints for aggregated subtask metrics across multiple job vertices
ASF GitHub Bot (Jira)
2026/08/24
[jira] [Updated] (FLINK-30499) Over window codegen error when member code incorrectly used in method body
Sergey Nuyanzin (Jira)
2026/08/24
[jira] [Updated] (FLINK-25802) OverWindow in batch mode failed
Sergey Nuyanzin (Jira)
2026/08/24
Re: [PR] [FLINK-32609] Support Projection Pushdown [flink-connector-kafka]
via GitHub
2026/08/24
[jira] [Commented] (FLINK-25802) OverWindow in batch mode failed
Sergey Nuyanzin (Jira)
2026/08/24
Re: [PR] [FLINK-40293][table] Add UDF metric config options and instrument sync scalar and table UDF calls [flink]
via GitHub
2026/08/24
[jira] [Resolved] (FLINK-40296) Add an object-level migrate hook to TypeSerializerSnapshot
Yuepeng Pan (Jira)
2026/08/24
[jira] [Assigned] (FLINK-40296) Add an object-level migrate hook to TypeSerializerSnapshot
Yuepeng Pan (Jira)
2026/08/24
Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws]
via GitHub
2026/08/24
Re: [PR] [FLINK-40417][python] Add remaining basic functionality to DataFrame API [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40417][python] Add remaining basic functionality to DataFrame API [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40417][python] Add remaining basic functionality to DataFrame API [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40417][python] Add remaining basic functionality to DataFrame API [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40417][python] Add remaining basic functionality to DataFrame API [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40417][python] Add remaining basic functionality to DataFrame API [flink]
via GitHub
2026/08/24
[jira] [Commented] (FLINK-40457) Bump pekko to 1.7.0
Sergey Nuyanzin (Jira)
2026/08/24
Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws]
via GitHub
2026/08/24
[jira] [Commented] (FLINK-37925) Support type casting between variant and primitive type
Sergey Nuyanzin (Jira)
2026/08/24
Re: [PR] [FLINK-37925][table] Define CAST and TRY_CAST from VARIANT to scalar types [flink]
via GitHub
2026/08/24
[jira] [Commented] (FLINK-40459) Bump the build/enforced Maven version from 3.8.6 to 3.9.x
Sergey Nuyanzin (Jira)
2026/08/24
Re: [PR] [FLINK-40381] Fix thread leak in Elasticsearch8AsyncWriter by closing HTTP transport on sink close [flink-connector-elasticsearch]
via GitHub
2026/08/24
[jira] [Created] (FLINK-40461) Add config option for labels on operator generated events
Jira
2026/08/24
[PR] Add config option for labels on operator generated events [flink-kubernetes-operator]
via GitHub
2026/08/24
[PR] [FLINK-40179] Support windowed states in state catalog [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40179] Support windowed states in state catalog [flink]
via GitHub
2026/08/24
[jira] [Updated] (FLINK-40179) Support windowed states in state catalog
ASF GitHub Bot (Jira)
2026/08/24
Re: [PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink]
via GitHub
2026/08/24
[jira] [Updated] (FLINK-40241) Support VARIANT as column type in the 'raw' format
ASF GitHub Bot (Jira)
2026/08/24
[PR] [FLINK-40241][table-runtime] Support VARIANT as column type in the 'raw' format [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws]
via GitHub
2026/08/24
Re: [PR] [FLINK-40382][build] Stop surefire from hiding nested test classes [flink]
via GitHub
2026/08/24
[jira] [Created] (FLINK-40460) Upgrade archive-producing Maven plugins to reproducible-capable versions
Martijn Visser (Jira)
2026/08/24
Re: [PR] [FLINK-40017] Introduce Seaweedfs in native-s3-fs [flink]
via GitHub
2026/08/24
Re: [I] [Feature] Track token usage metrics for embedding models [flink-agents]
via GitHub
2026/08/24
Re: [PR] [FLINK-40356][table] Add new MapFromEntries function [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws]
via GitHub
2026/08/24
Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws]
via GitHub
2026/08/24
Re: [PR] [Bug] Recovered Durable ActionState for keys owned by other subtasks is never pruned [flink-agents]
via GitHub
2026/08/24
Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws]
via GitHub
2026/08/24
Re: [PR] [FLINK-40381] Fix thread leak in Elasticsearch8AsyncWriter by closing HTTP transport on sink close [flink-connector-elasticsearch]
via GitHub
2026/08/24
Re: [PR] [FLINK-39137][Connectors/Kinesis] Add configurable interval between non-empty getRecords calls [flink-connector-aws]
via GitHub
2026/08/24
Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-37977][table] Support VARIANT in user-defined functions and process table functions [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
2026/08/24
Re: [PR] [FLINK-40459][build] Bump Maven from 3.8.6 to 3.9.16 [flink]
via GitHub
Earlier messages
Later messages