issues  

Messages by Date

• 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
• 2026/10/10 Re: [PR] [FLINK-40757][Connectors/Elasticsearch] Add a PR template with AI disclosure [flink-connector-elasticsearch] via GitHub
• 2026/10/10 [jira] [Closed] (FLINK-40636) Add Maven/Aether connection timeouts to shared connector CI to avoid 50-minute hangs Sylwester Lachiewicz (Jira)
• 2026/10/10 Re: [PR] [FLINK-32806][runtime] Support eviction of clean job result entries in EmbeddedJobResultStore [flink] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40771][Connectors/Redis Streams] Add a PR template with AI disclosure [flink-connector-redis-streams] via GitHub
• 2026/10/10 [jira] [Closed] (FLINK-40636) Add Maven/Aether connection timeouts to shared connector CI to avoid 50-minute hangs Sylwester Lachiewicz (Jira)
• 2026/10/10 Re: [PR] [api][plan][runtime][python] Support registering an Agent as an in-process internal sub-agent [flink-agents] via GitHub
• 2026/10/10 [jira] [Updated] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests Rui Fan (Jira)
• 2026/10/10 Re: [PR] [FLINK-40768][Connectors/Cassandra] Add a PR template with AI disclosure [flink-connector-cassandra] via GitHub
• 2026/10/10 [PR] [Tech Debt][runtime][python] Preserve skill-repository close failures in SkillManager.close() [flink-agents] via GitHub
• 2026/10/10 Re: [I] [Tech Debt][runtime][python][skills] Preserve skill-repository close failures [flink-agents] via GitHub
• 2026/10/10 [jira] [Reopened] (FLINK-40636) Add Maven/Aether connection timeouts to shared connector CI to avoid 50-minute hangs Sylwester Lachiewicz (Jira)
• 2026/10/10 Re: [PR] [FLINK-36297][state] Wait for the periodic materialization scheduler to terminate on close [flink] via GitHub
• 2026/10/10 [jira] [Resolved] (FLINK-40757) Add a PR template with AI disclosure for flink-connector-elasticsearch Rui Fan (Jira)
• 2026/10/10 Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• 2026/10/10 Re: [PR] [BP-1.20][FLINK-38613][tests] Force number of splits in UnalignedCheckpointRescaleWithMixedExchangesITCase [flink] via GitHub
• 2026/10/10 [jira] [Updated] (FLINK-40866) Add FlinkMiniClusterController and register the FlinkMiniCluster kind Dale Lane (Jira)
• 2026/10/10 Re: [PR] [FLINK-40757][Connectors/Elasticsearch] Add a PR template with AI disclosure [flink-connector-elasticsearch] via GitHub
• 2026/10/10 [jira] [Commented] (FLINK-38613) UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint failed in test_cron_jdk11 tests Rui Fan (Jira)
• 2026/10/10 [PR] [BP-1.20][FLINK-38613][tests] Force number of splits in UnalignedCheckpointRescaleWithMixedExchangesITCase [flink] via GitHub
• 2026/10/10 [PR] [BP-2.2][FLINK-38613][tests] Force number of splits in UnalignedCheckpointRescaleWithMixedExchangesITCase [flink] via GitHub
• 2026/10/10 [jira] [Resolved] (FLINK-40756) Add a PR template with AI disclosure for flink-shaded Rui Fan (Jira)
• 2026/10/10 Re: [PR] [FLINK-40770][Connectors/RabbitMQ] Add a PR template with AI disclosure [flink-connector-rabbitmq] via GitHub
• 2026/10/10 [jira] [Resolved] (FLINK-40770) Add a PR template with AI disclosure for flink-connector-rabbitmq Rui Fan (Jira)
• 2026/10/10 [jira] [Resolved] (FLINK-40764) Add a PR template with AI disclosure for flink-benchmarks Rui Fan (Jira)
• 2026/10/10 [jira] [Resolved] (FLINK-40758) Add a PR template with AI disclosure for flink-connector-http Rui Fan (Jira)
• 2026/10/10 [jira] [Resolved] (FLINK-40750) Add AI disclosure to the Flink AWS connectors PR template Rui Fan (Jira)
• 2026/10/10 [jira] [Resolved] (FLINK-40771) Add a PR template with AI disclosure for flink-connector-redis-streams Rui Fan (Jira)
• 2026/10/10 [jira] [Resolved] (FLINK-40768) Add a PR template with AI disclosure for flink-connector-cassandra Rui Fan (Jira)
• 2026/10/10 [jira] [Resolved] (FLINK-40769) Add a PR template with AI disclosure for flink-connector-gcp-pubsub Rui Fan (Jira)
• 2026/10/10 Re: [PR] [FLINK-40769][Connectors/Google PubSub] Add a PR template with AI disclosure [flink-connector-gcp-pubsub] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40758][Connectors/HTTP] Add a PR template with AI disclosure [flink-connector-http] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40750][Connectors/AWS] Add AI disclosure to the PR template [flink-connector-aws] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40769][Connectors/Google PubSub] Add a PR template with AI disclosure [flink-connector-gcp-pubsub] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40771][Connectors/Redis Streams] Add a PR template with AI disclosure [flink-connector-redis-streams] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40770][Connectors/RabbitMQ] Add a PR template with AI disclosure [flink-connector-rabbitmq] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40764][benchmarks] Add a PR template with AI disclosure [flink-benchmarks] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40750][Connectors/AWS] Add AI disclosure to the PR template [flink-connector-aws] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40768][Connectors/Cassandra] Add a PR template with AI disclosure [flink-connector-cassandra] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40756][shaded] Add a PR template with AI disclosure [flink-shaded] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40046][runtime-web] Upgrade @antv/g2 to v5 [flink] via GitHub
• 2026/10/10 Re: [PR] [FLINK-38907][postgres] Debezium publication filtering data lost [flink-cdc] 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] [FLINK-40198][python] Add Kafka source and sink APIs to DataFrame API [flink] via GitHub
• 2026/10/10 [jira] [Updated] (FLINK-40850) Fluss sink rejects pre-created primary-key tables with custom bucket keys Hongshun Wang (Jira)
• 2026/10/10 Re: [PR] [FLINK-40218][core] Store a JSON number literal in the VARIANT builder like PARSE_JSON [flink] via GitHub
• 2026/10/10 [PR] [api][runtime][python] Replace Event Log with unified Trace Log [flink-agents] via GitHub
• 2026/10/10 Re: [PR] Add Flink CDC 3.7.0 release blog [flink-web] via GitHub
• 2026/10/10 [PR] [api][runtime][java][python] Add event-backed chat calls from actions [flink-agents] via GitHub
• 2026/10/10 Re: [PR] [api][runtime][java][python] Add non-durable async execution [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-40850][pipeline-connector/fluss] Accept custom bucket keys in pre-created primary-key tables [flink-cdc] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40198][python] Add Kafka source and sink APIs to DataFrame API [flink] via GitHub
• 2026/10/10 [jira] [Resolved] (FLINK-40218) Let callers that already hold parsed JSON build a Variant without a String round trip Sergey Nuyanzin (Jira)
• 2026/10/10 [jira] [Commented] (FLINK-40218) Let callers that already hold parsed JSON build a Variant without a String round trip Sergey Nuyanzin (Jira)
• 2026/10/10 Re: [PR] [BP-1.20][FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue. [flink] via GitHub
• 2026/10/10 Re: [D] [Discussion][Observability] Replace Event Log with a Unified Trace Log [flink-agents] via GitHub
• 2026/10/10 [I] [Bug][runtime] Lifecycle and metrics inconsistencies in parallel action execution [flink-agents] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40439][python] Add model provider management to the DataFrame API [flink] via GitHub
• 2026/10/10 [jira] [Updated] (FLINK-40439) Add model provider management to DataFrame API ASF GitHub Bot (Jira)
• 2026/10/10 Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• 2026/10/10 [PR] [FLINK-40439][python] Add model provider management to the DataFrame API [flink] via GitHub
• 2026/10/10 Re: [D] [Discussion] Context compaction for Flink Agents [flink-agents] via GitHub
• 2026/10/10 Re: [PR] [api][runtime][java][python] Add non-durable async execution [flink-agents] via GitHub
• 2026/10/10 Re: [PR] [BP-1.20][FLINK-36973][config] Skip options not explicitly set when converting SavepointRestoreSettings to Configuration [flink] via GitHub
• 2026/10/10 Re: [PR] [api][plan][runtime][python] Support registering an Agent as an in-process internal sub-agent [flink-agents] via GitHub
• 2026/10/10 [PR] [BP-1.20][FLINK-36973][config] Skip options not explicitly set when converting SavepointRestoreSettings to Configuration [flink] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40425][python][table] Support OVER windows in DataFrame API [flink] via GitHub
• 2026/10/10 [I] [Bug][runtime] An interrupted ordinary child in a mixed gather leaves completed durable results PENDING [flink-agents] via GitHub
• 2026/10/10 Re: [PR] [FLINK-40538][postgres] Skip WAL position search on idle publication … [flink-cdc] via GitHub
• 2026/10/10 [PR] Rebuild website for Flink CDC 3.7.0 [flink-web] 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] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• 2026/10/10 Re: [PR] Rebuild website for Flink CDC 3.7.0 [flink-web] via GitHub
• 2026/10/10 [PR] Flink CDC 3.7.0 [flink-web] via GitHub
• 2026/10/10 Re: [PR] [FLINK-32695] [Tests] Migrated SimpleStringGenerator to Source V2 Implementation [flink] via GitHub
• 2026/10/10 Re: [PR] Flink CDC 3.7.0 [flink-web] via GitHub
• 2026/10/10 Re: [I] [Tech Debt][API][RunnerContext] Add a non-durable asynchronous execution API [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] Add Flink CDC 3.7.0 release blog [flink-web] via GitHub
• 2026/10/10 Re: [PR] [api][runtime][java][python] Add non-durable async execution [flink-agents] via GitHub
• 2026/10/10 Re: [PR] [api][runtime][java][python] Add non-durable async execution [flink-agents] via GitHub
• 2026/10/09 Re: [PR] [FLINK-35276][table] Fix incorrect sort order for floating-point negative zero in generated comparators [flink] via GitHub
• 2026/10/09 Re: [PR] [FLINK-35276][table] Fix incorrect sort order for floating-point negative zero in generated comparators [flink] via GitHub
• 2026/10/09 [jira] [Updated] (FLINK-40850) Fluss sink rejects pre-created primary-key tables with custom bucket keys Hongshun Wang (Jira)
• 2026/10/09 [jira] [Resolved] (FLINK-40850) Fluss sink rejects pre-created primary-key tables with custom bucket keys Hongshun Wang (Jira)
• 2026/10/09 [jira] [Assigned] (FLINK-40850) Fluss sink rejects pre-created primary-key tables with custom bucket keys Hongshun Wang (Jira)
• 2026/10/09 Re: [PR] [FLINK-40198][python] Add Kafka source and sink APIs to DataFrame API [flink] via GitHub
• 2026/10/09 Re: [PR] [FLINK-40779][connector-jdbc] Snapshot splitter state together with its splits [flink-connector-jdbc] via GitHub
• 2026/10/09 Re: [PR] [FLINK-40198][python] Add Kafka source and sink APIs to DataFrame API [flink] via GitHub
• 2026/10/09 [PR] [BP-3.6][FLINK-38450][iceberg] Fix duplicate records when schema change splits writes within a checkpoint [flink-cdc] via GitHub
• 2026/10/09 Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• 2026/10/09 Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• 2026/10/09 Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• 2026/10/09 Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• 2026/10/09 Re: [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink] via GitHub
• 2026/10/09 Re: [PR] [FLINK-22599][rpc] Name the applicable timeout options in RPC timeout messages [flink] via GitHub
• 2026/10/09 Re: [PR] [FLINK-31737][runtime-web] Hide rescale controls for jobs that do not support rescaling [flink] via GitHub
• 2026/10/09 Re: [PR] [FLINK-18692][format/avro] Resolve specific record schema without static SCHEMA$ field [flink] via GitHub
• 2026/10/09 [jira] [Updated] (FLINK-18692) AvroSerializationSchema does not work with types generated by avrohugger ASF GitHub Bot (Jira)
• 2026/10/09 [jira] [Updated] (FLINK-22599) Point to `client.timeout` in error messages where it is used for rpc timeout ASF GitHub Bot (Jira)
• 2026/10/09 [jira] [Updated] (FLINK-31737) Hide the rescaling buttons for batch jobs in the WEB UI ASF GitHub Bot (Jira)
• 2026/10/09 [PR] [FLINK-22599][rpc] Name the applicable timeout options in RPC timeout messages [flink] via GitHub
• 2026/10/09 [PR] [FLINK-31737][runtime-web] Hide rescale controls for jobs that do not support rescaling [flink] via GitHub
• 2026/10/09 [PR] [FLINK-18692][format/avro] Resolve specific record schema without static SCHEMA$ field [flink] via GitHub
• 2026/10/09 Re: [PR] [FLINK-40538][postgres] Skip WAL position search on idle publication … [flink-cdc] via GitHub
• 2026/10/09 Re: [PR] [FLINK-39064][Table SQL / API] Add built-in REGEXP_SPLIT function to split string by regular expression pattern [flink] via GitHub
• 2026/10/09 [jira] [Resolved] (FLINK-40951) Sync Chinese docs of Flink source connectors with English docs Xiqian Yu (Jira)
• 2026/10/09 [jira] [Updated] (FLINK-40951) Sync Chinese docs of Flink source connectors with English docs Xiqian Yu (Jira)
• 2026/10/09 Re: [PR] [FLINK-40951][docs] Translate Flink source connector docs into Chinese [flink-cdc] via GitHub
• 2026/10/09 Re: [PR] [FLINK-36165][source-connector/mysql] Support capturing snapshot data with conditions [flink-cdc] via GitHub
• 2026/10/09 [I] [Feature][chat-models] Support multimodal tool results in model provider adapters [flink-agents] via GitHub
• 2026/10/09 [jira] [Commented] (FLINK-40425) Add OVER window aggregation support to DataFrame API Dian Fu (Jira)
• 2026/10/09 [jira] [Updated] (FLINK-39732) Introduce TableDiscoverer SPI for flexible table subscription (with default JdbcTableDiscoverer) Xiqian Yu (Jira)
• 2026/10/09 [PR] [FLINK-39412][cdc-common] Skip duplicate columns in AddColumnEvent to ensure idempotency [flink-cdc] via GitHub
• 2026/10/09 [jira] [Resolved] (FLINK-40739) [Bug][pipeline-connector][maxcompute] Partition values extracted from wrong column index when partition columns are not contiguous at the end of schema Xiqian Yu (Jira)
• 2026/10/09 [jira] [Resolved] (FLINK-40690) Fluss sink applies top-level column mapping to nested ROW fields Xiqian Yu (Jira)
• 2026/10/09 [jira] [Resolved] (FLINK-40623) [cdc-base] JdbcSourceChunkSplitter keeps a pooled JDBC connection for the whole job lifetime; with default connection.pool.size=20 the 21st incremental-snapshot job on the same JobManager can never start Xiqian Yu (Jira)
• 2026/10/09 [jira] [Updated] (FLINK-39252) Flink cdc pipeline support sqlserver source pipeline connector Xiqian Yu (Jira)
• 2026/10/09 [jira] [Updated] (FLINK-39757) Fix kafka sink could not serialize debezium json with column default values Xiqian Yu (Jira)
• 2026/10/09 [jira] [Updated] (FLINK-40411) Introduce an OpenAI-compatible model client for Flink CDC Pipeline Xiqian Yu (Jira)
• 2026/10/09 [jira] [Resolved] (FLINK-34806) [Feature][Postgres] Support automatically identify newly added tables Xiqian Yu (Jira)
• 2026/10/09 [jira] [Updated] (FLINK-39759) Fix StarRocks CHAR / VARCHAR mapping rules to contain utf8mb4 characters Xiqian Yu (Jira)
• 2026/10/09 Re: [PR] [FLINK-40735][table] Compare non-time OVER accumulators with a generated equaliser [flink] via GitHub
• 2026/10/09 Re: [PR] [FLINK-40735][table] Compare non-time OVER accumulators with a generated equaliser [flink] via GitHub
• 2026/10/09 Re: [PR] [runtime][java] Complete batch workflows before key switches [flink-agents] via GitHub
• 2026/10/09 Re: [PR] [runtime][java] Surface Kafka action-state send failures [flink-agents] via GitHub
• 2026/10/09 Re: [PR] [runtime][java] Preserve pending Fluss action state across checkpoints [flink-agents] via GitHub
• 2026/10/09 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/09 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/09 [jira] [Closed] (FLINK-38245) FLIP-532: Donate GetInData HTTP Connector to Flink david radley (Jira)
• 2026/10/09 [jira] [Closed] (FLINK-38306) knit in the http connector docs into the Flink docs david radley (Jira)
• 2026/10/09 Re: [PR] [hotfix][BP-2.3][docs] Add HTTP connector to externalized connectors list [flink] via GitHub
• 2026/10/09 Re: [PR] [hotfix][BP-2.3][docs] Add HTTP connector 1.0 docs [flink] via GitHub
• 2026/10/09 Re: [PR] [hotfix][BP-2.2] Add HTTP connector 1.0 docs [flink] via GitHub
• 2026/10/09 Re: [PR] [FLINK-35459] Use Incremental Source Framework in Flink tidb CDC Source Connector [flink-cdc] via GitHub
• 2026/10/09 Re: [PR] [hotfix][connect/mysql] Pin Percona Toolkit image for OSC tests [flink-cdc] via GitHub
• 2026/10/09 Re: [PR] [FLINK-40278][connector-http] Document and test that HTTP sink retries resend the whole batch [flink-connector-http] via GitHub
• 2026/10/09 Re: [PR] [hotfix][docs] Add HTTP connector to externalized connectors list [flink] via GitHub
• 2026/10/09 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/09 Re: [PR] [FLINK-40298][table] Opt-in name-based state schema evolution for RowData [flink] via GitHub
• 2026/10/09 Re: [PR] [api][java][python] Refactor ChatMessage and separate model invocation results [flink-agents] via GitHub
• 2026/10/09 [jira] [Commented] (FLINK-39412) AddColumnEvent fails with duplicate field names when schema change events are replayed after failover wind.wang (Jira)
• 2026/10/09 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/09 Re: [PR] [FLINK-40737][table] Keep non-time OVER data views inside the accumulator [flink] via GitHub
• 2026/10/09 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/09 [jira] [Updated] (FLINK-40299) Add end-to-end state migration coverage and user documentation for RowData schema evolution Weiqing Yang (Jira)
• 2026/10/09 Re: [PR] [FLINK-40193][python] Add join_lateral support to the DataFrame API [flink] via GitHub
• 2026/10/09 [PR] [api][plan][integrations][java][python] Apply an agent output schema natively on the final response [flink-agents] via GitHub
• 2026/10/09 Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
• 2026/10/09 [PR] [FLINK-40198][python] Add Kafka source and sink APIs to DataFrame API [flink] via GitHub
• 2026/10/09 Re: [PR] [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native [flink] via GitHub
• 2026/10/09 [jira] [Assigned] (FLINK-40174) Document the EARLY_FIRE hint for interval joins Weiqing Yang (Jira)
• 2026/10/09 [jira] [Commented] (FLINK-40908) HBaseITCase.test fails with expected: <6> but was: <0> Yahya Kisana (Jira)
• 2026/10/09 Re: [PR] [FLINK-40949][table-runtime] Don't report NULL window bounds as a NULL rowtime in WindowedUnsliceAssigner [flink] via GitHub
• 2026/10/09 Re: [PR] [api][runtime][java][python] Add non-durable async execution [flink-agents] via GitHub
• 2026/10/09 [jira] [Resolved] (FLINK-40965) Treat IF as conditional function in code gen Sergey Nuyanzin (Jira)
• 2026/10/09 Re: [PR] [hotfix][BP-2.2][docs] Add HTTP connector to externalized connectors list [flink] via GitHub
• 2026/10/09 [jira] [Commented] (FLINK-40735) OVER window ordered by a non-time attribute fails for LAG and ARRAY_AGG when a row arrives out of order sepuri sai krishna (Jira)
• 2026/10/09 [jira] [Updated] (FLINK-40737) COLLECT over a non-time OVER window returns only the current row instead of the running window Martijn Visser (Jira)
• 2026/10/09 [jira] [Resolved] (FLINK-40921) Invoke statebackend's close() and dispose() in right order Zakelly Lan (Jira)
• 2026/10/09 Re: [PR] [FLINK-40921] Invoke statebackend's close() and dispose() in right order [flink] via GitHub
• 2026/10/09 Re: [PR] [FLINK-40737][table] Keep non-time OVER data views inside the accumulator [flink] via GitHub
• 2026/10/09 Re: [PR] [FLINK-40743][jdbc] Fix the Table sink's empty lineage dataset name [flink-connector-jdbc] via GitHub
• 2026/10/09 Re: [PR] [hotfix][docs] Add HTTP connector to externalized connectors list [flink] via GitHub

• Earlier messages
• Later messages