commits  

Messages by Thread

• (flink-ci-docker) branch main updated (cbddd0c -> 0a2f2bb) snuyanzin
  • (flink-ci-docker) 02/02: [hotfix] Fix docker warnings snuyanzin
  • (flink-ci-docker) 01/02: [FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper snuyanzin
• (flink-connector-cassandra) branch main updated (32f8cc8 -> ca6117d) martijnvisser
  • (flink-connector-cassandra) 01/03: [FLINK-41071][Connectors/Cassandra] Upgrade Testcontainers to 1.21.4 martijnvisser
  • (flink-connector-cassandra) 03/03: [FLINK-41070][Connectors/Cassandra] Test against Flink 1.19.3 martijnvisser
  • (flink-connector-cassandra) 02/03: [FLINK-38485][Connectors/Cassandra] Add commons-codec to the test classpath martijnvisser
• (flink-shaded) branch release-21.0 updated: [FLINK-41076] Bump Netty to 4.2.19.Final (release-21.0) rmetzger
• (flink-shaded) branch release-21.0 updated: [FLINK-41076] Bump Jackson to 2.21.8 (release-21.0) rmetzger
• (flink-shaded) branch release-21.0 updated: [FLINK-41076] Bump ZooKeeper to 3.8.7 (release-21.0) rmetzger
• (flink-agents) branch main updated: [api][integrations][java][python] Reject a blank model in chat model setups (#1317) wenjin
• (flink-agents) branch main updated: [docs] Clarify shared action scope and complete agent documentation (#1319) wenjin
• (flink) branch master updated: [FLINK-41034][table] Don't store rows whose join key can never match in streaming joins gustavodemorais
• (flink-agents) branch main updated: [runtime][python][docs] Fix execution guards and observability gaps in Operations guidance (#1305) wenjin
• (flink-agents) branch main updated: [docs][python] Fix setup, Quickstart and scalar Table output (#1316) wenjin
• (flink-cdc) branch release-3.7 updated: [docs] Correct Debezium version in DataStream API package guidance (#4590) yux
• (flink-cdc) branch master updated: [docs] Correct Debezium version in DataStream API package guidance (#4591) yux
• (flink-agents) branch main updated: [runtime][python] Handle missing long-term memory IDs (#1314) wenjin
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-456d42d8d4 created (now 5a8b9db1a02) github-bot
• (flink) branch master updated: [hotfix][python] Bump certifi from 2026.1.4 to 2026.10.19 in /flink-python/docs (#29555) dianfu
• (flink) branch dependabot/uv/flink-python/docs/certifi-2026.10.19 deleted (was e9232f13f96) github-bot
• (flink) branch master updated: [FLINK-40192][python] Add as-of join support to DataFrame API dianfu
• (flink-agents) branch main updated: [docs] Correct memory documentation (#1307) wenjin
• (flink-agents) branch main updated: [runtime] Fix ActionStateStore divergence detection for multi-action replay (#1306) wenjin
• (flink-agents) branch main updated: [runtime] Process the input queued behind an input that triggers no Actions (#1310) wenjin
• (flink) branch master updated: [FLINK-40968][table] Fix Table API map() op_mapping for TO and FROM_CHANGELOG PTFs gustavodemorais
• (flink) branch master updated: [FLINK-40098][test-utils] Add FailingCheckpointedSource for exactly-once source tests (#28686) martijnvisser
• (flink-shaded) branch release-21.0 created (now e458d63) rmetzger
• (flink) branch release-2.3 updated: [FLINK-34427][tests] Wait for slot manager close() in runTest martijnvisser
• (flink) branch dependabot/uv/flink-python/docs/certifi-2026.10.19 created (now e9232f13f96) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-ba099ef016 created (now 3a91c46beec) github-bot
• (flink) branch release-1.20 updated: [FLINK-34427][tests] Wait for slot manager close() in runTest martijnvisser
• (flink) branch release-2.2 updated: [FLINK-34427][tests] Wait for slot manager close() in runTest martijnvisser
• (flink-connector-kafka) branch main updated: [FLINK-33484][Connectors/Kafka] Correct offsets committed to Kafka martijnvisser
• (flink) branch master updated: [FLINK-40664][tests] Isolate MDC logging test clusters (#29235) martijnvisser
• (flink-agents) branch main updated: [api][plan][java][python] Fix MCP server declarations in YAML (#1303) wenjin
• (flink) branch master updated (d851e0a897a -> 8a369e790b6) fanrui
  • (flink) 02/02: [FLINK-40780][tests] Add ITCases for forward edge parallelism mismatch modes fanrui
  • (flink) 01/02: [FLINK-40780][runtime] Make FORWARD-to-REBALANCE downgrade on parallelism mismatch configurable fanrui
• (flink) branch master updated: [FLINK-41040][state-processor-api] Fix binary row conversion. gyfora
• (flink) branch master updated: [FLINK-40463][table] Widen `JSON_VALUE` and `JSON_QUERY` `RETURNING` type support (#29506) ramin
• (flink) branch master updated: [FLINK-34427][tests] Wait for slot manager close() in runTest martijnvisser
• (flink) branch master updated: [FLINK-40829][python] Allow assign uid for Timestamp operators (#29312) dianfu
• (flink-cdc) branch master updated: [FLINK-41058][pipeline-connector/fluss] Merge schema options with global sink table properties when creating tables. (#4587) hongshun
• (flink) branch master updated (353c25629ca -> 96f55807499) fanrui
  • (flink) 01/02: [FLINK-40904][runtime] Pass consumer parallelism to tasks via ResultPartitionDeploymentDescriptor fanrui
  • (flink) 02/02: [FLINK-40904][runtime] Detect FORWARD parallelism mismatch with the actual consumer parallelism fanrui
• (flink-cdc) branch master updated: [FLINK-40982][pipeline-connector/fluss] Make ADD COLUMN replay idempotent (#4574) hongshun
• (flink-agents) branch main updated: [docs] Add decision model entries to the resource, event, and cross-language indexes (#1300) wenjin
• (flink-cdc) branch master updated: [FLINK-40853][postgres] Skip LSN commit for checkpoints without a stream offset (#4566) hongshun
• (flink-agents) branch main updated: [runtime][java] Keep worker lock ownership when an async call leaves the interrupt flag set (#1298) wenjin
• (flink-agents) branch main updated: [release][dist] Build release artifacts with JDK 21 and keep JDK 21 classes in thin JARs (#1295) wenjin
• (flink-agents) branch main updated: [docs] Fix non-runnable shared chat model example in the YAML API page (#1297) wenjin
• (flink) branch master updated: [FLINK-40916][runtime] Add option to create checkpoint directories on first checkpoint (#29409) martijnvisser
• (flink-connector-jdbc) branch main updated: [FLINK-40743][jdbc] Fix the Table sink's empty lineage dataset name martijnvisser
• (flink) branch master updated: [FLINK-40961][table] Support notifying stateful sets for broadcast tables in PTFs twalthr
• (flink) branch master updated: [FLINK-40953][s3] Store the native S3 recoverable writer tail under the target directory dbsamrat
• (flink-agents) branch main updated: [docs] Improve consistency and configuration guidance (#1284) wenjin
• (flink-agents) branch main updated: [hotfix][plan] Upgrade tree-sitter to 0.26.6 (#1293) wenjin
• (flink-agents) branch release-0.3 updated: [hotfix][ci] Pull MinIO for Milvus tests from Bitnami's legacy image (#1162) (#1288) wenjin
• (flink-agents) branch main updated: [hotfix][integrations][python][docs] Align vector stores with their declared contracts (#1280) yunfengzhou
• (flink-agents) branch main updated: [docs] Document the successive Python job limitation on a session cluster (#1282) wenjin
• (flink-agents) branch main updated (742faf60c -> bff15845f) wenjin
  • (flink-agents) 03/05: [examples][python] Handle review windows with no valid scores wenjin
  • (flink-agents) 01/05: [runtime][python] Fix Table environment creation in to_table wenjin
  • (flink-agents) 05/05: [docs] Clarify sub-agent usage and execution semantics wenjin
  • (flink-agents) 02/05: [runtime][python] Support root resource fallback for internal sub-agents wenjin
  • (flink-agents) 04/05: [docs][python] Correct Table input examples to use Row wenjin
• (flink-agents) branch release-0.3 updated: [hotfix][docs] Link example sources through gh_link on release-0.3 (#1286) wenjin
• (flink-agents) branch main updated: [docs] Fix release-branch source links and the Apple Silicon setup note (#1285) wenjin
• (flink-agents) branch main updated: [api][python][integrations] Share the native output model helper across chat model connections (#1277) wenjin
• (flink-agents) branch main updated: [hotfix][docs][api] Correct Calling LLMs, Vector Search and ReAct Agent to match the code (#1278) yunfengzhou
• (flink) branch master updated: [FLINK-40978][table] Cast from VARIANT through FromVariantConverter twalthr
• (flink-agents) branch main updated: [api][java][python] Render a flat RowTypeInfo output schema as JSON Schema in the ReAct Agent prompt (#1270) wenjin
• (flink) branch dependabot/maven/flink-filesystems/flink-fs-hadoop-shaded/commons-beanutils-commons-beanutils-1.11.0 deleted (was 9f7c1073446) github-bot
• (flink-agents) branch main updated: [integrations][java][python] Skip native structured output for a Map, JsonNode or dict field (#1265) wenjin
• (flink) branch dependabot/maven/flink-docs/org.jsoup-jsoup-1.23.1 deleted (was 4a3777dda89) github-bot
• (flink) branch dependabot/maven/flink-table/flink-sql-client/commons-beanutils-commons-beanutils-1.11.0 deleted (was d1bd6d9a2f9) github-bot
• (flink) branch master updated: [hotfix][runtime-web] Restore metric chart height to 150 martijnvisser
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-a19ccc8885 deleted (was e575974c023) github-bot
• [I] [cdc-pipeline-connector-starrocks] NoSuchMethodError StatefulSink.createWriter(Sink$InitContext) on Flink 2.2 with Flink CDC 3.7.0-2.2 [flink-cdc] via GitHub
  • Re: [I] [cdc-pipeline-connector-starrocks] NoSuchMethodError StatefulSink.createWriter(Sink$InitContext) on Flink 2.2 with Flink CDC 3.7.0-2.2 [flink-cdc] via GitHub
  • Re: [I] [cdc-pipeline-connector-starrocks] NoSuchMethodError StatefulSink.createWriter(Sink$InitContext) on Flink 2.2 with Flink CDC 3.7.0-2.2 [flink-cdc] via GitHub
  • Re: [I] [cdc-pipeline-connector-starrocks] NoSuchMethodError StatefulSink.createWriter(Sink$InitContext) on Flink 2.2 with Flink CDC 3.7.0-2.2 [flink-cdc] via GitHub
• (flink) branch master updated (818fda57643 -> e64938456a5) martijnvisser
  • (flink) 01/02: [hotfix][table-planner] Extract the SqlParseException conversion in CalciteParser martijnvisser
  • (flink) 02/02: [FLINK-24908][table-planner] Show the position and the failing line in parse errors martijnvisser
• (flink) branch master updated: [FLINK-41023][python][docs] Build English and Chinese docs from one lockfile (#29518) dianfu
• (flink) branch master updated: [FLINK-41022][build] Update lz4-java to 1.12.0 martijnvisser
• (flink-agents) branch main updated: [docs] Restructure the observability chapter (#1262) wenjin
• (flink) branch master updated (dd5feb6ba0e -> 99c5866b071) martijnvisser
  • (flink) 01/02: [FLINK-41021][fs] Update commons-beanutils to 1.11.0 martijnvisser
  • (flink) 02/02: [FLINK-41021][docs] Update jsoup to 1.23.2 martijnvisser
• (flink) branch dependabot/maven/at.yawk.lz4-lz4-java-1.11.1 deleted (was 10318f47504) github-bot
• (flink) branch dependabot/maven/flink-docs/org.jsoup-jsoup-1.23.2 deleted (was 5cdaa41395b) github-bot
• (flink) branch dependabot/maven/at.yawk.lz4-lz4-java-1.11.4 deleted (was a36036abcac) github-bot
• (flink-agents) branch main updated: [python][integrations] Raise a clear error for an unrenderable output schema in the Ollama connection (#1276) wenjin
• (flink) branch dependabot/uv/flink-python/docs/idna-3.15 deleted (was 51941fc88aa) github-bot
• (flink-agents) branch main updated: [docs] Improve the Sub-Agents guide (#1268) yunfengzhou
• (flink) branch dependabot/uv/flink-python/docs/soupsieve-2.9 deleted (was 9c9c53a693f) github-bot
• (flink) branch dependabot/uv/flink-python/docs/pygments-2.20.0 deleted (was 08f6b72c3c4) github-bot
• (flink) branch dependabot/uv/flink-python/docs/urllib3-2.7.0 deleted (was e95fccc2ada) github-bot
• (flink) branch master updated: [FLINK-41020][python][docs] Update PyFlink docs dependencies with open Dependabot advisories (#29516) dianfu
• (flink) branch release-1.20 updated: [FLINK-38500][python] Bump pemja to 0.5.8 (#29505) dianfu
• (flink) branch release-2.2 updated: [FLINK-38500][python] Bump pemja to 0.5.8 (#29504) dianfu
• (flink) branch release-2.3 updated: [FLINK-38500][python] Bump pemja to 0.5.8 (#29503) dianfu
• (flink) branch master updated: [FLINK-38500][python] Bump pemja to 0.6.3 (#29502) dianfu
• (flink) branch dependabot/maven/flink-docs/org.jsoup-jsoup-1.23.2 created (now 5cdaa41395b) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/ip-address-10.7.3 deleted (was 48f1af181ad) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/proxy-addr-2.0.8 deleted (was 8bb7c557eaf) github-bot
• (flink) branch release-2.2 updated: [hotfix][BP-2.2][docs] Add HTTP connector to externalized connectors list (#29448) davidrad
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/hono-4.13.1 deleted (was 68671cd8e27) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/postcss-8.5.23 deleted (was 266913a0ce3) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-18c70401c2 deleted (was d4d4c8c3889) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/js-yaml-4.3.1 deleted (was bf1ddee7833) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/compiler-21.2.19 deleted (was a1a5a7ea863) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/fast-uri-3.1.4 deleted (was 95c4c72e8ef) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/ip-address-10.4.0 deleted (was b081d5cb7e0) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-086ee281ad deleted (was ffad1bef861) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/brace-expansion-1.1.21 deleted (was 8e1a9691fea) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/angular/router-21.2.24 deleted (was 837e711b3cc) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-b02d00d3ff deleted (was 92ac4249c38) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/multi-d0c2d048a7 deleted (was 7578582ef9f) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/postcss-selector-parser-7.1.6 deleted (was 6794e687823) github-bot
• (flink) branch dependabot/npm_and_yarn/flink-runtime-web/web-dashboard/source-map-js-1.2.2 deleted (was 14fa6b14a3f) github-bot
• (flink) branch master updated: [FLINK-40998][runtime-web] Update web-dashboard dependencies with open Dependabot advisories (#29485) martijnvisser
• (flink) branch master updated: [FLINK-40960][runtime][JUnit5 Migration] Migrate the remaining of testing classes in taskmanager package of flink-runtime module panyuepeng
• (flink) branch master updated: [FLINK-41017][table] Use `DecimalData#isCompact` while casting snuyanzin
• (flink) branch master updated: [FLINK-40989][table-planner] Compare `MAP` values by value instead of by reference snuyanzin
• (flink-agents) branch main updated: [docs] Document coding-agent Skill usage and refresh homepage navigation (#1273) wenjin
• (flink) branch master updated: [FLINK-40931][state/forst] Track renamed directories in `ForStFileSystemTrackingCreatedDirDecorator` (#29475) zakelly
• (flink) branch master updated: [hotfix][test-utils-junit] Keep TestLoggerExtension#exceptionToString and delete TestLogger#exceptionToString to reduce code redundancy. panyuepeng
• (flink) branch master updated: [hotfix][runtime] Minor polish the debug log for StreamTask.java panyuepeng
• (flink-cdc) branch master updated: [FLINK-41006][pipeline-connector/starrocks] Upgrade StarRocks Flink connector to 1.2.16 (#4578) yux
• (flink) branch master updated: [FLINK-40996][table] Make `TRY_PARSE_JSON`, `PARSE_JSON` reuse parsed json snuyanzin
• (flink) branch master updated: [FLINK-40174][docs] Document the EARLY_FIRE hint for interval joins panyuepeng
• (flink-agents) branch main updated: [docs] Improve Built-in ReAct Agent usage documentation (#1259) wenjin
• (flink-agents) branch main updated (bde1069a -> c36d084d) wenjin
  • (flink-agents) 01/03: [api][java][python] Honor empty text when loading YAML prompts wenjin
  • (flink-agents) 03/03: [docs] Clarify YAML declarations and document subagents wenjin
  • (flink-agents) 02/03: [api][java][python] Declare internal subagents in YAML wenjin
• (flink-agents) branch main updated: [integration][java][python] Send user images and documents to Anthropic (#1204) wenjin
• (flink-agents) branch main updated: [runtime][java] Preserve pending Fluss action state across checkpoints (#1175) wenjin
• (flink-agents) branch main updated: [integrations][java] List each enum constant by its Jackson-serialized value in native schemas (#1260) wenjin
• (flink-agents) branch main updated: [docs] Clarify Tool Use injection and parallel-call guidance (#1261) wenjin
• (flink-agents) branch main updated: [hotfix][runtime] Use TraceContext in BuiltInInputRunMetricsTest (#1267) wenjin
• (flink) branch master updated: [FLINK-40436][python] Add UDAF support to the DataFrame API (#29431) dianfu
• (flink) branch release-2.2 updated: [FLINK-39226][python] Fix embedded PyIterator class cast after recovery (#29494) dianfu
• (flink) branch master updated: [hotfix][core] Use the try mechanism to proactively close closeable objects to avoid object leaks in ExceptionUtils#stringifyException (#29490) panyuepeng
• (flink) branch master updated: [FLINK-40173][table-planner] Add restore coverage for early-fire interval join panyuepeng
• (flink) branch master updated (047597e0cce -> b6d7afe8077) panyuepeng
• (flink-cdc) branch master updated: [FLINK-40560][postgres] Drop the replication slot when a snapshot-only source finishes (#4523) hongshun
• (flink-agents) branch main updated: [runtime] Count restored input runs once when tasks identify them first (#1245) wenjin
• (flink) branch release-1.20 updated: [FLINK-39226][python] Fix embedded PyIterator class cast after recovery (#29495) dianfu
• (flink) branch master updated: [FLINK-41001][model] Accept compatible string inputs in the OpenAI provider (#29486) dianfu
• (flink-connector-pulsar) branch main updated: [FLINK-41003] Bump Pulsar version to 4.0.14 fcsaky
• (flink-agents) branch main updated: [docs] Improve Agent core concepts, Actions, and Events guides (#1263) wenjin
• (flink) branch release-1.20 updated: [FLINK-40959][table-runtime] Fix `BinaryExternalSorter` emitting unsorted rows fcsaky
• (flink) branch master updated: [FLINK-40294][table-planner] Instrument async scalar and table UDF calls with metrics (#29007) panyuepeng
• (flink) branch release-2.3 updated: [FLINK-40969][runtime] Fix rescale details lookup for evicted latest events. martijnvisser
• (flink) branch master updated: [FLINK-40440][python] Add model prediction support to the DataFrame API (#29478) dianfu
• (flink-cdc) branch master updated: [FLINK-40983][docs] Document Kafka sink.delivery-guarantee (#4575) kunni
• (flink-cdc) branch master updated: [FLINK-40994][connect/paimon] Upgrade Paimon SDK to 2.1.0 (#4577) kunni
• (flink-agents) branch main updated: [doc] Add a structured output user guide (#1252) wenjin
• (flink) branch master updated: [FLINK-40959][table-runtime] Fix `BinaryExternalSorter` emitting unsorted rows fcsaky
• (flink) branch release-2.2 updated: [FLINK-40959][table-runtime] Fix `BinaryExternalSorter` emitting unsorted rows fcsaky
• (flink) branch release-2.3 updated: [FLINK-40959][table-runtime] Fix `BinaryExternalSorter` emitting unsorted rows fcsaky
• (flink-agents) branch main updated: [docs] Clarify API and language choices (#1257) wenjin
• (flink) branch master updated: [FLINK-40433][python] Introduce map and map_batches in DataFrame API dianfu
• (flink-cdc) branch master updated: [FLINK-38907][postgres] Fix data loss with filtered publication autocreate mode in backfill phase (#4223) hongshun
• (flink-connector-aws) branch main updated: [FLINK-40808] Add PyPI publishing support for apache-flink-connector-aws dbsamrat
• (flink-cdc) branch master updated: [docs] Update docs for release 3.7.0 (#4576) yux
• (flink) branch release-2.3 updated: [FLINK-40986][python] Make named Row hashing consistent with equality (#29472) dianfu
• (flink) branch release-1.20 updated: [FLINK-40986][python] Make named Row hashing consistent with equality (#29472) dianfu
• (flink) branch master updated: [FLINK-40986][python] Make named Row hashing consistent with equality (#29472) dianfu
• (flink-agents) branch main updated: [api][runtime][python] Support running a ReActAgent as a general-purpose sub-agent (#1206) wenjin
• (flink-agents) branch main updated: [integrations][java] List Jackson enum values in OpenAI, Azure and Anthropic native schemas (#1247) wenjin
• (flink) branch master updated: [FLINK-40969][runtime] Fix rescale details lookup for evicted latest events. martijnvisser
• (flink) branch master updated: [FLINK-39163][python] Support ML_PREDICT in Python API (#27710) dianfu
• (flink) branch master updated: [FLINK-40439][python] Add DataFrame model provider management dianfu
• (flink) branch master updated: [FLINK-40425][python] Support OVER windows in DataFrame API dianfu
• (flink) branch master updated: [FLINK-40902][docs] Remove equi-predicate requirement from Table API LATERAL SNAPSHOT join docs (#29471) fhueske
• (flink-cdc) branch master updated: [legal] Update NOTICE for bundled dependencies (#4565) yux
• (flink) branch master updated (087e8772291 -> 87bb3057bbe) martijnvisser
  • (flink) 02/02: [FLINK-40971][parquet] Run ParquetTimestampITCase for all its parameters martijnvisser
  • (flink) 01/02: [hotfix][parquet] Use AssertJ in ParquetTimestampITCase martijnvisser
• (flink) branch master updated: [FLINK-40902][table] Support LATERAL SNAPSHOT join without an equi-key (#29421) fhueske
• (flink) branch master updated: [FLINK-40979][table-planner] Run HashAggITCase's inherited tests with adaptive local hash agg martijnvisser
• (flink-agents) branch main updated: [python] Key built-in chat model calls by an explicit durable id (#1240) wenjin
• (flink) branch master updated: [FLINK-40901][table] Use `JsonParseReuse` for `JSON_TYPE`/`JSON_LENGTH` snuyanzin
• (flink-agents) branch main updated: [runtime][java][python] Keep durable gather outcomes completed before an ordinary cancellation (#1239) wenjin
• (flink-agents) branch main updated: [runtime][java][python] Avoid async-pool self-deadlock in internal sub-agent await (#1213) (#1237) yunfengzhou
• (flink) branch master updated: [FLINK-40903][runtime/network] Add source host info in TM disconnect error peterhuang
• (flink) branch master updated: [hotfix][build] Remove stale IllegalImport suppressions martijnvisser
• (flink) branch master updated: [FLINK-40972][table] Do not generate cast classes in case of Identity casts snuyanzin
• (flink-cdc) branch master updated: [FLINK-40538][postgres] Skip WAL position search on idle publication for a fresh start (#4521) hongshun
• (flink-connector-hbase) branch main updated: [FLINK-40907][Connectors/HBase] Download HBase from archive.apache.org in HBaseContainer martijnvisser
• (flink) branch release-2.3 updated: [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test (#29352) martijnvisser
• (flink) branch release-2.2 updated: [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test (#29352) martijnvisser
• (flink) branch master updated: [FLINK-40571][table-planner] Fix flaky process-stateful-multi-input-with-timeout PTF test (#29352) martijnvisser

• Earlier messages