8
I Use This!
Very High Activity

Commits : Listings

Analyzed 1 day ago. based on code collected 2 days ago.
Sep 03, 2025 — Sep 03, 2026
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
[FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses More... 2 days ago
[FLINK-40431][python] Add UDF support to DataFrame API (#29029) More... 3 days ago
[FLINK-40496][table-planner] Apply append-only column rules consistently when altering a materialized table (#29034) More... 3 days ago
[FLINK-40537][build] IDEA should use java version same as in `source.java.version` More... 3 days ago
[FLINK-40536][build] Bump cyclonedx-maven-plugin to 2.9.3 More... 3 days ago
[FLINK-40486][table] Introduce the UUID logical type More... 4 days ago
[FLINK-40017] Introduce Seaweedfs in native-s3-fs More... 4 days ago
[FLINK-40382][tests] Execute static nested test class variants and guard against regressions More... 5 days ago
[FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5 More... 5 days ago
[FLINK-40524][network] Skip the recoveredBuffers monitor on the getNextBuffer hot path for channels that never recover More... 5 days ago
[FLINK-40525][network] Remove residual receivedBuffers lock in finishReadRecoveredState to avoid ABBA deadlock More... 5 days ago
[FLINK-40523][network] Compute tracePersist debug string only when trace logging is enabled More... 5 days ago
[FLINK-40356][table] Add new MapFromEntries built-in function More... 5 days ago
[FLINK-40519][network] Deliver priority barrier to a credited remote reader while the subpartition is blocked during recovery More... 5 days ago
[FLINK-40521][network] Document potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery More... 5 days ago
[FLINK-40518][checkpointing] Only enable checkpointing-during-recovery when unaligned checkpoints are enabled More... 5 days ago
[FLINK-40522][network] Deduplicate RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel More... 5 days ago
[hotfix][docs] Fix AzureTableConfiguration class name casing in Azure Table Storage doc (#29044) More... 5 days ago
[hotfix][build] Bump `directory-maven-plugin` to 1.0 More... 5 days ago
[FLINK-40510][build] Bump Apache Parent pom to 39 More... 6 days ago
[hotfix][runtime] Fix getOrinalTypeSerializerSnapshot typo (#29046) More... 6 days ago
[FLINK-40506][s3] Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies More... 7 days ago
[FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction (#29030) More... 8 days ago
[FLINK-40241][table-runtime] Support `VARIANT` as column type in the 'raw' format More... 8 days ago
[FLINK-40498][tests] Adjust LateralSnapshotJoin tests for optional TABLE keyword (#29035) More... 8 days ago
[FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness (#29024) More... 8 days ago
[FLINK-40197][python] Add sql() to the DataFrame API More... 8 days ago
[FLINK-40459][build] Bump Maven from 3.8.6 to 3.9.16 (#29009) More... 8 days ago
[FLINK-39780] Make TABLE keyword optional in LATERAL context (#28276) More... 8 days ago
[hotfix][docs] Fix OPTIONS hint key in time attributes docs More... 8 days ago