-
Notifications
You must be signed in to change notification settings - Fork 13.6k
Pull requests: apache/flink
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[FLINK-37921][table] Replace TableKeyedAsyncWaitOperator with new operator under new async framework
#26698
opened Jun 18, 2025 by
xishuaidelin
Loading…
[FLINK-37944][test] Add utils for initializing process function test harnesses with async state.
#26697
opened Jun 18, 2025 by
AlexYinHan
Loading…
[FLINK-37867][state/forst] Ensure files of half-uploaded checkpoints are cleaned when using path copying.
#26696
opened Jun 18, 2025 by
AlexYinHan
Loading…
[FLINK-37946][backport][doc] fix sql syntax of page Table API & SQL EXPLAIN
#26693
opened Jun 17, 2025 by
slankka
Loading…
[FLINK-37889] [table-planner] Add JoinToMultiJoinRule
#26689
opened Jun 17, 2025 by
SteveStevenpoor
Loading…
[FLINK-36540][Runtime] Add Support for Hadoop Caller Context when using Flink to operate hdfs.
#26681
opened Jun 16, 2025 by
liangyu-1
Loading…
POC removing unaligned checkpoint flag from StreamConfig
#26678
opened Jun 13, 2025 by
1996fanrui
•
Draft
FLINK-37953: Add OBF password obfuscation support for SSL configurations
#26677
opened Jun 13, 2025 by
basapuram-kumar
Loading…
[FLINK-37938] ml_evaluation accumulator implementation
#26676
opened Jun 13, 2025 by
lihaosky
Loading…
[FLINK-37799][model][docs] Add document for OpenAI Model Function
#26671
opened Jun 12, 2025 by
yunfengzhou-hub
Loading…
[FLINK-37877][table] Add the key ordered operator in table runtime for key ordered async lookup join
#26668
opened Jun 11, 2025 by
xishuaidelin
Loading…
[FLINK-37795] rewrite ml_evaluate to ml_predict and aggregate function
#26667
opened Jun 10, 2025 by
lihaosky
Loading…
[hotfix] Rename isUnalignedCheckpointsInterruptibleTimersEnabled config
#26666
opened Jun 10, 2025 by
nateab
Loading…
Bump org.apache.kafka:kafka-clients from 2.2.2 to 3.9.1 in /flink-end-to-end-tests/flink-sql-client-test
dependencies
Pull requests that update a dependency file
java
Pull requests that update Java code
#26665
opened Jun 10, 2025 by
dependabot
bot
Loading…
[FLINK-37701][flink-runtime] Fix AdaptiveScheduler ignoring checkpoint states sizes for local recovery adjustment.
#26663
opened Jun 10, 2025 by
Izeren
Loading…
[FLINK-33045] Make it possible to disable auto-registering schema in Schema Registry
#26662
opened Jun 10, 2025 by
MartijnVisser
Loading…
[FLINK-35051][checkpoint] Treat handling of unaligned checkpoint barrier as the high priority mail
#26660
opened Jun 10, 2025 by
1996fanrui
Loading…
[FLINK-37923][sql] Introduce VARIANT type and PARSE_JSON to Flink SQL
#26655
opened Jun 9, 2025 by
Sxnan
Loading…
[FLINK-37294][state] Support state migration between disabling and enabling ttl in HeapKeyedStateBackend
#26651
opened Jun 8, 2025 by
hejufang
Loading…
Fix documentation issue regarding to createTemporalTableFunction params
#26645
opened Jun 6, 2025 by
ahmadm9212
Loading…
Previous Next
ProTip!
Mix and match filters to narrow down what you’re looking for.