issues
Thread
Date
Earlier messages
Later messages
Messages by Date
2026/08/01
[jira] (FLINK-40282) Expand and correct the concepts Glossary
Lorenzo Nicora (Jira)
2026/08/01
[PR] [FLINK-40282][docs] Expand and correct the concepts Glossary [flink]
via GitHub
2026/08/01
[jira] [Commented] (FLINK-40269) Unaligned checkpoint restore may fail after rescale when a two-input task reads from the same upstream
Rui Fan (Jira)
2026/08/01
[jira] [Updated] (FLINK-40269) Unaligned checkpoint restore may fail after rescale when a two-input task reads from the same upstream
Rui Fan (Jira)
2026/08/01
Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink]
via GitHub
2026/08/01
[jira] [Updated] (FLINK-40282) Expand and correct the concepts Glossary
Lorenzo Nicora (Jira)
2026/08/01
Re: [PR] [FLINK-39984][runtime][webUI] Support LITE/FULL thread dump modes [flink]
via GitHub
2026/08/01
[jira] [Commented] (FLINK-40282) Expand and correct the concepts Glossary
Lorenzo Nicora (Jira)
2026/08/01
[jira] [Created] (FLINK-40282) Expand and correct the concepts Glossary
Lorenzo Nicora (Jira)
2026/08/01
Re: [PR] [FLINK-39984][runtime] Dispatch thread dump to ioExecutor [flink]
via GitHub
2026/08/01
[jira] [Created] (FLINK-40281) Improve HTTP sink failure observability
Bharath Reddy Gunapati (Jira)
2026/08/01
[jira] [Updated] (FLINK-40277) Add HTTP sink response classification and retry support
ASF GitHub Bot (Jira)
2026/08/01
[PR] [FLINK-40277][connector-http] Add HTTP sink response classification and retries [flink-connector-http]
via GitHub
2026/08/01
[jira] [Created] (FLINK-40280) Document HTTP sink retry, error handling, and configuration parity
Bharath Reddy Gunapati (Jira)
2026/08/01
[jira] [Created] (FLINK-40279) Add HTTP sink parity for OIDC, proxy, and HTTP version configuration
Bharath Reddy Gunapati (Jira)
2026/08/01
[jira] [Created] (FLINK-40278) Define and implement HTTP sink batch retry semantics
Bharath Reddy Gunapati (Jira)
2026/08/01
[jira] [Closed] (FLINK-40276) Add HTTP sink response classification and retry support
Bharath Reddy Gunapati (Jira)
2026/08/01
[jira] [Created] (FLINK-40277) Add HTTP sink response classification and retry support
Bharath Reddy Gunapati (Jira)
2026/08/01
[jira] [Closed] (FLINK-40229) Introduce HttpSinkConfig and wire core sink options via ReadableConfig
Bharath Reddy Gunapati (Jira)
2026/08/01
[jira] [Created] (FLINK-40275) Improve HTTP sink parity with HTTP lookup source
Bharath Reddy Gunapati (Jira)
2026/08/01
[jira] [Created] (FLINK-40276) Add HTTP sink response classification and retry support
Bharath Reddy Gunapati (Jira)
2026/08/01
Re: [PR] [FLINK-39771][tests][JUnit5 migration] Module: flink-cep [flink]
via GitHub
2026/08/01
Re: [PR] [FLINK-39771][tests][JUnit5 migration] Module: flink-cep [flink]
via GitHub
2026/08/01
Re: [PR] [FLINK-39771][tests][JUnit5 migration] Module: flink-cep [flink]
via GitHub
2026/08/01
Re: [PR] [FLINK-39771][tests][JUnit5 migration] Module: flink-cep [flink]
via GitHub
2026/08/01
Re: [PR] [FLINK-39771][tests][JUnit5 migration] Module: flink-cep [flink]
via GitHub
2026/08/01
Re: [PR] [FLINK-39771][tests][JUnit5 migration] Module: flink-cep [flink]
via GitHub
2026/08/01
[jira] [Updated] (FLINK-39876) [JUnit5 Migration] Migrate flink-streaming-java assertions to AssertJ
Purushottam Sinha (Jira)
2026/08/01
[jira] [Closed] (FLINK-39878) [JUnit5 Migration] Migrate flink-sql-parser assertions to AssertJ
Purushottam Sinha (Jira)
2026/08/01
[jira] [Commented] (FLINK-39877) [JUnit5 Migration] Migrate flink-runtime assertions to AssertJ
Purushottam Sinha (Jira)
2026/08/01
[jira] [Commented] (FLINK-39878) [JUnit5 Migration] Migrate flink-sql-parser assertions to AssertJ
Purushottam Sinha (Jira)
2026/08/01
[jira] [Commented] (FLINK-39876) [JUnit5 Migration] Migrate flink-streaming-java assertions to AssertJ
Purushottam Sinha (Jira)
2026/08/01
[jira] [Closed] (FLINK-39877) [JUnit5 Migration] Migrate flink-runtime assertions to AssertJ
Purushottam Sinha (Jira)
2026/08/01
[jira] [Closed] (FLINK-39876) [JUnit5 Migration] Migrate flink-streaming-java assertions to AssertJ
Purushottam Sinha (Jira)
2026/08/01
Re: [PR] [FLINK-39876][tests] Migrate flink-streaming-java assertions to AssertJ [flink]
via GitHub
2026/08/01
Re: [PR] [FLINK-39876][tests] Migrate flink-streaming-java assertions to AssertJ [flink]
via GitHub
2026/08/01
Re: [PR] [FLINK-39876][tests] Migrate flink-streaming-java assertions to AssertJ [flink]
via GitHub
2026/08/01
Re: [PR] [FLINK-39876][tests] Migrate flink-streaming-java assertions to AssertJ [flink]
via GitHub
2026/08/01
Re: [PR] [FLINK-39876][tests] Migrate flink-streaming-java assertions to AssertJ [flink]
via GitHub
2026/08/01
Re: [PR] [FLINK-40267][table-planner] Validate persisted columns on CREATE MATERIALIZED TABLE [flink]
via GitHub
2026/08/01
[jira] [Updated] (FLINK-40274) [Flink CDC][cdc-cli] Remove unsupported kubernetes-session from target option help message
jaejun lee (Jira)
2026/08/01
[jira] [Updated] (FLINK-40274) [Flink CDC][cdc-cli] Remove unsupported kubernetes-session from target option help message
ASF GitHub Bot (Jira)
2026/08/01
[PR] [FLINK-40274][cdc-cli] Remove unsupported kubernetes-session from target option help message [flink-cdc]
via GitHub
2026/08/01
[jira] [Updated] (FLINK-40274) [Flink CDC][cdc-cli] Remove unsupported kubernetes-session from target option help message
jaejun lee (Jira)
2026/08/01
[jira] [Created] (FLINK-40274) Flink CDC Remove unsupported kubernetes-session from target option help message
jaejun lee (Jira)
2026/08/01
[jira] [Resolved] (FLINK-40272) Add cache file for checkstyle
Sergey Nuyanzin (Jira)
2026/08/01
[jira] [Commented] (FLINK-40272) Add cache file for checkstyle
Sergey Nuyanzin (Jira)
2026/08/01
Re: [PR] [FLINK-40272][build] Add cache file for checkstyle [flink]
via GitHub
2026/08/01
Re: [PR] [FLINK-40272][build] Add cache file for checkstyle [flink]
via GitHub
2026/08/01
Re: [PR] [FLINK-40272][build] Add cache file for checkstyle [flink]
via GitHub
2026/08/01
[jira] [Commented] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE
Qiu Yanjun (Jira)
2026/07/31
Re: [PR] [FLINK-40187][python] Introduce DataType class in DataFrame API [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-35324][formats] Avro format can not perform projection pushdown for specific fields [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40187][python] Introduce DataType class in DataFrame API [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40187][python] Introduce DataType class in DataFrame API [flink]
via GitHub
2026/07/31
Re: [PR] [api][plan][runtime] Introduce AGENT resource type and sub-agent invocation API [flink-agents]
via GitHub
2026/07/31
Re: [PR] [FLINK-35324][formats] Avro format can not perform projection pushdown for specific fields [flink]
via GitHub
2026/07/31
Re: [PR] [hotfix] Fix broken links and markup in website source [flink-web]
via GitHub
2026/07/31
Re: [I] [Bug] Bounded workflows silently drop records in batch mode with multiple keys [flink-agents]
via GitHub
2026/07/31
[PR] [hotfix] Fix broken links and markup in website source [flink-web]
via GitHub
2026/07/31
Re: [PR] [FLINK-39193][Kafka Connector] Fix Kafka client compatibility for committed offset lookup [flink-connector-kafka]
via GitHub
2026/07/31
Re: [PR] [FLINK-39215] [python] Clean up PythonDriver tmp dir on launch failure [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39132] [e2e] Stabilize Kubernetes materialized table test [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39587][runtime-web] Remove eslint cache from web dashboard lint [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39962] [runtime] Fix flaky DeclarativeSlotPoolBridgeTest [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39963][runtime/tests] Stabilize balanced input slow task detector test [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39429][cdc-base] Avoid shaded Guava in incremental source fetchers [flink-cdc]
via GitHub
2026/07/31
Re: [PR] [FLINK-39687] [sql-gateway] Fix URI dependency conversion in SessionContext [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39613][runtime] Unquote schema metadata keys [flink-cdc]
via GitHub
2026/07/31
Re: [PR] [FLINK-39954][tests] Relax SinkV2 scaling commit assertion [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40051][pipeline-connector/hudi] Fix schema operator UID with operator UID prefix [flink-cdc]
via GitHub
2026/07/31
Re: [PR] [FLINK-40152][connector/postgres] Make table filtering case-sensitive [flink-cdc]
via GitHub
2026/07/31
Re: [PR] [FLINK-39620] [table-runtime] Add restored cumulative window regression [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39572] [python] Hide sensitive process environment values in logs [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39674][formats] Upgrade Confluent Schema Registry client [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39771][tests][JUnit5 migration] Module: flink-cep [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40272][build] Add cache file for checkstyle [flink]
via GitHub
2026/07/31
Re: [D] [Feature] Sub-agent Resource for Flink Agents - Framework part [flink-agents]
via GitHub
2026/07/31
Re: [PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc]
via GitHub
2026/07/31
[jira] [Updated] (FLINK-40273) JDBC docs: update for the 4.x module split and Sink V2 API
ASF GitHub Bot (Jira)
2026/07/31
[PR] [FLINK-40273][docs] Update JDBC documentation for the 4.x module split and APIs [flink-connector-jdbc]
via GitHub
2026/07/31
[jira] [Created] (FLINK-40273) JDBC docs: update for the 4.x module split and Sink V2 API
Purushottam Sinha (Jira)
2026/07/31
Re: [PR] [FLINK-39900] [forst] Add configuration option for setting the number of ForSt transfer threads [flink]
via GitHub
2026/07/31
[jira] [Commented] (FLINK-40265) BinaryStringData.compareTo uses inconsistent UTF-16 and UTF-8 ordering for SMP characters
Qiu Yanjun (Jira)
2026/07/31
[jira] [Updated] (FLINK-40135) [PyFlink] Prevent Beam state access after runner shutdown
ASF GitHub Bot (Jira)
2026/07/31
Re: [PR] [FLINK-40135][python] Prevent Beam state access after runner shutdown [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-32212][runtime] Match library BLOBs by content in BlobLibraryCacheManager [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-32212][runtime] Match library BLOBs by content in BlobLibraryCacheManager [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-32212][runtime] Match library BLOBs by content in BlobLibraryCacheManager [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-32212][runtime] Match library BLOBs by content in BlobLibraryCacheManager [flink]
via GitHub
2026/07/31
Re: [PR] [DON'T MERGE][FLINK-40269] Simplification suggestion [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40272][build] Add cache file for checkstyle [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink]
via GitHub
2026/07/31
[jira] [Updated] (FLINK-40272) Add cache file for checkstyle
ASF GitHub Bot (Jira)
2026/07/31
[PR] [FLINK-40272][build] Add cache file for checkstyle [flink]
via GitHub
2026/07/31
[jira] [Created] (FLINK-40272) Add cache file for checkstyle
Sergey Nuyanzin (Jira)
2026/07/31
[jira] [Resolved] (FLINK-40233) JSON functions return NULL when sharing a parsed input
Sergey Nuyanzin (Jira)
2026/07/31
[jira] [Commented] (FLINK-40233) JSON functions return NULL when sharing a parsed input
Sergey Nuyanzin (Jira)
2026/07/31
Re: [PR] [FLINK-40233][table] Correctly share the parsed JSON across `JSON_VALUE`/`JSON_QUERY` calls when the owning call is skipped because of `NULL` or not taken branch [flink]
via GitHub
2026/07/31
[jira] [Updated] (FLINK-39900) Support configuring the number of threads used in ForStStateDataTransfer
Sergey Nuyanzin (Jira)
2026/07/31
[jira] [Reopened] (FLINK-39900) Support configuring the number of threads used in ForStStateDataTransfer
Sergey Nuyanzin (Jira)
2026/07/31
[jira] [Commented] (FLINK-39900) Support configuring the number of threads used in ForStStateDataTransfer
Sergey Nuyanzin (Jira)
2026/07/31
Re: [PR] [hotfix][build] Fix compilation [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on native s3 [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39900] [forst] Add configuration option for setting the number of ForSt transfer threads [flink]
via GitHub
2026/07/31
Re: [PR] [hotfix][build] Fix compilation [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40256][docs] Include sub-package config options in the configuration reference [flink]
via GitHub
2026/07/31
Re: [PR] [hotfix][docs] Add code review guidelines to AGENTS.md [flink]
via GitHub
2026/07/31
[PR] [hotfix][docs] Add code review guidelines to AGENTS.md [flink]
via GitHub
2026/07/31
Re: [PR] [DON'T MERGE][FLINK-40269] Simplification suggestion [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink]
via GitHub
2026/07/31
[PR] [FLINK-40269] Simplification suggestion [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink]
via GitHub
2026/07/31
Re: [PR] [hotfix][build] Fix compilation [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39900] [forst] Add configuration option for setting the number of ForSt transfer threads [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39900] [forst] Add configuration option for setting the number of ForSt transfer threads [flink]
via GitHub
2026/07/31
[PR] [hotfix][build] Fix compilation [flink]
via GitHub
2026/07/31
[jira] [Resolved] (FLINK-39490) [web dashboard] Improve feedback when cluster is unreachable
Yuepeng Pan (Jira)
2026/07/31
Re: [PR] [FLINK-39490][runtime-web] Improve feedback when cluster is unreachable [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-25802][FLINK-30499][table-planner] Fix TIMESTAMP codegen for RANGE OVER window bounds [flink]
via GitHub
2026/07/31
[jira] [Updated] (FLINK-25802) OverWindow in batch mode failed
ASF GitHub Bot (Jira)
2026/07/31
[PR] [FLINK-25802][FLINK-30499][table-planner] Fix TIMESTAMP codegen for RANGE OVER window bounds [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40268][table] Add new JSON_TYPE function [flink]
via GitHub
2026/07/31
[jira] [Assigned] (FLINK-40271) Group window properties produce invalid SQL in QueryOperation#asSerializableString
Mika Naylor (Jira)
2026/07/31
[jira] [Created] (FLINK-40271) Group window properties produce invalid SQL in QueryOperation#asSerializableString
Timo Theusner (Jira)
2026/07/31
Re: [I] [Feature] [integration] Integrate built-in IBM watsonx.ai chat model [flink-agents]
via GitHub
2026/07/31
Re: [PR] [FLINK-40270][connector-base][runtime] Make source threads job-attributable via MDC propagation and thread names [flink]
via GitHub
2026/07/31
[jira] [Updated] (FLINK-40270) Make source fetcher and coordinator threads job-attributable (MDC + thread names)
ASF GitHub Bot (Jira)
2026/07/31
[PR] [FLINK-40270][connector-base][runtime] Make source threads job-attributable via MDC propagation and thread names [flink]
via GitHub
2026/07/31
[jira] [Commented] (FLINK-40251) Support Process Table Function (PTF) in Python Table API
Timo Walther (Jira)
2026/07/31
[jira] [Assigned] (FLINK-40270) Make source fetcher and coordinator threads job-attributable (MDC + thread names)
Roman Khachatryan (Jira)
2026/07/31
[jira] [Created] (FLINK-40270) Make source fetcher and coordinator threads job-attributable (MDC + thread names)
Aleksandr Savonin (Jira)
2026/07/31
[jira] [Closed] (FLINK-40208) Support adding jobConfiguration keys of choice to logging MDC
Roman Khachatryan (Jira)
2026/07/31
[jira] [Resolved] (FLINK-39900) Support configuring the number of threads used in ForStStateDataTransfer
Zakelly Lan (Jira)
2026/07/31
[jira] [Commented] (FLINK-39900) Support configuring the number of threads used in ForStStateDataTransfer
Zakelly Lan (Jira)
2026/07/31
Re: [PR] [FLINK-39900] [forst] Add configuration option for setting the number of ForSt transfer threads [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink]
via GitHub
2026/07/31
[jira] [Updated] (FLINK-40269) Unaligned checkpoint restore may fail after rescale when a two-input task reads from the same upstream
ASF GitHub Bot (Jira)
2026/07/31
[PR] [FLINK-40269][runtime] Fix channel state assignment for duplicate connections [flink]
via GitHub
2026/07/31
Re: [PR] [api][runtime][python] Add memory events for agent memory observability [flink-agents]
via GitHub
2026/07/31
[jira] [Closed] (FLINK-40227) VariantSerializer.deserialize ignores DataInputView#read return value, corrupting Variant state restore
Ferenc Csaky (Jira)
2026/07/31
Re: [PR] [FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink]
via GitHub
2026/07/31
Re: [PR] [BP-2.2][FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink]
via GitHub
2026/07/31
Re: [PR] [BP-2.3][FLINK-40227][core] Use readFully to read Variant value/metadata in VariantSerializer.deserialize [flink]
via GitHub
2026/07/31
[jira] [Updated] (FLINK-40227) VariantSerializer.deserialize ignores DataInputView#read return value, corrupting Variant state restore
Ferenc Csaky (Jira)
2026/07/31
[jira] [Updated] (FLINK-40227) VariantSerializer.deserialize ignores DataInputView#read return value, corrupting Variant state restore
Ferenc Csaky (Jira)
2026/07/31
[jira] [Updated] (FLINK-40227) VariantSerializer.deserialize ignores DataInputView#read return value, corrupting Variant state restore
Ferenc Csaky (Jira)
2026/07/31
[jira] [Updated] (FLINK-40227) VariantSerializer.deserialize ignores DataInputView#read return value, corrupting Variant state restore
Ferenc Csaky (Jira)
2026/07/31
Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-37925][table] Define VARIANT cast rules so a cast never alters the stored value [flink]
via GitHub
2026/07/31
Re: [PR] Flink 40208/job mdc registry [flink]
via GitHub
2026/07/31
[PR] Flink 40208/job mdc registry [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39925][Autoscaler] Skip scaling decisions when vertex IO metrics are incomplete to prevent incorrect scale down [flink-kubernetes-operator]
via GitHub
2026/07/31
Re: [PR] [Feature] Parallel Tool Call Execution [flink-agents]
via GitHub
2026/07/31
Re: [D] [Feature] Sub-agent Resource for Flink Agents - Framework part [flink-agents]
via GitHub
2026/07/31
Re: [D] [Feature] Sub-agent Resource for Flink Agents - Framework part [flink-agents]
via GitHub
2026/07/31
Re: [PR] [FLINK-40267][table-planner] Validate persisted columns on CREATE MATERIALIZED TABLE [flink]
via GitHub
2026/07/31
[jira] [Updated] (FLINK-40267) CREATE MATERIALIZED TABLE skips persisted-metadata-column validation applied by CREATE OR ALTER
ASF GitHub Bot (Jira)
2026/07/31
[PR] [FLINK-40267][table-planner] Validate persisted columns on CREATE MATERIALIZED TABLE [flink]
via GitHub
2026/07/31
[jira] [Commented] (FLINK-40262) Support matching Avro record fields by name in the Avro RowData converters
Dale Lane (Jira)
2026/07/31
Re: [PR] [FLINK-39490][runtime-web] Improve feedback when cluster is unreachable [flink]
via GitHub
2026/07/31
Re: [PR] [hotfix][docs] Remove dangling references to removed Hive connector docs [flink]
via GitHub
2026/07/31
Re: [PR] [hotfix][docs] Remove dangling references to removed Hive connector docs [flink]
via GitHub
2026/07/31
Re: [PR] [hotfix][docs] Remove dangling references to removed Hive connector docs [flink]
via GitHub
2026/07/31
Re: [PR] [hotfix][docs] Remove dangling references to removed Hive connector docs [flink]
via GitHub
2026/07/31
Re: [D] [Feature] Sub-agent Resource for Flink Agents - Framework part [flink-agents]
via GitHub
2026/07/31
[PR] [runtime][python] Refresh imports for new dependency generations [flink-agents]
via GitHub
2026/07/31
[PR] [runtime][python] Release Pemja objects when closing action executor [flink-agents]
via GitHub
2026/07/31
[I] [Bug] PythonActionExecutor leaks Pemja PyObject references across task restarts [flink-agents]
via GitHub
2026/07/31
[I] [Bug] Refresh Python import state when Flink replaces dependency directories [flink-agents]
via GitHub
2026/07/31
Re: [PR] [FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator [flink]
via GitHub
2026/07/31
Re: [PR] [FLINK-39215] [python] Clean up PythonDriver tmp dir on launch failure [flink]
via GitHub
2026/07/30
Re: [PR] [runtime][java][python] Add CEL Action condition filtering [flink-agents]
via GitHub
2026/07/30
Re: [PR] [FLINK-40187][python] Introduce DataType class in DataFrame API [flink]
via GitHub
2026/07/30
Re: [PR] [integrations][openai] Apply OpenAI native structured output [flink-agents]
via GitHub
2026/07/30
Re: [PR] [integrations][java][python] Apply Azure OpenAI native structured output [flink-agents]
via GitHub
2026/07/30
Re: [PR] [runtime][java][python] Add CEL Action condition filtering [flink-agents]
via GitHub
2026/07/30
Re: [PR] [hotfix][docs] Remove dangling references to removed Hive connector docs [flink]
via GitHub
2026/07/30
[PR] [hotfix][docs] Remove dangling references to removed Hive connector docs [flink]
via GitHub
2026/07/30
Re: [PR] [integrations][java][python] Apply Azure OpenAI native structured output [flink-agents]
via GitHub
2026/07/30
[jira] [Updated] (FLINK-40257) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE
soyeong choe (Jira)
2026/07/30
[jira] [Closed] (FLINK-40259) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE
soyeong choe (Jira)
2026/07/30
[jira] [Closed] (FLINK-40258) MongoDB CDC SampleBucketSplitStrategy calculates negative $sample size when collection count exceeds Integer.MAX_VALUE
soyeong choe (Jira)
2026/07/30
Re: [PR] [FLINK-39874][filesystems] Fix temp file leak on native s3 [flink]
via GitHub
2026/07/30
[jira] [Updated] (FLINK-37918) Restore the ability to set an interval for GetRecords calls to Kinesis shards.
hajimeni (Jira)
2026/07/30
Re: [PR] [FLINK-39732] Introduce ObjectIdDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) [flink-cdc]
via GitHub
2026/07/30
Re: [PR] [FLINK-39198] Fix data loss during restoration from checkpoint in TIMESTAMP startup mode. [flink-cdc]
via GitHub
2026/07/30
[jira] [Comment Edited] (FLINK-40253) [Prometheus] PrometheusPushGatewayReporter fails to read boolean configuration values from YAML file
Yao Zhang (Jira)
2026/07/30
[jira] [Commented] (FLINK-40253) [Prometheus] PrometheusPushGatewayReporter fails to read boolean configuration values from YAML file
Yao Zhang (Jira)
2026/07/30
Re: [PR] [FLINK-39732] Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) [flink-cdc]
via GitHub
Earlier messages
Later messages