issues  

Messages by Date

• 2026/10/12 [jira] [Updated] (FLINK-40979) HashAggITCase only runs its inherited tests without adaptive local hash aggregation Martijn Visser (Jira)
• 2026/10/12 [jira] [Updated] (FLINK-40981) ParameterizedTestExtension should fail tests that it does not parameterize Martijn Visser (Jira)
• 2026/10/12 [jira] [Created] (FLINK-40981) ParameterizedTestExtension should fail tests that it does not parameterize Martijn Visser (Jira)
• 2026/10/12 [jira] [Created] (FLINK-40979) HashAggITCase only runs its inherited tests without adaptive local hash aggregation Martijn Visser (Jira)
• 2026/10/12 [jira] [Created] (FLINK-40980) JsonRowDataSerDeSchemaTest array tests don't cover the JsonParser deserializer Martijn Visser (Jira)
• 2026/10/12 [PR] [FLINK-40978][table] Cast from VARIANT through FromVariantConverter [flink] via GitHub
• 2026/10/12 [PR] [hotfix][build] Remove stale IllegalImport suppressions [flink] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40908][Connectors/HBase] Update bundled hbase-default.xml and NOTICE to HBase 2.6.6 [flink-connector-hbase] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40974][tests] Fix object reuse runs of JavaProgramTestBase [flink] via GitHub
• 2026/10/12 [jira] [Closed] (FLINK-40908) HBaseITCase.test fails with expected: <6> but was: <0> Ferenc Csaky (Jira)
• 2026/10/12 Re: [PR] [FLINK-38907][postgres] Debezium publication filtering data lost [flink-cdc] via GitHub
• 2026/10/12 [jira] [Created] (FLINK-40977) ForSt JUnit 5 migration is incomplete Martijn Visser (Jira)
• 2026/10/12 [jira] [Created] (FLINK-40975) FlinkBushyJoinReorderRule drops or misplaces join conditions, producing wrong results Hanyu Zheng (Jira)
• 2026/10/12 Re: [PR] [FLINK-29775][tests][JUnit5 migration] Module: flink-statebackend-rocksdb [flink] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40903][runtime/network] Add source host info in TM disconnect error [flink] via GitHub
• 2026/10/12 [jira] [Commented] (FLINK-33533) Add documentation about performance for huge ProtoBuf definations ChenZhuo (Jira)
• 2026/10/12 [jira] [Commented] (FLINK-38078) DataStream API Execution Configuration doc contains deleted API usage ChenZhuo (Jira)
• 2026/10/12 [jira] [Commented] (FLINK-39237) Docs training links should not depend on the Flink release branch ChenZhuo (Jira)
• 2026/10/12 Re: [PR] [FLINK-40908][Connectors/HBase] Update bundled hbase-default.xml and NOTICE to HBase 2.6.6 [flink-connector-hbase] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40425][python][table] Support OVER windows in DataFrame API [flink] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40908][Connectors/HBase] Update bundled hbase-default.xml and NOTICE to HBase 2.6.6 [flink-connector-hbase] via GitHub
• 2026/10/12 [jira] [Created] (FLINK-40974) HadoopIOFormatsITCase#testJobWithObjectReuse runs without object reuse Martijn Visser (Jira)
• 2026/10/12 Re: [PR] [FLINK-36297][state] Wait for the periodic materialization scheduler to terminate on close [flink] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40971][parquet] Run ParquetTimestampITCase for all its parameters [flink] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40695] Add a retry state for failed ExecutionGraph creation [flink] via GitHub
• 2026/10/12 [jira] [Comment Edited] (FLINK-40970) [JUnit5 Migration] Migrate the JUnit 4 tests not covered by other subtasks Purushottam Sinha (Jira)
• 2026/10/12 [jira] [Updated] (FLINK-40971) ParquetTimestampITCase never runs its parameterized cases ASF GitHub Bot (Jira)
• 2026/10/12 [PR] [FLINK-40971][parquet] Run ParquetTimestampITCase for all its parameters [flink] via GitHub
• 2026/10/12 [jira] [Updated] (FLINK-40972) In case of IdentityCastRule CodeGen still produces dummy classes ASF GitHub Bot (Jira)
• 2026/10/12 [jira] [Commented] (FLINK-40971) ParquetTimestampITCase never runs its parameterized cases Purushottam Sinha (Jira)
• 2026/10/12 [jira] [Commented] (FLINK-40970) [JUnit5 Migration] Migrate the JUnit 4 tests not covered by other subtasks Purushottam Sinha (Jira)
• 2026/10/12 [jira] [Commented] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Purushottam Sinha (Jira)
• 2026/10/12 Re: [PR] [FLINK-40972][table] Do not generate cast classes in case of Identity casts [flink] via GitHub
• 2026/10/12 [jira] [Updated] (FLINK-40973) Fluss source fails on retriable errors during periodic table discovery ASF GitHub Bot (Jira)
• 2026/10/12 [jira] [Created] (FLINK-40973) Fluss source fails on retriable errors during periodic table discovery Xiaobing Fang (Jira)
• 2026/10/12 [jira] [Created] (FLINK-40972) In case of IdentityCastRule CodeGen still produces dummy classes Sergey Nuyanzin (Jira)
• 2026/10/12 Re: [PR] [BP-1.20][FLINK-38613][tests] Force number of splits in UnalignedCheckpointRescaleWithMixedExchangesITCase [flink] via GitHub
• 2026/10/12 [jira] [Comment Edited] (FLINK-27455) [JUnit5 Migration] SnapshotMigrationTestBase Martijn Visser (Jira)
• 2026/10/12 Re: [PR] [FLINK-40908][Connectors/HBase] Update bundled hbase-default.xml and NOTICE to HBase 2.6.6 [flink-connector-hbase] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40439][python] Add model provider management to the DataFrame API [flink] via GitHub
• 2026/10/12 [jira] [Commented] (FLINK-35491) [JUnit5 Migration] Module: Flink CDC modules Martijn Visser (Jira)
• 2026/10/12 [jira] [Assigned] (FLINK-32839) [JUnit5 Migration] The entrypoint, event, execution and externalresource packages of flink-runtime module Martijn Visser (Jira)
• 2026/10/12 Re: [PR] [FLINK-40908][Connectors/HBase] Update bundled hbase-default.xml and NOTICE to HBase 2.6.6 [flink-connector-hbase] via GitHub
• 2026/10/12 [jira] [Commented] (FLINK-34585) [JUnit5 Migration] Module: Flink CDC Martijn Visser (Jira)
• 2026/10/12 [jira] [Assigned] (FLINK-32841) [JUnit5 Migration] The failure, filecache, hadoop, heartbeat, highavailability and instance packages of flink-runtime module Martijn Visser (Jira)
• 2026/10/12 [jira] [Assigned] (FLINK-32841) [JUnit5 Migration] The failure, filecache, hadoop, heartbeat, highavailability and instance packages of flink-runtime module Martijn Visser (Jira)
• 2026/10/12 [jira] [Assigned] (FLINK-32838) [JUnit5 Migration] The deployment and dispatcher packages of flink-runtime module Martijn Visser (Jira)
• 2026/10/12 [jira] [Assigned] (FLINK-32839) [JUnit5 Migration] The entrypoint, event, execution and externalresource packages of flink-runtime module Martijn Visser (Jira)
• 2026/10/12 [jira] [Assigned] (FLINK-32838) [JUnit5 Migration] The deployment and dispatcher packages of flink-runtime module Martijn Visser (Jira)
• 2026/10/12 [jira] [Closed] (FLINK-34585) [JUnit5 Migration] Module: Flink CDC Martijn Visser (Jira)
• 2026/10/12 [jira] [Closed] (FLINK-35491) [JUnit5 Migration] Module: Flink CDC modules Martijn Visser (Jira)
• 2026/10/12 [jira] [Commented] (FLINK-32842) [JUnit5 Migration] The iterative, jobgraph and jobmanager packages of flink-runtime module Martijn Visser (Jira)
• 2026/10/12 [jira] [Commented] (FLINK-32853) [JUnit5 Migration] The security, taskmanager and source packages of flink-runtime module Martijn Visser (Jira)
• 2026/10/12 [jira] [Assigned] (FLINK-29776) [JUnit5 Migration] Module: flink-statebackend-changelog Martijn Visser (Jira)
• 2026/10/12 [jira] [Closed] (FLINK-40564) [JUnit5 Migration] Migrate flink-statebackend-changelog tests to JUnit 5 and AssertJ Martijn Visser (Jira)
• 2026/10/12 [jira] [Closed] (FLINK-40561) Migrate RocksDB state backend tests to JUnit 5 and AssertJ Martijn Visser (Jira)
• 2026/10/12 [jira] [Updated] (FLINK-40969) Rescale details endpoint returns 404 for latest events evicted from AdaptiveScheduler history ASF GitHub Bot (Jira)
• 2026/10/12 [jira] [Closed] (FLINK-27455) [JUnit5 Migration] SnapshotMigrationTestBase Martijn Visser (Jira)
• 2026/10/12 [jira] [Comment Edited] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests Rui Fan (Jira)
• 2026/10/12 Re: [PR] [FLINK-40907][Connectors/HBase] Download HBase from archive.apache.org in HBaseContainer [flink-connector-hbase] via GitHub
• 2026/10/12 Re: [PR] [runtime] Fix lifecycle and metric bookkeeping gaps in parallel action execution [flink-agents] via GitHub
• 2026/10/12 Re: [PR] [BP-2.2][FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
• 2026/10/12 [PR] [BP-2.3][FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40907][Connectors/HBase] Download HBase from archive.apache.org in HBaseContainer [flink-connector-hbase] via GitHub
• 2026/10/12 [PR] [BP-2.2][FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40344][table] Support selecting computed grouping expressions [flink] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
• 2026/10/12 [jira] [Commented] (FLINK-40471) Add per-UDF concurrency and batch size support to DataFrame API Dian Fu (Jira)
• 2026/10/12 [jira] [Assigned] (FLINK-40471) Add per-UDF concurrency and batch size support to DataFrame API Dian Fu (Jira)
• 2026/10/12 Re: [PR] [FLINK-40538][postgres] Skip WAL position search on idle publication … [flink-cdc] via GitHub
• 2026/10/12 [jira] [Commented] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Martijn Visser (Jira)
• 2026/10/12 [jira] [Assigned] (FLINK-40571) ProcessTableFunctionSemanticTests[process-stateful-multi-input-with-timeout] is flaky on master Martijn Visser (Jira)
• 2026/10/12 Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test [flink] via GitHub
• 2026/10/12 [jira] [Assigned] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Martijn Visser (Jira)
• 2026/10/12 [jira] [Commented] (FLINK-40886) BlobLibraryCacheManagerTest.testApplicationLevelJarSharing fails with FileAlreadyExistsException on the application directory Robin Varghese (Jira)
• 2026/10/12 [PR] [FLINK-40907][Connectors/HBase] Download HBase from archive.apache.org in HBaseContainer [flink-connector-hbase] via GitHub
• 2026/10/12 [jira] [Updated] (FLINK-40907) HBaseITCase.test cannot build the HBase image, hbase-2.6.6 tarball gone from dlcdn ASF GitHub Bot (Jira)
• 2026/10/12 [jira] [Resolved] (FLINK-40538) [Postgres] Connector never starts streaming on a database with no publication traffic Hongshun Wang (Jira)
• 2026/10/12 [jira] [Assigned] (FLINK-40538) [Postgres] Connector never starts streaming on a database with no publication traffic Hongshun Wang (Jira)
• 2026/10/12 [jira] [Assigned] (FLINK-40907) HBaseITCase.test cannot build the HBase image, hbase-2.6.6 tarball gone from dlcdn Martijn Visser (Jira)
• 2026/10/12 [jira] [Commented] (FLINK-40907) HBaseITCase.test cannot build the HBase image, hbase-2.6.6 tarball gone from dlcdn Yahya Kisana (Jira)
• 2026/10/12 [jira] [Commented] (FLINK-36297) SIGSEGV caused CI failure Martijn Visser (Jira)
• 2026/10/12 Re: [PR] [FLINK-36297][state] Wait for the periodic materialization scheduler to terminate on close [flink] via GitHub
• 2026/10/12 [jira] [Assigned] (FLINK-40907) HBaseITCase.test cannot build the HBase image, hbase-2.6.6 tarball gone from dlcdn Martijn Visser (Jira)
• 2026/10/12 Re: [PR] [FLINK-40908][Connectors/HBase] Update bundled hbase-default.xml and NOTICE to HBase 2.6.6 [flink-connector-hbase] via GitHub
• 2026/10/12 Re: [PR] [FLINK-35012][table] Fix flaky ChangelogNormalizeRestoreTest by adding padding records to prevent mini-batch merging [flink] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40806][table] Add PARSE_XML and TRY_PARSE_XML functions [flink] via GitHub
• 2026/10/12 [jira] [Commented] (FLINK-40471) Add per-UDF concurrency and batch size support to DataFrame API ChenZhuo (Jira)
• 2026/10/12 Re: [PR] [BP-3.6][FLINK-38450][iceberg] Fix duplicate records across schema changes and restore CI [flink-cdc] via GitHub
• 2026/10/12 Re: [PR] [runtime][java] Reuse saved Kafka action results after recovery [flink-agents] via GitHub
• 2026/10/12 Re: [PR] [runtime][java] Reject memory writes below a value field before mutating state [flink-agents] via GitHub
• 2026/10/12 Re: [PR] [FLINK-40806][table] Add PARSE_XML and TRY_PARSE_XML functions [flink] via GitHub
• 2026/10/12 Re: [I] [Bug][runtime] Kafka recovery can skip saved results for pending actions [flink-agents] via GitHub
• 2026/10/12 Re: [PR] [runtime][java] Reuse saved Kafka action results after recovery [flink-agents] via GitHub
• 2026/10/12 Re: [PR] [hotfix][docs] Add HTTP connector to externalized connectors list [flink] via GitHub
• 2026/10/12 Re: [I] [Bug][runtime] Memory writes below a value field mutate state before failing [flink-agents] via GitHub
• 2026/10/12 Re: [PR] [FLINK-39190] Relocate Jackson in filesystem plugin POMs to prevent classpath conflicts [flink] via GitHub
• 2026/10/12 Re: [PR] [runtime][java] Preserve pending Fluss action state across checkpoints [flink-agents] via GitHub
• 2026/10/12 Re: [PR] [FLINK-XXXXX][table] Add GEOGRAPHY Java API and runtime representation [flink] via GitHub
• 2026/10/12 Re: [PR] [FLINK-XXXXX][table] Add GEOGRAPHY logical type model [flink] via GitHub
• 2026/10/12 Re: [PR] [FLINK-39340][table] Add BinaryMultiJoinToJoinRule [flink] via GitHub
• 2026/10/11 Re: [PR] [api][runtime][java][python] Add event-backed chat calls from actions [flink-agents] via GitHub
• 2026/10/11 [jira] [Commented] (FLINK-40192) Add as-of join support to DataFrame API Dian Fu (Jira)
• 2026/10/11 [jira] [Assigned] (FLINK-40192) Add as-of join support to DataFrame API Dian Fu (Jira)
• 2026/10/11 Re: [PR] [api][runtime][java][python] Add event-backed chat calls from actions [flink-agents] via GitHub
• 2026/10/11 Re: [I] [Bug][runtime] Memory writes below a value field mutate state before failing [flink-agents] via GitHub
• 2026/10/11 [jira] [Commented] (FLINK-40658) UNNEST silently drops null ROW elements from ARRAY Dian Fu (Jira)
• 2026/10/11 [jira] [Closed] (FLINK-40658) UNNEST silently drops null ROW elements from ARRAY Dian Fu (Jira)
• 2026/10/11 Re: [PR] [FLINK-40658][table] Preserve null ROW elements in UNNEST [flink] via GitHub
• 2026/10/11 Re: [PR] [integration][observability] Add OpenTelemetry GenAI exporter for Agent Traces (Phase 1) [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [api][runtime][python] Replace Event Log with unified Trace Log [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [api][runtime][python] Support running a ReActAgent as a general-purpose sub-agent [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [api][runtime][python] Support running a ReActAgent as a general-purpose sub-agent [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [runtime][java] Reuse saved Kafka action results after recovery [flink-agents] via GitHub
• 2026/10/11 Re: [I] [Bug][runtime] An interrupted ordinary child in a mixed gather leaves completed durable results PENDING [flink-agents] via GitHub
• 2026/10/11 [jira] [Assigned] (FLINK-40908) HBaseITCase.test fails with expected: <6> but was: <0> Ferenc Csaky (Jira)
• 2026/10/11 Re: [I] [Bug][runtime] Lifecycle and metrics inconsistencies in parallel action execution [flink-agents] via GitHub
• 2026/10/11 [PR] [runtime][java] Avoid async-pool self-deadlock in internal sub-agent await (#1213) [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [FLINK-38907][postgres] Debezium publication filtering data lost [flink-cdc] via GitHub
• 2026/10/11 Re: [PR] [FLINK-40735][table] Compare non-time OVER accumulators with a generated equaliser [flink] via GitHub
• 2026/10/11 [jira] [Commented] (FLINK-40192) Add as-of join support to DataFrame API Bettle (Jira)
• 2026/10/11 Re: [I] [Bug] [runtime][python] ChatMessage argument digests change across processes and re-execute persisted durable calls [flink-agents] via GitHub
• 2026/10/11 [jira] [Closed] (FLINK-40856) Support zip-style multi-column explode in DataFrame API Dian Fu (Jira)
• 2026/10/11 Re: [PR] [FLINK-37246] add tokens acquired by current user for token refresh [flink] via GitHub
• 2026/10/11 Re: [PR] [FLINK-40856][python] Support zip-style multi-column DataFrame explode [flink] via GitHub
• 2026/10/11 Re: [I] [Tech Debt][API][ChatMessage] Review ChatMessage responsibilities and data model [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• 2026/10/11 Re: [I] [Tech Debt][runtime][python][skills] Preserve skill-repository close failures [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [Tech Debt][runtime][python] Preserve skill-repository close failures in SkillManager.close() [flink-agents] via GitHub
• 2026/10/11 Re: [I] [Bug][runtime] Lifecycle and metrics inconsistencies in parallel action execution [flink-agents] via GitHub
• 2026/10/11 Re: [I] [Tech Debt][runtime][python][skills] Preserve skill-repository close failures [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [runtime][java] Surface Kafka action-state send failures [flink-agents] via GitHub
• 2026/10/11 [jira] [Closed] (FLINK-40198) Add Kafka source and sink APIs to DataFrame API Dian Fu (Jira)
• 2026/10/11 Re: [PR] [runtime][java] Surface Kafka action-state send failures [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [api][runtime][java][python] Add event-backed chat calls from actions [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [api][runtime][java][python] Add event-backed chat calls from actions [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [Tech Debt][API][ReActAgent] Support skills in constructors [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [FLINK-40198][python] Add Kafka source and sink APIs to DataFrame API [flink] via GitHub
• 2026/10/11 Re: [PR] [api][plan][integrations][java][python] Apply an agent output schema natively on the final response [flink-agents] via GitHub
• 2026/10/11 [I] [Doc] Reorganize Chat Models, Chat Messages, and provider documentation [flink-agents] via GitHub
• 2026/10/11 [I] [Doc] Improve Model Routing examples and behavior reference [flink-agents] via GitHub
• 2026/10/11 [I] [Doc] Clarify API choices, language dimensions, and cross-language contracts [flink-agents] via GitHub
• 2026/10/11 [I] [Doc] Restructure documentation navigation and page hierarchy for 0.4 [flink-agents] via GitHub
• 2026/10/11 [I] [Doc] Improve Metrics and Logging user documentation [flink-agents] via GitHub
• 2026/10/11 [I] [Doc] Add documentation and release entry points for the Coding-agent Skill [flink-agents] via GitHub
• 2026/10/11 [I] [Doc] Improve consistency, Action State Store, and configuration guidance [flink-agents] via GitHub
• 2026/10/11 [I] [Doc] Clarify YAML reference and Tool Use responsibilities [flink-agents] via GitHub
• 2026/10/11 [I] [Doc] Improve Built-in ReAct Agent and Skills usage documentation [flink-agents] via GitHub
• 2026/10/11 [I] [Doc] Improve Setup and the Quickstart user journey [flink-agents] via GitHub
• 2026/10/11 [I] [Doc] Improve Agent core concepts, Actions, Events, and execution guides [flink-agents] via GitHub
• 2026/10/11 [I] [Doc][Umbrella] Restructure and improve documentation for 0.4 [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [FLINK-40425][python][table] Support OVER windows in DataFrame API [flink] via GitHub
• 2026/10/11 Re: [I] [Bug][runtime] Lifecycle and metrics inconsistencies in parallel action execution [flink-agents] via GitHub
• 2026/10/11 Re: [I] [Bug][runtime] Lifecycle and metrics inconsistencies in parallel action execution [flink-agents] via GitHub
• 2026/10/11 [PR] [runtime] Fix lifecycle and metric bookkeeping gaps in parallel action execution [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [FLINK-35012][table] Fix flaky ChangelogNormalizeRestoreTest by adding padding records to prevent mini-batch merging [flink] via GitHub
• 2026/10/11 Re: [PR] [FLINK-40960][runtime][JUnit5 Migration] Migrate the remaining of testing classes in taskmanager package of flink-runtime module [flink] via GitHub
• 2026/10/11 Re: [PR] [FLINK-40960][runtime][JUnit5 Migration] Migrate the remaining of testing classes in taskmanager package of flink-runtime module [flink] via GitHub
• 2026/10/11 [jira] [Assigned] (FLINK-36297) SIGSEGV caused CI failure Martijn Visser (Jira)
• 2026/10/11 Re: [PR] [FLINK-40960][runtime][JUnit5 Migration] Migrate the remaining of testing classes in taskmanager package of flink-runtime module [flink] via GitHub
• 2026/10/11 Re: [PR] [FLINK-40960][runtime][JUnit5 Migration] Migrate the remaining of testing classes in taskmanager package of flink-runtime module [flink] via GitHub
• 2026/10/11 Re: [PR] [FLINK-40960][runtime][JUnit5 Migration] Migrate the remaining of testing classes in taskmanager package of flink-runtime module [flink] via GitHub
• 2026/10/11 Re: [PR] [FLINK-40960][runtime][JUnit5 Migration] Migrate the remaining of testing classes in taskmanager package of flink-runtime module [flink] via GitHub
• 2026/10/11 [PR] Support skills in constructors [flink-agents] via GitHub
• 2026/10/11 [I] [Feature][chat-models] Apply the output schema on the tool-calling request when the provider supports both [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [api][plan][integrations][java][python] Apply an agent output schema natively on the final response [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [BP-1.20][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue. [flink] via GitHub
• 2026/10/11 Re: [PR] [BP-2.2][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/10/11 Re: [PR] [BP-2.3][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/10/11 Re: [PR] [runtime][java] Reuse saved Kafka action results after recovery [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [BP-1.20][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue. [flink] via GitHub
• 2026/10/11 [jira] [Comment Edited] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created Rui Fan (Jira)
• 2026/10/11 [jira] [Resolved] (FLINK-40657) FutureCompletingBlockingQueue retains a ConditionAndFlag for every SplitFetcher ever created Rui Fan (Jira)
• 2026/10/11 Re: [PR] [BP-2.3][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/10/11 Re: [PR] [BP-2.2][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue [flink] via GitHub
• 2026/10/11 Re: [PR] [FLINK-35515][hive] Add Hive 4 support to the Flink Hive connector [flink-connector-hive] via GitHub
• 2026/10/11 Re: [PR] [BP-3.6][FLINK-38450][iceberg] Fix duplicate records across schema changes and restore CI [flink-cdc] via GitHub
• 2026/10/11 Re: [PR] [FLINK-40856][python] Support zip-style multi-column DataFrame explode [flink] via GitHub
• 2026/10/11 [jira] [Updated] (FLINK-40856) Support zip-style multi-column explode in DataFrame API ASF GitHub Bot (Jira)
• 2026/10/11 [PR] [FLINK-40856][python] Support zip-style multi-column DataFrame explode [flink] via GitHub
• 2026/10/11 Re: [I] [Feature] Support in-process internal sub-agent [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [runtime][java] Reuse saved Kafka action results after recovery [flink-agents] via GitHub
• 2026/10/11 Re: [PR] [FLINK-40425][python][table] Support OVER windows in DataFrame API [flink] via GitHub
• 2026/10/11 Re: [PR] [FLINK-40425][python][table] Support OVER windows in DataFrame API [flink] via GitHub
• 2026/10/11 Re: [PR] [FLINK-40425][python][table] Support OVER windows in DataFrame API [flink] via GitHub
• 2026/10/11 [jira] [Assigned] (FLINK-38046) Solve the issue of missing one piece of data Martijn Visser (Jira)
• 2026/10/11 [jira] [Resolved] (FLINK-40748) PreparedSplitterNumericParameters.withBatchSize reads past maxVal Martijn Visser (Jira)
• 2026/10/11 Re: [PR] [FLINK-40748][jdbc] Keep PreparedSplitterNumericParameters inside maxVal [flink-connector-jdbc] via GitHub
• 2026/10/10 [jira] [Updated] (FLINK-40126) Implement Topic integrity checks in Kafka Connector ASF GitHub Bot (Jira)
• 2026/10/10 Re: [PR] [FLINK-40126][connector] Topic integrity checks (draft) [flink-connector-kafka] via GitHub
• 2026/10/10 Re: [PR] [FLINK-39281] Flink Connector redis stream Source [flink-connector-redis-streams] via GitHub
• 2026/10/10 Re: [PR] [api][plan][integrations][java][python] Apply an agent output schema natively on the final response [flink-agents] via GitHub
• 2026/10/10 Re: [PR] [api][runtime][java][python] Add event-backed chat calls from actions [flink-agents] via GitHub
• 2026/10/10 Re: [PR] [runtime][java] Replay pending Kafka action state on recovery [flink-agents] via GitHub
• 2026/10/10 Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40636][ci] Add Maven and Aether connection timeouts to avoid 50-minute hangs [flink-connector-shared-utils] via GitHub
• 2026/10/10 Re: [PR] [BP-2.2][FLINK-38613][tests] Force number of splits in UnalignedCheckpointRescaleWithMixedExchangesITCase [flink] via GitHub

• Earlier messages
• Later messages