Pull Requests apache/flink

[FLINK-38825][python] Add Python DataStream API integration for AsyncBatchFunction

#27361 opened 2025-12-22 01:35 by featzhang

[FLINK-38825][table] Add SQL/Table API integration for AsyncBatch inference

#27360 opened 2025-12-22 01:24 by featzhang

[FLINK-38825][streaming] Implement retry and timeout strategies for AsyncBatchWaitOperator

#27359 opened 2025-12-22 01:04 by featzhang

[FLINK-38825][streaming] Add inference-oriented metrics to AsyncBatchWaitOperator

#27358 opened 2025-12-21 11:32 by featzhang

[FLINK-38825][streaming] Add ordered async batch support for AsyncBatchWaitOperator

#27357 opened 2025-12-21 10:32 by featzhang

[FLINK-38825] Add time-based batch triggering for AsyncBatchWaitOperator

#27356 opened 2025-12-21 10:18 by featzhang

[FLINK-38825] Introduce AsyncBatchFunction and AsyncBatchWaitOperator

#27355 opened 2025-12-21 09:42 by featzhang

[FLINK-38189][core][python] Add RowFieldExtractorSchema for Row field serialization

#27353 opened 2025-12-20 11:01 by Nflrijal

[FLINK-38822] Extend URL_DECODE with optional recursive decoding

#27351 opened 2025-12-19 11:02 by featzhang

[FLINK-38760][runtime] Add REST APIs for application query and cancellation

#27350 opened 2025-12-19 02:00 by eemario

[FLINK-38820] Move ptf rule to rule folder

#27349 opened 2025-12-18 19:48 by lihaosky

[hotfix][metrics] Fix NullArgumentException when calculating checkpoint statistics with empty data community-reviewed

#27348 opened 2025-12-18 02:22 by qiref

[FLINK-38810] Use splittable timers in Interval Join

#27345 opened 2025-12-15 17:01 by rkhachatryan

[FLINK-38809][Tests] Upgrade Testcontainers to 2.0.3

#27341 opened 2025-12-15 09:54 by MartijnVisser

[FLINK-38807][state] Add state SQL metadata based type inference community-reviewed

#27340 opened 2025-12-12 21:22 by gaborgsomogyi

[FLINK-38770][runtime] Fix parallelism overrides ignored in Application Mode community-reviewed

#27334 opened 2025-12-10 15:00 by barakbaron12

[FLINK-38799][runtime] Rename `LoadingWeight` to `ResourceUnitCount` community-reviewed

#27333 opened 2025-12-10 14:05 by ferenc-csaky

FLINK-38785: Fixing the quotes issue with variable concatenation

#27332 opened 2025-12-10 12:33 by junmuz

[FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant community-reviewed

#27330 opened 2025-12-09 16:17 by JinkunLiu

[FLINK-38793][table] Reuse result of functions if ther are used multiple times as input for other functions community-reviewed

#27328 opened 2025-12-08 09:23 by snuyanzin

[FLINK-38764] Upgrade lz4 to 1.8.1 due to security vulnerability community-reviewed

#27326 opened 2025-12-05 13:27 by pnowojski

[FLINK-38740][table] Introduce Welford's online algorithm for variance related functions to avoid catastrophic cancellation in naive algorithm

#27325 opened 2025-12-05 09:18 by dylanhz

[FLINK-38759][runtime] Refactor application mode with PackagedProgramApplication

#27324 opened 2025-12-05 06:56 by eemario

fix: update wording for 2.1.0 release notes for java 17 usage community-reviewed target:release-2.1

#27321 opened 2025-12-04 20:48 by chenrui333

[FLINK-38775][release] Generate reference data for state migration tests based on release-2.2.0

#27317 opened 2025-12-04 03:51 by ruanhang1993

Bump @modelcontextprotocol/sdk and @angular/cli in /flink-runtime-web/web-dashboard dependencies javascript

#27316 opened 2025-12-04 03:37 by dependabot[bot]

[FLINK-38774] Fixed incorrect handling of hidden directories when obtFixed incorrect handling of hidden directories when obtaining partition structureaining partiti… community-reviewed

#27314 opened 2025-12-04 03:14 by abjfh30

[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]