commits  

Messages by Date

• 2026/10/12 (flink) branch release-2.2 updated: [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test (#29352) martijnvisser
• 2026/10/12 (flink) branch master updated: [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test (#29352) martijnvisser
• 2026/10/12 (flink-connector-hbase) branch infrastructure-ruleset-bot/default-branch-protection deleted (was ac50ea5) fcsaky
• 2026/10/12 (flink-connector-hbase) branch main updated: [FLINK-40908] Update bundled `hbase-default.xml` and `NOTICE` to HBase 2.6.6 fcsaky
• 2026/10/12 (flink) branch release-1.20 updated (1b5f5767403 -> 73e921780b2) fanrui
• 2026/10/12 (flink) branch release-2.2 updated: [FLINK-38613][tests] Force number of splits in UnalignedCheckpointRescaleWithMixedExchangesITCase fanrui
• 2026/10/12 (flink-cdc) branch release-3.6 updated: [BP-3.6][FLINK-38450][iceberg] Fix duplicate records across schema changes and restore CI (#4572) kunni
• 2026/10/12 (flink-agents) branch main updated: [runtime][java] Reuse saved Kafka action results after recovery (#1161) wenjin
• 2026/10/12 (flink-agents) branch main updated: [runtime][java] Reject memory writes below a value field before mutating state (#1188) wenjin
• 2026/10/12 (flink) branch master updated: [hotfix][docs] Add HTTP connector to externalized connectors list (#29446) davidrad
• 2026/10/11 (flink) branch master updated: [FLINK-40658][table] Preserve null ROW elements in UNNEST (#29398) dianfu
• 2026/10/11 (flink) branch master updated: [FLINK-40856][python] Support strict zip-style multi-column DataFrame explode dianfu
• 2026/10/11 (flink-agents) branch main updated: [Tech Debt][runtime][python] Preserve skill-repository close failures in SkillManager.close() (#1221) wenjin
• 2026/10/11 (flink) branch master updated: [FLINK-40198][python] Add Kafka source and sink APIs to DataFrame API dianfu
• 2026/10/11 (flink) branch release-1.20 updated: [FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue (#29389) fanrui
• 2026/10/11 (flink) branch release-2.3 updated: [FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue (#29387) fanrui
• 2026/10/11 (flink) branch release-2.2 updated: [FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue fanrui
• 2026/10/11 (flink-connector-jdbc) branch main updated: [FLINK-40748][jdbc] Keep PreparedSplitterNumericParameters inside maxVal martijnvisser
• 2026/10/10 (flink-connector-rabbitmq) branch main updated: [FLINK-40770][Connectors/RabbitMQ] Add a PR template with AI disclosure (#35) fanrui
• 2026/10/10 (flink-benchmarks) branch master updated: [FLINK-40764][benchmarks] Add a PR template with AI disclosure fanrui
• 2026/10/10 (flink-connector-elasticsearch) branch main updated: [FLINK-40757][Connectors/Elasticsearch] Add a PR template with AI disclosure (#163) fanrui
• 2026/10/10 (flink-shaded) branch master updated: [FLINK-40756][shaded] Add a PR template with AI disclosure fanrui
• 2026/10/10 (flink-connector-redis-streams) branch main updated: [FLINK-40771][Connectors/Redis Streams] Add a PR template with AI disclosure (#8) fanrui
• 2026/10/10 (flink-connector-gcp-pubsub) branch main updated: [FLINK-40769][Connectors/Google PubSub] Add a PR template with AI disclosure (#39) fanrui
• 2026/10/10 (flink-connector-http) branch main updated: [FLINK-40758][Connectors/HTTP] Add a PR template with AI disclosure (#55) fanrui
• 2026/10/10 (flink-connector-aws) branch main updated: [FLINK-40750][Connectors/AWS] Add AI disclosure to the PR template fanrui
• 2026/10/10 (flink-connector-cassandra) branch main updated: [FLINK-40768][Connectors/Cassandra] Add a PR template with AI disclosure (#44) fanrui
• 2026/10/10 (flink) branch master updated: [FLINK-40218][core] Store a `JSON` number literal in the `VARIANT` builder like `PARSE_JSON` snuyanzin
• 2026/10/10 (flink-web) 01/02: Add Flink CDC 3.7.0 release blog yux
• 2026/10/10 (flink-web) branch asf-site updated (357b7242b9 -> 328708b2b4) yux
• 2026/10/10 (flink-web) 02/02: Rebuild website yux
• 2026/10/10 svn commit: r88415 - dev/flink/flink-cdc-3.7.0-rc1 yux
• 2026/10/10 (flink-web) branch asf-site updated (4a39ec3ccc -> 357b7242b9) yux
• 2026/10/10 (flink-web) 01/02: Flink CDC 3.7.0 yux
• 2026/10/10 svn commit: r88416 - dev/flink/flink-cdc-3.7.0-rc1 release/flink/flink-cdc-3.7.0 leonard
• 2026/10/10 (flink-cdc) annotated tag release-3.7.0 updated (045e8da45 -> 9c29e9a07) yux
• 2026/10/10 svn commit: r88414 - dev/flink/flink-cdc-3.7.0-rc1 yux
• 2026/10/09 (flink-cdc) branch master updated: [FLINK-40850][pipeline-connector/fluss] Accept custom bucket keys in pre-created primary-key tables (#4564) hongshun
• 2026/10/09 (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/proxy-addr-2.0.8 created (now 8bb7c557eaf) github-bot
• 2026/10/09 (flink) branch release-2.3 updated: [hotfix][BP-2.3][docs] Add HTTP connector to externalized connectors list (#29447) davidrad
• 2026/10/09 (flink) branch release-2.3 updated: [hotfix][BP-2.3][docs] Add HTTP connector 1.0 docs (#29437) davidrad
• 2026/10/09 (flink) branch release-2.2 updated: [hotfix] Add HTTP connector 1.0 docs (#28509) davidrad
• 2026/10/09 (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/source-map-js-1.2.2 created (now 14fa6b14a3f) github-bot
• 2026/10/09 (flink-web) branch asf-site updated: Add Flink Community Update for Q2 2026 (#871) davidrad
• 2026/10/09 (flink) 01/03: [FLINK-40965][table] Treat `IF` as conditional snuyanzin
• 2026/10/09 (flink-cdc) branch master updated: [hotfix][connect/mysql] Pin Percona Toolkit image for OSC tests (#4571) kunni
• 2026/10/09 (flink-agents) branch main updated: [api][runtime][java][python] Reject framework-owned lineage at event emission (#1212) wenjin
• 2026/10/09 (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/postcss-selector-parser-7.1.6 created (now 6794e687823) github-bot
• 2026/10/09 (flink) branch dependabot/maven/at.yawk.lz4-lz4-java-1.11.4 created (now a36036abcac) github-bot
• 2026/10/09 (flink) branch master updated: [FLINK-40797][table-planner] Exclude `NestedLoopJoin` from CBO search space for equi-joins snuyanzin
• 2026/10/09 (flink) branch master updated: [FLINK-40952][state/forst] Close the DBOptions copy of temporary restore DBs (#29430) zakelly
• 2026/10/09 (flink-connector-http) branch main updated: [FLINK-40940][connector-http] Decide lookup row emission independently of applyReadableMetadata (#56) davidrad
• 2026/10/09 (flink) branch master updated: [FLINK-37672][build] Migrate protobuf code generation to ascopes plugin (#29434) martijnvisser
• 2026/10/09 (flink) 02/02: [FLINK-40921][test] Invoke statebackend's close() in tests zakelly
• 2026/10/09 (flink) branch master updated (d8e1e0da8b3 -> 331004b56fb) zakelly
• 2026/10/09 (flink) 01/02: [FLINK-40921][runtime] Invoke statebackend's close() and dispose() in right order zakelly
• 2026/10/09 (flink) branch master updated (687ef8c4363 -> d8e1e0da8b3) snuyanzin
• 2026/10/09 (flink) 03/03: [FLINK-40965][table] Parameterize tests for conditional functions for short circuit case snuyanzin
• 2026/10/09 (flink) 02/03: [FLINK-40965][table] Treat `IFNULL` as conditional snuyanzin
• 2026/10/09 (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-b02d00d3ff created (now 92ac4249c38) github-bot
• 2026/10/09 (flink) branch master updated: [FLINK-40193][python] Add join_lateral support to the DataFrame API (#29433) dianfu
• 2026/10/08 (flink-agents) branch main updated: [runtime][python] Propagate durable call result persistence failures (#1211) wenjin
• 2026/10/08 (flink-cdc) branch master updated: [build] Bump version to 3.8-SNAPSHOT (#4563) kunni
• 2026/10/08 (flink) branch master updated: [FLINK-40196][python] Add missing-value handling to DataFrame API dianfu
• 2026/10/08 (flink-agents) branch main updated: [api][runtime][java][python] Simplify agent output materialization with typed toDataStream/toTable (#1183) wenjin
• 2026/10/08 (flink-agents) branch main updated: [java] Add missing Log4j dependencies to IDE support (#1210) wenjin
• 2026/10/08 (flink-agents) branch main updated: [runtime][python] Keep durable call failures whose exception can't be pickled or rebuilt (#1182) wenjin
• 2026/10/08 (flink) branch master updated: [FLINK-40608][python] Extract type inference mechanism to shared component (#29267) dianfu
• 2026/10/08 (flink-connector-kafka) branch main updated: [FLINK-40912][Connectors/Kafka] Close the exactly-once writer's `AdminClient` snuyanzin
• 2026/10/08 (flink) branch master updated: [FLINK-40816][kubernetes/configuration] Remove the deprecated configuration keys from the flink-kubernetes module. panyuepeng
• 2026/10/08 (flink) branch master updated: [FLINK-40958][core] Do not use recurcion in `VARIANT` `toJson` snuyanzin
• 2026/10/08 (flink) branch master updated: [FLINK-40327][state/forst] Close ReadOptions in ForStGeneralMultiGetOperation to fix native memory leak (#28985) zakelly
• 2026/10/08 (flink) branch master updated: [FLINK-40885][table] Support LATERAL SNAPSHOT join in the Table API (#29368) fhueske
• 2026/10/08 (flink) branch master updated: [FLINK-40910][table] Reject `VARIANT` where a query needs equality or ordering snuyanzin
• 2026/10/08 (flink) branch master updated: [FLINK-40437][python] Add iteration and bounded retrieval to DataFrame API dianfu
• 2026/10/07 (flink) branch master updated: [FLINK-40429][python] Add StatementSet support for DataFrame writes dianfu
• 2026/10/07 (flink-agents) branch main updated: [api][java][python] Add raw-bytes factories for media blocks (#1207) wenjin
• 2026/10/07 (flink-agents) branch main updated: [api][plan] Abstain on runtime non-candidate model selections (#1205) wenjin
• 2026/10/07 (flink-agents) branch main updated: align action recovery model (#1155) wenjin
• 2026/10/07 (flink) branch master updated: [FLINK-40925][rest] `JobVertexBackPressureHandler` throws `NoSuchElementException` when execution attempts are pruned concurrently snuyanzin
• 2026/10/07 (flink) branch master updated: [hotfix][table] Fix `EarlyFireJoinHintTest#testEarlyFireProcTimeOnRowTimeJoin` snuyanzin
• 2026/10/07 (flink) branch master updated: [FLINK-40883][table] Fix accumulator corruption in NonTimeRowsUnboundedPrecedingFunction (#29373) martijnvisser
• 2026/10/07 (flink) 04/04: [FLINK-40858][table] Non-equi joins fix: join key-only deletes with the stored record gustavodemorais
• 2026/10/07 (flink) branch master updated: [FLINK-40852][table] Treat `NULL` allowDuplicateKeys as false in `PARSE_JSON` and `TRY_PARSE_JSON` snuyanzin
• 2026/10/07 (flink) branch master updated: [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty gustavodemorais
• 2026/10/07 (flink-agents) branch main updated: [api][integrations] Use DashScope naming consistently (#1201) wenjin
• 2026/10/07 (flink) branch master updated (a47e4bf9b9e -> 3fc308453a4) panyuepeng
• 2026/10/07 (flink-agents) branch main updated: [integration][java][python] Reject media blocks in providers that send text only (#1186) wenjin
• 2026/10/07 (flink) branch release-2.3 updated (ac53e8d0a15 -> 098afcc7990) gustavodemorais
• 2026/10/07 (flink) branch master updated: [FLINK-40645][state/forst] Unregister closed streams from FileCacheEntry#openedStreams (#29169) zakelly
• 2026/10/07 (flink) branch release-2.2 updated (3d20ecb1dfb -> 768a0379c63) gustavodemorais
• 2026/10/07 (flink) 04/04: [FLINK-40858][table] Non-equi joins fix: join key-only deletes with the stored record gustavodemorais
• 2026/10/07 (flink) branch master updated: [FLINK-40920][table-planner] Fix ClassCastException when reducing a division by a constant expression snuyanzin
• 2026/10/07 (flink) branch master updated: [FLINK-40937][table] `UPDATE` fails with `IndexOutOfBoundsException` when a `SET` value's type doesn't match the column snuyanzin
• 2026/10/07 (flink) 02/04: [FLINK-40831][table] MiniBatch joins fix: count an updated record again after a suppressed retraction gustavodemorais
• 2026/10/07 (flink) 01/04: [FLINK-40809][table] Outer regular joins fix: do not count an updated record as a new match gustavodemorais
• 2026/10/07 (flink) 03/04: [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses gustavodemorais
• 2026/10/07 (flink) 01/04: [FLINK-40809][table] Outer regular joins fix: do not count an updated record as a new match gustavodemorais
• 2026/10/07 (flink) branch release-2.3 updated: [FLINK-40368][table] Deduplicate output should only be insert-only when ordered by time attribute (#29372) gustavodemorais
• 2026/10/07 (flink) 03/04: [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses gustavodemorais
• 2026/10/07 (flink) branch release-2.2 updated (767531a0c6c -> 3d20ecb1dfb) gustavodemorais
• 2026/10/07 (flink) 02/04: [FLINK-40831][table] MiniBatch joins fix: count an updated record again after a suppressed retraction gustavodemorais
• 2026/10/06 (flink) branch master updated: [FLINK-40644][state/forst] Close the remote stream when a CachedDataInputStream is closed zakelly
• 2026/10/06 (flink) branch master updated: [FLINK-34673][test] Fix SessionRelatedITCase#testTouchSession failure on GitHub Actions (#24826) martijnvisser
• 2026/10/06 (flink) branch master updated: [FLINK-40913][tests] Use a single vertex job in testStuckSyncPhaseFailsJob to avoid failures race martijnvisser
• 2026/10/06 (flink) branch release-1.20 updated: [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition martijnvisser
• 2026/10/06 (flink) branch release-2.3 updated: [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition martijnvisser
• 2026/10/06 (flink) branch release-2.2 updated: [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition martijnvisser
• 2026/10/06 (flink) branch master updated: [FLINK-36146][connector-base] Fix SingleThreadFetcherManager race condition martijnvisser
• 2026/10/06 (flink) 02/03: [FLINK-40826][table] Cast primitives to VARIANT through ToVariantConverter twalthr
• 2026/10/06 (flink) 03/03: [FLINK-40826][table] Support casting ARRAY, MAP, ROW and STRUCTURED to VARIANT twalthr
• 2026/10/06 (flink) 01/03: [FLINK-40911][core] Fix two bugs in the variant builder twalthr
• 2026/10/06 (flink) branch master updated (69b9cbb14c7 -> 140140a88fb) twalthr
• 2026/10/06 (flink) branch master updated: [FLINK-40909][table-planner] Support filter push down for element access on ARRAY, MAP and VARIANT arvid
• 2026/10/06 (flink-connector-http) branch main updated: Amend notice (#49) davidrad
• 2026/10/06 (flink-kubernetes-operator) branch main updated: [FLINK-40470] Record spec before deployment attempt in savepoint redeploy (#1216) rmetzger
• 2026/10/05 (flink) branch master updated: [FLINK-40657][connector-base] Release per-fetcher state in FutureCompletingBlockingQueue martijnvisser
• 2026/10/05 (flink) branch master updated: [FLINK-40890][table] Require deterministic build columns for LATERAL SNAPSHOT join (#29380) fhueske
• 2026/10/05 (flink) branch master updated: [FLINK-40368][table] Deduplicate output should only be insert-only when ordered by time attribute (#29372) martijnvisser
• 2026/10/05 (flink) branch master updated: [FLINK-40297][runtime] Route TTL-aware value migration through the migrate hook panyuepeng
• 2026/10/05 (flink) 02/02: [FLINK-40871][table] Avoid the UTF-8 round trip when casting strings and decimals to VARIANT arvid
• 2026/10/05 (flink) branch master updated: [FLINK-40892][table] Remove stale NDU IGNORE override from changelog PTF semantic tests martijnvisser
• 2026/10/05 (flink) branch master updated (63b7674dcca -> bd7e555ad48) arvid
• 2026/10/05 (flink) 01/02: [FLINK-40871][core] Append VARIANT strings as UTF-8 bytes and decimals as an unscaled long arvid
• 2026/10/05 (flink) branch master updated: [hotfix][table] Do not pollute code splitter cache with short code snuyanzin
• 2026/10/05 (flink) branch master updated (769d9fe34d5 -> 5afe863af62) gustavodemorais
• 2026/10/05 (flink-connector-jdbc) branch main updated: [FLINK-40778][tests] Handle Flink 2.4's AND digest in JdbcTablePlanTest martijnvisser
• 2026/10/04 (flink) branch master updated: [FLINK-40905][rpc] Bump Pekko to 1.7.1 snuyanzin
• 2026/10/03 (flink) branch master updated: [FLINK-40895][table] Use cache in code splitter snuyanzin
• 2026/10/02 (flink) branch master updated: [FLINK-40293][table] Add UDF metric config options and instrument sync scalar and table UDF calls (#28879) peterhuang
• 2026/10/02 (flink) branch master updated: [FLINK-38262][table] describe connection operation (#28792) lihaosky
• 2026/10/02 (flink) 02/04: [FLINK-40504][runtime] Mark WatermarkToDataOutput active on non-advancing watermarks martijnvisser
• 2026/10/02 (flink) 03/04: [FLINK-40504][core] Report activity from WatermarksWithIdleness on events martijnvisser
• 2026/10/02 (flink) branch release-2.2 updated (5f3d3d2ca5b -> fc918d4b450) martijnvisser
• 2026/10/02 (flink) 04/04: [FLINK-40504][core] Propagate active combined status from WatermarkOutputMultiplexer martijnvisser
• 2026/10/02 (flink) branch release-2.3 updated: [FLINK-40670][tests] Use different keys for different data martijnvisser
• 2026/10/02 (flink) branch release-2.2 updated: [FLINK-40670][tests] Use different keys for different data martijnvisser
• 2026/10/02 (flink) 01/04: [FLINK-40504][core] Make PartialWatermark idleness tri-state martijnvisser
• 2026/10/02 (flink) 04/04: [FLINK-40504][core] Propagate active combined status from WatermarkOutputMultiplexer martijnvisser
• 2026/10/02 (flink) 03/04: [FLINK-40504][core] Report activity from WatermarksWithIdleness on events martijnvisser
• 2026/10/02 (flink) 02/04: [FLINK-40504][runtime] Mark WatermarkToDataOutput active on non-advancing watermarks martijnvisser
• 2026/10/02 (flink) branch release-2.3 updated (8dde4fdd2de -> 34ec2b4ec17) martijnvisser
• 2026/10/02 (flink) 01/04: [FLINK-40504][core] Make PartialWatermark idleness tri-state martijnvisser
• 2026/10/02 (flink) 02/02: [FLINK-40830][table] Merge StringUtf8Utils into one class snuyanzin
• 2026/10/02 (flink) branch master updated (61ababd42fa -> 031ff76cae5) snuyanzin
• 2026/10/02 (flink) 01/02: [FLINK-40830][table] Reuse java's `getBytes` in `StringUtf8Utils` snuyanzin
• 2026/10/02 (flink) branch master updated: [FLINK-40708][table] Add semantic test for ValueView state in onTimer twalthr
• 2026/10/02 (flink) branch master updated: [FLINK-40854][table] Parse UTF-8 bytes directly in PARSE_JSON and TRY_PARSE_JSON twalthr
• 2026/10/02 (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/router-21.2.24 created (now 837e711b3cc) github-bot
• 2026/10/02 (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/brace-expansion-1.1.21 created (now 8e1a9691fea) github-bot
• 2026/10/02 (flink) branch master updated: [FLINK-40602][runtime] Fail job listing and cluster overview on JobMaster query error (#29136) rmetzger
• 2026/10/02 (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/ip-address-10.7.3 created (now 48f1af181ad) github-bot
• 2026/10/02 (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-18c70401c2 created (now d4d4c8c3889) github-bot
• 2026/10/02 (flink) branch master updated: [FLINK-40855][filesystems] Shut down STS clients after S3 delegation-token acquisition gaborgsomogyi
• 2026/10/02 (flink) branch master updated: [FLINK-40059][examples] Bump flink-connector-kafka to 5.0.0-2.2 (#28625) rmetzger
• 2026/10/02 (flink) branch master updated: [FLINK-40876][table] Code splitter should generate same code after repeated runs snuyanzin
• 2026/10/01 (flink) 02/02: [FLINK-40825][table] Support casting primitive types to VARIANT arvid
• 2026/10/01 (flink) 01/02: [FLINK-40825][table] Keep a stored NaN or infinity when casting VARIANT to FLOAT or DOUBLE arvid
• 2026/10/01 (flink) branch master updated (72bcee7aee1 -> e785c495e43) arvid
• 2026/10/01 (flink) branch master updated: [FLINK-40815][configuration] Remove the deprecated configuration keys from the flink-dstl-dfs module. panyuepeng
• 2026/10/01 (flink) branch master updated: [FLINK-40670][tests] Use different keys for different data snuyanzin
• 2026/10/01 (flink-connector-kafka) branch main updated: [FLINK-40847][Connectors/Kafka] Include transaction naming strategy in sink equality (#330) lihaosky
• 2026/10/01 (flink) branch release-1.20 updated: [FLINK-40705][python] Fix Java 8 compilation of ArrowReaderWriterTest martijnvisser
• 2026/10/01 (flink-kubernetes-operator) branch main updated: [FLINK-40857] Fix StatusRecorder not breaking out of for loop gyfora
• 2026/10/01 (flink) branch master updated: [FLINK-40834][ci] Keep rolled YARN container logs in CI artifacts martijnvisser
• 2026/10/01 (flink) branch release-2.3 updated: [FLINK-40326][core] Do not over-grant capacity in GatedRateLimiter martijnvisser
• 2026/10/01 (flink-agents) branch main updated: [integration][java][python] Send user images to Ollama (#1178) wenjin
• 2026/10/01 (flink) branch release-2.2 updated: [FLINK-40326][core] Do not over-grant capacity in GatedRateLimiter martijnvisser
• 2026/10/01 (flink) branch release-2.2 updated: [FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness (#29024) martijnvisser
• 2026/10/01 (flink) branch release-2.3 updated: [FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness (#29024) martijnvisser
• 2026/09/30 (flink-agents) branch main updated: [api][plan][java][python] Support direct declaration of cross-language actions (#1159) wenjin
• 2026/09/30 (flink) branch master updated: [FLINK-40419][python] Add regular join support to DataFrame API dianfu
• 2026/09/30 (flink) branch release-1.20 updated: [FLINK-40705][python] Reset Arrow map child writers between batches dianfu
• 2026/09/30 (flink) branch release-2.3 updated: [FLINK-40705][python] Reset Arrow map child writers between batches dianfu
• 2026/09/30 (flink) branch master updated: [FLINK-40427][python] Add catalog management and catalog table I/O to DataFrame API dianfu
• 2026/09/30 (flink) branch master updated: [FLINK-40832][core] Validate decimal range in `VariantBuilder.of(BigDecimal)` snuyanzin
• 2026/09/30 (flink) 02/02: [FLINK-40831][table] MiniBatch joins fix: count an updated record again after a suppressed retraction gustavodemorais
• 2026/09/30 (flink) branch master updated: [FLINK-40708][table] Support ValueView in PTFs twalthr
• 2026/09/30 (flink) branch master updated: [FLINK-40435][python] Add explode support to DataFrame API dianfu
• 2026/09/30 (flink) branch release-2.2 updated: [FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest martijnvisser
• 2026/09/30 (flink) branch release-2.3 updated: [FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest martijnvisser
• 2026/09/30 (flink) branch release-2.3 updated: [FLINK-40109][yarn][tests] Include rolled logs in the keytab log check martijnvisser
• 2026/09/30 (flink) branch master updated: [FLINK-40839][table] Support `VARIANT` columns omitted from an `INSERT` column list snuyanzin
• 2026/09/30 (flink) branch master updated (5c56320f1ce -> 076753358ce) gustavodemorais
• 2026/09/30 (flink) 01/02: [FLINK-40809][table] Outer regular joins fix: do not count an updated record as a new match gustavodemorais
• 2026/09/29 (flink-agents) branch main updated: [api][java] Keep failed Python tool calls as errors in ToolResponseEvent (#1180) wenjin
• 2026/09/29 (flink) branch release-2.3 updated: [FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion martijnvisser
• 2026/09/29 (flink) 01/02: [hotfix][runtime] Release all channels' deserializers before failing in StreamTaskNetworkInput martijnvisser
• 2026/09/29 (flink-connector-jdbc) branch main updated: [FLINK-40781][tests] Run the ArchUnit tests in each module martijnvisser
• 2026/09/29 (flink) branch release-2.2 updated (d595c863ec9 -> 1f90dad29b3) martijnvisser
• 2026/09/29 (flink) 02/02: [FLINK-39103][runtime] Tolerate deserializer release failure if the corresponding channel already had errors martijnvisser
• 2026/09/29 (flink-connector-jdbc) branch main updated (3ffb29b6 -> 24e2f8b7) martijnvisser
• 2026/09/29 (flink-connector-jdbc) 02/02: [hotfix][jdbc] Drop the XaFacade link from JdbcExactlyOnceOptions martijnvisser
• 2026/09/29 (flink) branch master updated: [FLINK-40109][yarn][tests] Include rolled logs in the keytab log check martijnvisser
• 2026/09/29 (flink) branch master updated: [FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest martijnvisser
• 2026/09/29 (flink) branch release-2.2 updated: [FLINK-40568][tests] Fix flaky ProcessTableFunctionSemanticTests by using materialized data assertion martijnvisser
• 2026/09/29 (flink) 01/03: [FLINK-40180][state-processor-api] Non-keyed/operator state related utilities gyfora
• 2026/09/29 (flink-agents) branch main updated: [integration][java][python] Send multimodal user messages through OpenAI Chat Completions (#1164) wenjin
• 2026/09/29 (flink) branch master updated (0897586aa50 -> 4a071899941) twalthr
• 2026/09/29 (flink-cdc) branch codex/pr-4540 deleted (was 469dda0cb) yux

• Earlier messages
• Later messages