-
Notifications
You must be signed in to change notification settings - Fork 13k
Pull requests: apache/flink
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[FLINK-34482][checkpoint] Rename checkpointing options
component=Runtime/Checkpointing
#24878
opened Jun 3, 2024 by
masteryhx
Loading…
[FLINK-32081][checkpoint] Compatibility between file-merging on and off across job runs
component=Runtime/Checkpointing
component=Runtime/StateBackends
#24873
opened May 31, 2024 by
ljz2051
Loading…
[FLINK-34559] Limit Global & Local Aggregation buffers
component=TableSQL/Runtime
#24869
opened May 29, 2024 by
rkhachatryan
Loading…
[FLINK-35353][docs-zh]Translate "Profiler" page into Chinese
component=chinese-translation
component=Documentation
#24822
opened May 22, 2024 by
drymatini
Loading…
[FLINK-35049][state] Implement Map Async State API for ForStStateBackend
component=Runtime/StateBackends
#24812
opened May 20, 2024 by
fredia
Loading…
[FLINK-34108][table] Add built-in URL_ENCODE and URL_DECODE function.
component=TableSQL/API
#24773
opened May 12, 2024 by
superdiaodiao
Loading…
[FLINK-34609][table] Migrate BatchPhysicalScriptTransformRule to java.
component=TableSQL/Planner
#24457
opened Mar 7, 2024 by
liuyongvs
Loading…
[FLINK-34603][table] Migrate BatchPhysicalBoundedStreamScanRule to java.
component=TableSQL/Planner
#24451
opened Mar 7, 2024 by
liuyongvs
Loading…
[FLINK-34487][ci] Adds Python Wheels nightly GHA workflow
component=BuildSystem/CI
#24426
opened Mar 1, 2024 by
morazow
Loading…
[FLINK-34497][REST] Avoid using system classloader in SerializedThrowableDeserializer
component=Runtime/REST
#24369
opened Feb 22, 2024 by
jrthe42
Loading…
[FLINK-34427][runtime] Adds state check to requirementsCheck logic
component=Runtime/Coordination
#24309
opened Feb 13, 2024 by
XComp
Loading…
[FLINK-34094] Adds documentation for AsyncScalarFunction
component=Documentation
#24224
opened Jan 30, 2024 by
AlanConfluent
Loading…
[FLINK-34252][table] Fix lastRecordTime tracking in WatermarkAssignerOperator
component=TableSQL/Runtime
#24211
opened Jan 29, 2024 by
dchristle
Loading…
[FLINK-34111][table] Add JSON_QUOTE and JSON_UNQUOTE function
component=TableSQL/API
#24156
opened Jan 19, 2024 by
jeyhunkarimov
Loading…
[FLINK-34015][checkpoint] fix that passing ignore-unclaimed-state through dynamic props does not take effect
component=Runtime/StateBackends
#24058
opened Jan 10, 2024 by
xiangforever2014
Loading…
[FLINK-33741]Expose Rocksdb Histogram statistics in Flink metrics
component=<none>
#24050
opened Jan 9, 2024 by
zhougit86
Loading…
[FLINK-33932][checkpointing] Add retry mechanism in RocksDBStateUploader
component=Runtime/Checkpointing
#23986
opened Dec 25, 2023 by
xiangyuf
Loading…
[hotfix] [tests] Per-class the lifecycle of mini-cluster in
ClientHeartbeatTest
.
#23910
opened Dec 12, 2023 by
TestBoost
Loading…
[FLINK-33719][table] Cleanup the usage of deprecated StreamTableEnvir…
component=<none>
#23898
opened Dec 8, 2023 by
liuyongvs
Loading…
[FLINK-33584][Filesystems] Update Hadoop Filesystem dependencies to 3.3.6
component=Connectors/FileSystem
component=FileSystems
#23844
opened Nov 30, 2023 by
snuyanzin
Loading…
[FLINK-27681] RocksdbStatebackend verify incremental sst file checksum during checkpoint
component=Runtime/StateBackends
#23765
opened Nov 21, 2023 by
mayuehappy
Loading…
[FLINK-33536] Fix Flink Table API CSV streaming sink fails with IOException: Stream closed
component=FileSystems
component=TableSQL/API
#23725
opened Nov 15, 2023 by
Samrat002
Loading…
[FLINK-33509] Fix flaky test testNodeAffinity() in InitTaskManagerDecoratorTest.java
component=<none>
#23694
opened Nov 10, 2023 by
yijut2
Loading…
[FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler
component=Runtime/Task
#23635
opened Oct 31, 2023 by
RocMarshal
Loading…
[FLINK-33249][table-planner] comment should be parsed by StringLitera…
component=TableSQL/Planner
#23517
opened Oct 12, 2023 by
zhougit86
Loading…
Previous Next
ProTip!
Updated in the last three days: updated:>2024-06-04.