Google GitGoogle Git
Sign in
apache/flink/HEAD
  1. e01bbca [FLINK-34246][runtime] Add option to only archive failed jobs to history server (#29015) by Archit Goyal · 11 hours ago master
  2. a9d5b29 [FLINK-40197][python] Support UDF bindings in DataFrame.sql (#29146) by Federico Dolce · 15 hours ago
  3. dd8eeed [FLINK-40424][table][python] Support windowing TVFs in the DataFrame API (#29070) by Timo Theusner · 16 hours ago
  4. 383996f [FLINK-40600][runtime-web] Add missing web dashboard specs and tighten thin ones by Purushottam Sinha · 3 days ago
  5. 1d6a308 [FLINK-40631][table] Pin `serialVersionUID` in `Variant` by Sergey Nuyanzin · 18 hours ago
  6. dd33da5 [FLINK-40520][checkpointing] Release spilled channel state on recovery abort between fetch and drain by Rui Fan · 2 days ago
  7. b7d7313 [FLINK-40282][docs] Expand and correct the concepts Glossary (#28863) by Lorenzo Nicora · 2 days ago
  8. 21f6a07 [FLINK-40492][table] Support casting from VARIANT to TIME and nanosecond timestamps by Moritz Manner · 2 days ago
  9. 30a02ea [FLINK-40515][core] Extend BinaryVariant to support UUID by Moritz Manner · 2 days ago
  10. c31f467 [FLINK-40464][python] Bump cibuildwheel to 4.2.0 (#29016) by florianvazelle · 2 days ago
  11. ca17e52 [FLINK-40593][s3] Batch recursive S3 deletes in native s3 connector with global and per-bucket opt-out by Gabor Somogyi · 2 days ago
  12. 0a6d741 [FLINK-35321][runtime] Ensure pendingCommitables metric is not re-registered while copying CommittableCollector (#27598) by Piotr Rudnicki · 2 days ago
  13. dcb6399 [FLINK-40478][runtime-web] Log effective HistoryServer configuration at startup (#29020) by Archit Goyal · 2 days ago
  14. d5c4ba0 [FLINK-40530][runtime-web] Isolate per-entry failures in job overview aggregation (#29062) by Archit Goyal · 2 days ago
  15. 8ae4de6 [FLINK-31931][runtime-web] Stop polling a TaskManager once it is gone by Martijn Visser · 9 weeks ago
  16. 97af402 [FLINK-31931][runtime/rest] Return 404 instead of 500 for unknown TaskManager in TaskManagerDetailsHandler by Martijn Visser · 9 weeks ago
  17. 3302914 [FLINK-40449][table] Reject non-temporal streaming sort during planning by Martijn Visser · 3 weeks ago
  18. fb806c8 [FLINK-40616][table] Make BITMAP and VARIANT conversion handling consistent by Ramin Gharib · 3 days ago
  19. f7ed53e [FLINK-40488][table] Support comparison and ordering for the UUID type by Ramin Gharib · 4 days ago
  20. 558fd5d [FLINK-40488][table] Support UUID value literals by Ramin Gharib · 4 days ago
  21. f83a73c [FLINK-40421][python] Add sorting APIs to DataFrame API by Milesian111 · 9 days ago
  22. 75892ba [FLINK-40529][python] Warn on use of deprecated APIs not at import time (#29061) by Deepyaman Datta · 2 days ago
  23. f2beda6 [FLINK-23758][python] Fix semantics of Expression.__invert__ (#29148) by Beetle brank · 2 days ago
  24. ef4e64c [FLINK-40606][table-planner] Fix code generation for binary array casts by dylanhz · 2 days ago
  25. 0bc5d30 [FLINK-40599][python] Allow pyarrow up to 25.x (#29134) by florianvazelle · 3 days ago
  26. 44edc3c [FLINK-40580][table] Render VARIANT object/array as SQL when casting to character string by Ramin Gharib · 3 days ago
  27. bf88c83 [FLINK-40423][python] Add Top-N support to the DataFrame API (#29105) by Timo Theusner · 3 days ago
  28. 7bd2926 [FLINK-40603][build] Use hadoop 3.4.3 for jdk25 by Sergey Nuyanzin · 3 days ago
  29. e63885d [FLINK-40430][python] Add configuration support to DataFrame API by Federico Dolce · 11 days ago
  30. 4e9d541 [FLINK-40567][tests] Avoid @TempDir cleanup race in HistoryServerArchiveFetcherTest (#29116) by Purushottam Sinha · 3 days ago
  31. 7ebd152 [FLINK-40117][runtime-web] Extend Vitest smoke-test coverage to more web-dashboard views by Purushottam Sinha · 7 weeks ago
  32. e712083 [FLINK-40596] Closing metric might lead to a number of test failures by Sergey Nuyanzin · 4 days ago
  33. e57428c [FLINK-40590][runtime-web] Update Angular and monaco-editor to latest available versions by Purushottam Sinha · 4 days ago
  34. d8f92d4 [FLINK-40399][state] Separate key filter runtime contract from push-down planning by Ilya Soin · 4 days ago
  35. 39bf636 [hotfix][table] Fix tryParseJson() docs to say NULL instead of throws an error by Ramin Gharib · 5 days ago
  36. 7fcc6b8 [FLINK-40549][metrics] Close splitMetricGroup along with the child splitWatermarkMetricGroup by Efrat Levitan · 9 days ago
  37. 88a2854 [FLINK-40549][metrics] Remove metricGroup parent reference upon close() by Efrat Levitan · 9 days ago
  38. 78b0df6 [FLINK-37926][table] Support casting from VARIANT to MAP by Ramin Gharib · 5 days ago
  39. 4ad8e83 [FLINK-37926][table] Support casting from VARIANT to ROW and STRUCTURED by Ramin Gharib · 5 days ago
  40. ae57348 [hotfix][docs] Add 2.3 to PreviousDocs list by Gustavo de Morais · 5 days ago
  41. 9c67427 [FLINK-40541][table] Add on_time argument to SNAPSHOT for LATERAL SNAPSHOT join by Fabian Hueske · 5 days ago
  42. 0fb6dcf [FLINK-40487][table] `CAST` between `UUID` and `STRING` / `BINARY(16)` by Ramin Gharib · 5 days ago
  43. ad4a20a [FLINK-40573][build] Remove wildcard imports while spotless apply by Sergey Nuyanzin · 5 days ago
  44. 1705984 [FLINK-39977][runtime] Add ITCase for file-merged channel state recovery by Zakelly · 8 days ago
  45. 396face [FLINK-39977][runtime] Recovery of merged channel state handles by Zakelly · 14 days ago
  46. bf4a71a [FLINK-40545][table] Add `parseJson()` and `tryParseJson()` Table API expression methods by Ramin Gharib · 6 days ago
  47. ca6e927 [FLINK-40071][build] Bump jackson-bom to 2.22.2 by Purushottam Sinha · 6 days ago
  48. c51e715 [FLINK-40565] Bump netty to 4.2.17 by Sergey Nuyanzin · 6 days ago
  49. fc2b5ef [FLINK-40563][build] Bump lombok to 1.18.48 by Sergey Nuyanzin · 6 days ago
  50. 3593f08 [FLINK-40517][checkpointing] Aggregate cross-channel watermarks on the recovery unspilling thread for fan-in rescale by Rui Fan · 12 days ago
  51. 30b5f50 [FLINK-40350][table-runtime] `LPAD`/`RPAD` split supplementary-plane characters into unpaired surrogates by Sepuri Sai Krishna · 8 days ago
  52. 9a3b1a8 [FLINK-40527] Update flink-shaded to 22.0 by Sergey Nuyanzin · 8 days ago
  53. dd2bc4b [FLINK-40540][table-planner] Put the rule's reason first in the planning error by Martijn Visser · 10 days ago
  54. 5d3597c [FLINK-37926][table] Support casting from `VARIANT` to `ARRAY` by Ramin Gharib · 8 days ago
  55. d5ff3fe [FLINK-40548][ci] Use image with ubuntu 24.04 by Sergey Nuyanzin · 8 days ago
  56. 995865e [FLINK-40490][table] Add runtime serialization and codegen for the `UUID` type by Ramin Gharib · 8 days ago
  57. aff06f8 Revert "[FLINK-39977][runtime] Recovery of merged channel state handles" by Sergey Nuyanzin · 8 days ago
  58. a1b2ccd Revert "[FLINK-39977][runtime] Add ITCase for file-merged channel state recovery" by Sergey Nuyanzin · 8 days ago
  59. e0fed5b [FLINK-40466][table] Refactor defining table arguments in PTF Test Harness for more complex table arguments (#29018) by Mika Naylor · 8 days ago
  60. ab65430 [FLINK-39977][runtime] Add ITCase for file-merged channel state recovery by Zakelly · 14 days ago
  61. 85d60af [FLINK-39977][runtime] Recovery of merged channel state handles by Zakelly · 14 days ago
  62. c4bfcd5 [FLINK-40370][python] Fix bytes-backed Avro decimal framing (#28996) by vbhanuchander-lang · 9 days ago
  63. 26c1062 [FLINK-40491][core] Extend `BinaryVariant` with `TIME`, `TIMESTAMP_NS`, `TIMESTAMP_LTZ_NS` primitives by Moritz Manner · 9 days ago
  64. d554162 [FLINK-40477][table] Fix constraint enforcer for partial deletes (#29067) by Fabian Hueske · 9 days ago
  65. e67c936 [FLINK-40539][sql-gateway] Redact sensitive values in SET; and session config responses by Gabor Somogyi · 9 days ago
  66. 81389ac [FLINK-40431][python] Add UDF support to DataFrame API (#29029) by Liu Liu · 10 days ago
  67. 3e1c65e [FLINK-40519][network] Deliver priority barrier to a credited remote reader while the subpartition is blocked during recovery by Rui Fan · 12 days ago
  68. 7d19438 [FLINK-40496][table-planner] Apply append-only column rules consistently when altering a materialized table (#29034) by Arvid Heise · 10 days ago
  69. 916248e [FLINK-40537][build] IDEA should use java version same as in `source.java.version` by Sergey Nuyanzin · 10 days ago
  70. 008e440 [FLINK-40422][python] Add slicing APIs to DataFrame API by Milesian111 · 2 weeks ago
  71. 9bd05c5 [FLINK-40524][network] Skip the recoveredBuffers monitor on the getNextBuffer hot path for channels that never recover by Rui Fan · 12 days ago
  72. a0d52bd [FLINK-40521][network] Document potential lost priority-barrier wakeup in LocalInputChannel during checkpointing-during-recovery by Rui Fan · 12 days ago
  73. 8ce71ee [FLINK-40518][checkpointing] Only enable checkpointing-during-recovery when unaligned checkpoints are enabled by Rui Fan · 12 days ago
  74. 3cdde2a [FLINK-40522][network] Deduplicate RecoveryCheckpointBarrier sentinel helpers shared by LocalInputChannel and RemoteInputChannel by Rui Fan · 12 days ago
  75. c7489bc [FLINK-40525][network] Remove residual receivedBuffers lock in finishReadRecoveredState to avoid ABBA deadlock by Rui Fan · 12 days ago
  76. 03e57af [FLINK-40523][network] Compute tracePersist debug string only when trace logging is enabled by Rui Fan · 12 days ago
  77. bee138d [FLINK-40536][build] Bump cyclonedx-maven-plugin to 2.9.3 by Sergey Nuyanzin · 10 days ago
  78. 9e76ac4 [FLINK-40197][python] Add sql() to the DataFrame API by Federico Dolce · 2 weeks ago
  79. 878844f [FLINK-40486][table] Introduce the UUID logical type by Ramin Gharib · 11 days ago
  80. 76b7ed3 [FLINK-40017] Introduce Seaweedfs in native-s3-fs by Samrat · 11 days ago
  81. a922643 [hotfix][build] Bump `directory-maven-plugin` to 1.0 by Sergey Nuyanzin · 12 days ago
  82. 8b0f380 [FLINK-40510][build] Bump Apache Parent pom to 39 by Sergey Nuyanzin · 12 days ago
  83. 6221069 [FLINK-40382][tests] Execute static nested test class variants and guard against regressions by Purushottam Sinha · 11 days ago
  84. 097f914 [FLINK-40207][table-runtime] Modernize BinaryStringDataTest with JUnit 5 by Ramin Gharib · 11 days ago
  85. cea216a [FLINK-40356][table] Add new MapFromEntries built-in function by Vasudev Kelappassery · 12 days ago
  86. 0cca582 [hotfix][docs] Fix AzureTableConfiguration class name casing in Azure Table Storage doc (#29044) by Vaibhav Mashal · 12 days ago
  87. 76e774e [hotfix][runtime] Fix getOrinalTypeSerializerSnapshot typo (#29046) by Weiqing Yang · 13 days ago
  88. 13a86e4 [FLINK-40506][s3] Shade all runtime deps in flink-s3-fs-native to avoid silently dropping plugin dependencies by Gabor Somogyi · 13 days ago
  89. b53ea1b [FLINK-40481][table] Fix SHOW CREATE FROM_NOW timestamp direction (#29030) by Arvid Heise · 2 weeks ago
  90. cc633c6 [FLINK-40241][table-runtime] Support `VARIANT` as column type in the 'raw' format by Ramin Gharib · 2 weeks ago
  91. a24de2e [FLINK-40498][tests] Adjust LateralSnapshotJoin tests for optional TABLE keyword (#29035) by Fabian Hueske · 2 weeks ago
  92. e439490 [FLINK-37666] CWE-378: Creation of Temporary File With Insecure Permissions in Temporary File Creation by Samrat002 · 4 weeks ago
  93. bb773b5 [FLINK-40475][runtime] Fix watermark loss and stall in StatusWatermarkValve when subpartitions realign after idleness (#29024) by Martijn Visser · 2 weeks ago
  94. e3a53a5 [FLINK-40459][build] Bump Maven from 3.8.6 to 3.9.16 (#29009) by Martijn Visser · 2 weeks ago
  95. 6fc280f [FLINK-39780] Make TABLE keyword optional in LATERAL context (#28276) by Fabian Hueske · 2 weeks ago
  96. 3265f06 [hotfix][docs] Fix OPTIONS hint key in time attributes docs by Rango · 2 weeks ago
  97. 8e9e69c [FLINK-39986][table-planner] Support Python UDF deduplication in projection and condition (#28638) by RaoraoXiong · 2 weeks ago
  98. 438b3a8 [FLINK-40484][tests] Run UnalignedCheckpointTestBase with the DefaultScheduler by Rui Fan · 2 weeks ago
  99. 57de467 [FLINK-40482][runtime] Abort checkpoint unless all tasks are RUNNING or FINISHED by Rui Fan · 2 weeks ago
  100. 5265908 [FLINK-40194][python] Add drop_duplicates to the DataFrame API (#29022) by Timo Theusner · 2 weeks ago