Pull Requests apache/flink

[FLINK-37902] batch support for ml_predict

#27310 opened 2025-12-03 23:45 by lihaosky

Bump @angular/compiler from 20.1.3 to 20.3.15 in /flink-runtime-web/web-dashboard dependencies javascript

#27297 opened 2025-12-02 03:22 by dependabot[bot]

Bump express in /flink-runtime-web/web-dashboard dependencies javascript

#27295 opened 2025-12-01 21:16 by dependabot[bot]

[FLINK-38717][runtime] Display the load status of TaskManagers.

#27291 opened 2025-12-01 11:22 by RocMarshal

[FLINK-38748][runtime] Enhance the switching logic of AdaptiveScheduler from Restarting to CreatingExecutionGraph and accelerate the transition.

#27286 opened 2025-11-28 16:29 by RocMarshal

[FLINK-38340][runtime] Introduce the rescale timeline related abstraction for performing rescale operations

#27285 opened 2025-11-28 15:50 by RocMarshal

Bump @angular/common from 20.1.3 to 20.3.14 in /flink-runtime-web/web-dashboard dependencies javascript

#27281 opened 2025-11-26 23:55 by dependabot[bot]

Bump node-forge from 1.3.1 to 1.3.2 in /flink-runtime-web/web-dashboard dependencies javascript

#27280 opened 2025-11-26 22:09 by dependabot[bot]

[FLINK-38735][connector-file] add restore state check community-reviewed

#27276 opened 2025-11-26 07:06 by liunaijie

[FLINK-38716][docs] Describe the impact of slot.request.max-interval on balanced tasks scheduling. community-reviewed

#27270 opened 2025-11-25 08:19 by RocMarshal

[hotfix][docs] Add documentation for building multiple legacy releases on Windowses on Windows community-reviewed

#27267 opened 2025-11-24 16:42 by MOliverRoth

Bump com.squareup.okhttp3:okhttp from 3.7.0 to 4.10.0.redhat-00002 in /flink-runtime dependencies java

#27260 opened 2025-11-21 19:38 by dependabot[bot]

[FLINK-37427] Fix NPE in StandaloneHaServices and add unit testAdd unit test case for StandaloneHaServices constructor community-reviewed

#27258 opened 2025-11-20 19:26 by lurongjiang

[FLINK-38703][runtime] Update slot manager metrics in thread-safety manner community-reviewed

#27257 opened 2025-11-20 15:48 by ztison

[FLINK-38695][table-runtime] Fix wrong metric about left cache request count in DeltaJoinCache community-reviewed

#27252 opened 2025-11-19 11:50 by xuyangzhong

Bump js-yaml from 4.1.0 to 4.1.1 in /flink-runtime-web/web-dashboard dependencies javascript

#27249 opened 2025-11-18 20:12 by dependabot[bot]

[hotfix] [build] Exclude commons-beanutils from Hadoop dependency to remediate CVE-2025-48734

#27248 opened 2025-11-18 16:27 by guptas6est

[FLINK-38689] [flink-protobuf] Add support for protobuf 4.x field name conflict resolution

#27245 opened 2025-11-17 21:31 by khaledh

[FLINK-38349][runtime] Address SpillingThread Zero-Division During Channel Merging Operations

#27238 opened 2025-11-13 20:43 by rionmonster

Bump com.squareup.okhttp3:okhttp from 3.7.0 to 4.10.0.redhat-00002 dependencies java

#27237 opened 2025-11-13 16:38 by dependabot[bot]

Fix watermark alignment explanation in documentation community-reviewed target:release-2.1

#27227 opened 2025-11-11 15:00 by SherwinFeng

Fix watermark alignment explanation in documentation community-reviewed target:release-2.1

#27221 opened 2025-11-10 15:16 by SherwinFeng

[FLINK-37607] Fix RpcEndpoint#MainThreadExecutor lost scheduling tasks when not running community-reviewed

#27211 opened 2025-11-09 12:41 by Look-Y-Y

[FLINK-38557][FileSystems] Bumped presto version from 0.272 to 0.295 community-reviewed

#27209 opened 2025-11-08 03:34 by kosuruvarunkumar

Fix grammar in Adaptive Scheduler documentation community-reviewed

#27202 opened 2025-11-05 21:05 by Maestro2496

[hotfix] [docs] Rework 'Name and Description' section of operators overview to improve grammar and clarity community-reviewed

#27201 opened 2025-11-05 17:07 by cassie365

[hotfix] Add null check for currentReader in pauseOrResumeSplits community-reviewed

#27200 opened 2025-11-05 17:02 by xccui

[FLINK-38592] [POC] Native Flink S3 FileSystem

#27187 opened 2025-11-03 17:50 by Samrat002

[FLINK-38542][checkpoint] Recover output buffers of upstream task on downstream task side directly

#27182 opened 2025-11-02 20:16 by 1996fanrui

[FLINK-38595][table] Add tests for multiple features with MJ

#27175 opened 2025-10-30 17:35 by gustavodemorais