Google Git Google Git
Sign in
apache/flink/HEAD
  1. 9412b86 [FLINK-40793][tests] Fix unstable DefaultSchedulerTest (#29278) by Sepuri Sai Krishna · 6 hours ago master
  2. e790cfb2 [FLINK-41271][python] Fail Python tasks when the data RPC channel between Java/Python process terminates (#29677) by Biao Geng · 7 hours ago
  3. 9efe0f8 [FLINK-34985][python] Fix named row access in thread-mode Table.map (#29287) by Stefan Wang · 10 hours ago
  4. 3f35de7 [hotfix][build] Update maven-archetype version to 3.4.1 by Sergey Nuyanzin · 14 hours ago
  5. 43a6beb [hotfix][ci] Skip e2e for docs-only PRs based on the PR's changed files by Sergey Nuyanzin · 17 hours ago
  6. 20fbfd5 [hotfix][splitter] Drop empty lines from code by Sergey Nuyanzin · 26 hours ago
  7. 79a06c9 [FLINK-41382][table] Ensure list of split calls is also splitted if required by Sergey Nuyanzin · 3 days ago
  8. 088d10b [FLINK-40963][table-planner] Add support for `DATE` and `TIME` conversion to `JSON` by Saketh Kurnool · 22 hours ago
  9. 61e584e [FLINK-41315][docs] Add the page structure for built-in function docs by Ramin Gharib · 23 hours ago
  10. 9c8f401 [FLINK-41273][table] Support set operations on unbounded tables in the Table API by Timo Theusner · 12 days ago
  11. d7ad073 [FLINK-41414][table] Expand the AGENTS.md guide for adding a built-in function by Ramin Gharib · 26 hours ago
  12. 30e854c [hotfix][python] List the missing expressions in the PyFlink API reference by Ramin Gharib · 26 hours ago
  13. 707f5e0 [FLINK-36694][filesystems] Update Azure, OSS and GCS to Hadoop 3.4.3 by Diljeet(DJ) Singh · 3 days ago
  14. 6ab669a [FLINK-41378][yarn] Use the AWS SDK v2 modules in the YARN S3 test by Martijn Visser · 2 days ago
  15. baf3e9a [FLINK-41378][ci] Drop the duplicate Hadoop 3.4.3 nightly stages by Martijn Visser · 3 days ago
  16. 50819e1 [FLINK-41378][build] Raise the minimum Hadoop version to 3.4.3 by Martijn Visser · 3 days ago
  17. e62133a [FLINK-39624][state] Return null from TtlListState#asyncGet for empty state by Purushottam Sinha · 4 days ago
  18. f2c498a [FLINK-41103][python] Clear ValueState without adding None in update(None) (#29601) by Sangkyoon Nam · 31 hours ago
  19. f69b51d [FLINK-41108][python] Use the TTL config when invalidating cached state after namespace merges (#29602) by Sangkyoon Nam · 31 hours ago
  20. c0ee48e [hotfix][test] Run `testAcceptingOfferedSlotsWithoutResourceManagerConnected` on a single threaded main executor by Sergey Nuyanzin · 2 days ago
  21. a21fa00 [FLINK-40776][table-runtime] Cache query-parameter pattern in `PARSE_URL` by Utkarsh Vashishtha · 2 days ago
  22. 56685ad [hotfix][ci] Rebalance end-to-end tests in `run-nightly-tests.sh` by Sergey Nuyanzin · 2 days ago
  23. 5b32cc7 [hotfix][tests] Use uppercase keywords in `CaseFunctionsITCase` by Sergey Nuyanzin · 2 days ago
  24. 9cc9a3e [FLINK-41380][table] Make generated code for `CASE` ... `WHEN` flat by Sergey Nuyanzin · 4 days ago
  25. ac930c9 [FLINK-41066][table] Handle upsert inputs in multi-way joins by Rion Williams · 2 days ago
  26. fc2568f [FLINK-41383][table] `REGEXP`, `REGEXP_EXTRACT` and `REGEXP_REPLACE` look up a constant pattern for every row by Sergey Nuyanzin · 2 days ago
  27. ab1cb0b [FLINK-41381][table] Use indexed seq for generation the digest of a Calc by Sergey Nuyanzin · 2 days ago
  28. 485da2c [FLINK-41370][table] Reject a literal index below 1 in SQL VARIANT array access (#29806) by Ramin Gharib · 2 days ago
  29. 8f8a1bc [hotfix][test] Use `-Dfast` for `test_kubernetes_itcases.sh` by Sergey Nuyanzin · 2 days ago
  30. 4fb928e [hotfix][runtime] Fix typo in JobManagerProcessSpec and TaskExecutorProcessSpec javadoc by Garvit Sharma · 12 days ago
  31. 2e89b87 [FLINK-40494][docs] Document the UUID type by Ramin Gharib · 7 days ago
  32. efb58c5 [FLINK-41308][runtime-web] Use nettyShuffleMemorySegments fields for the Netty Shuffle Buffers table (#29761) by Purushottam Sinha · 5 days ago
  33. de2cb88 [FLINK-41301][table] Throw TableRuntimeException for every failed cast from VARIANT by Ramin Gharib · 5 days ago
  34. 7c5b237 [FLINK-40319][table] Allow CAST from a VARIANT string value to BINARY and VARBINARY by Ramin Gharib · 5 days ago
  35. 12c944d [FLINK-39566][runtime-web] Add checkpoint duration Gantt view by Purushottam Sinha · 5 days ago
  36. 6759427 [FLINK-41282][table-planner] Use each multi-join step's own join columns for upsert keys by Anton Borisov · 5 days ago
  37. 8ac9c03 [FLINK-41263][table-planner] Add CompiledPlan support for BatchExecAdaptiveJoin by Bonnie Varghese · 5 days ago
  38. 44131db [FLINK-41086][table] Return NULL from `JSON_LENGTH` and `JSON_TYPE` when a JSON path function fails (#29628) by Yahya Kisana · 5 days ago
  39. 6e194b0 [FLINK-41362][table] Reject VARIANT in primary key columns (#29801) by Ramin Gharib · 6 days ago
  40. 362ce71 [hotfix][ci] Build flink-shaded for e2e only once by Sergey Nuyanzin · 6 days ago
  41. 17e3796 [hotfix][ci] Do not run disk clean up if e2e is skipped by Sergey Nuyanzin · 6 days ago
  42. dd8c9d7 [FLINK-41209][table] Run materialized table jobs in any TableEnvironment (#29659) by Timo Theusner · 6 days ago
  43. d6addb7 [hotfix][docs] Fix typos in Hive dialect docs by Arvind Kandpal · 6 days ago
  44. 4baebd6 [FLINK-37381][docs] Fix typo in `joins.md` document by Arvind Kandpal · 6 days ago
  45. ec317b7 [FLINK-40799][table] FlinkMarkChangeLogNormalizeProgram should cast to `RexCall` only in case of `AND` by Sergey Nuyanzin · 6 days ago
  46. 4938de93 [hotfix][table] Treat missing predicates in FilterPushDownSpec as empty by Sergey Nuyanzin · 10 days ago
  47. b70989e [hotfix][table] Treat missing predicates in MetadataFilterPushDownSpec as empty by Sergey Nuyanzin · 10 days ago
  48. 75f86b6 [FLINK-41331][ci] Move python header installation to flink-ci-docker by Sergey Nuyanzin · 7 days ago
  49. e4d2b06 [FLINK-41330][table] Return NULL for a VARIANT array index outside the INT range (#29785) by Ramin Gharib · 7 days ago
  50. c59810c [FLINK-41323][table-runtime] Add a binary encoding for a VARIANT column in the raw format by Ramin Gharib · 8 days ago
  51. 33a8167 [FLINK-41305][table-runtime] Support the raw line delimiter only for a string column and split UTF-8 on its bytes by Ramin Gharib · 8 days ago
  52. 2180171 [FLINK-41305][table-runtime] Require UTF-8 for a VARIANT column in the raw format and parse it from bytes by Ramin Gharib · 8 days ago
  53. 4cdc6d8 [FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types by Ramin Gharib · 7 days ago
  54. ce373fe [hotfix][ci] Remove obsolete libssl download for e2e netty-tcnative on Ubuntu 26.04 by Sergey Nuyanzin · 8 days ago
  55. 29655b3 [FLINK-41014][s3] Add an adaptive retry mode to the native S3 connector by Gabor Somogyi · 8 days ago
  56. 2ea9ccb [FLINK-40943][filesystems] Restore FileSink state written with flink-s3-fs-hadoop in flink-s3-fs-native by Joao Boto · 8 days ago
  57. 1867469 [FLINK-41298][table] Document and test that JSON input is read only up to its first value by Ramin Gharib · 9 days ago
  58. c48b1f1 [hotfix][e2e] Submit all TPC-H queries in one SQL Client session in test_tpch.sh by Sergey Nuyanzin · 9 days ago
  59. 891bd52 [hotfix][ci] Do not invoke lint or test for npm in compile_ci by Sergey Nuyanzin · 11 days ago
  60. 10189e5 [hotfix][ci] Use Redhat mirror only for certain groups by Sergey Nuyanzin · 11 days ago
  61. 8b445a1 [FLINK-41277][tests] `test_file_sink.sh` hangs in the second OpenSSL linkage run by Sergey Nuyanzin · 9 days ago
  62. e77c6fe [FLINK-41291] Bump snappy-java from 1.1.10.7 to 1.1.10.12 by Sergey Nuyanzin · 9 days ago
  63. a4c3507 [hotfix][ci] Make scala byte code generation multithreaded by Sergey Nuyanzin · 10 days ago
  64. b33e401 [hotfix][ci] Skip maven source in compile_ci and test jobs by Sergey Nuyanzin · 10 days ago
  65. ac917e9 [FLINK-41102][python] Flush pending keyed state operations on key switch without state cache (#29600) by Sangkyoon Nam · 9 days ago
  66. b9d1ab9 [FLINK-41275][e2e] Start SQL e2e test clusters once per class instead of per test by Sergey Nuyanzin · 13 days ago
  67. a5b015f [FLINK-41275][e2e] Start `FlinkContainers` once per class in `SqlClientITCase` by Sergey Nuyanzin · 13 days ago
  68. 0196674 [FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision by Ramin Gharib · 12 days ago
  69. cd4c2ab [hotfix][docs] Fix temporal table function examples (#29717) by Martijn Visser · 11 days ago
  70. 29a37c6 [hotfix][ci] Use `includeOnlyProperties` only for JGit by Sergey Nuyanzin · 11 days ago
  71. a7f4db7 [FLINK-34224][state] Fix mailbox handling in changelog storage metrics tests (#29560) by Rakesh Kumar · 12 days ago
  72. d542aea [FLINK-36725] Add CompiledPlan suppport for BatchExecRuntimeFilter by bvarghese1 · 2 weeks ago
  73. f9252f2 [hotfix][ci] Use more threads for download during ci, also download dep POMs in parallel by Sergey Nuyanzin · 12 days ago
  74. d8af382 [FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops by Purushottam Sinha · 13 days ago
  75. 3d6cd07 [FLINK-40886][runtime] Do not create the blob directories in the file count checks by Robin Varghese · 3 weeks ago
  76. cc5f054 [FLINK-41276][ci] Run the License task in parallel and regroup its log so the license checks still work by Sergey Nuyanzin · 12 days ago
  77. 449a0b1 [FLINK-40002][table-planner] Keep metadata column references out of physical filter push-down by Jim Hughes · 12 days ago
  78. 5a4f05b [FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join by Rion Williams · 12 days ago
  79. 4a0abed [FLINK-39330][runtime] Make CollectSinkFunction teardown null-safe (#28474) by Abhijeet Sharma · 12 days ago
  80. f9abda3 [FLINK-41256][runtime] Don't set the current key in KeyedSortPartitionOperator by Piotr Nowojski · 13 days ago
  81. f91e622 [FLINK-41256][runtime] Fail on operators changing the current key out of order in BATCH execution by Piotr Nowojski · 14 days ago
  82. 8d7da02 [FLINK-41256][runtime] Use moveToNextKey on the keyed input path of key-sorted inputs by Piotr Nowojski · 14 days ago
  83. 4f7d111 [FLINK-41256][runtime] Add moveToNextKey to KeyContext and KeyedStateBackend by Piotr Nowojski · 14 days ago
  84. 3e64714 [FLINK-41260][table] Improve error msg by rejecting ORDER BY in ARRAY_AGG and JSON_ARRAYAGG during planning by Rion Williams · 12 days ago
  85. 5b04b40 [FLINK-41211][table] Add listMaterializedTables for a given catalog and database by Timo Theusner · 12 days ago
  86. 379201f [FLINK-41104][python] Return true from MapState.contains for keys mapped to None by Sangkyoon Nam · 3 weeks ago
  87. 6928548 [FLINK-41106][python] Iterate key-value pairs in MapState.put_all (#29597) by Sangkyoon Nam · 12 days ago
  88. b6e3880 [hotfix][ci] Run python doc checks in parallel by Sergey Nuyanzin · 12 days ago
  89. 22a8c01 [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps (#29630) by Sangkyoon Nam · 12 days ago
  90. 3a48394 [FLINK-40196][table] Remove IS_NOT_NAN in favor of NOT IS_NAN (#29639) by Matt Belle · 12 days ago
  91. ebfb1b0 [FLINK-40499][runtime] Emit ACTIVE before final MAX_WATERMARK at drain by Martijn Visser · 3 months ago
  92. 72a46e1 [hotfix][ci] Use blobless fetch in Azure single-branch checkout by Sergey Nuyanzin · 13 days ago
  93. 6477043 [FLINK-40958][core] `BinaryVariantInternalBuilder.appendVariantImpl` might lead to `StackOverflow` by Sergey Nuyanzin · 13 days ago
  94. f8f7068 [FLINK-40948][table] Maintain window properties for different joins by Sergey Nuyanzin · 13 days ago
  95. d9af54c [FLINK-41217][table-planner] Don't emit the rows of VALUES again after a restore by Hanyu (Peter) Zheng · 2 weeks ago
  96. cb81919 [FLINK-41217][table] Add ValuesSource, a FLIP-27 source over the rows of VALUES by Hanyu (Peter) Zheng · 2 weeks ago
  97. be8a126 [FLINK-41217][connectors] Generate no data points for a count of 0 in DataGeneratorSource by Hanyu (Peter) Zheng · 14 days ago
  98. 267ea2b [FLINK-41217][core] Support empty sequences in NumberSequenceSource by Hanyu (Peter) Zheng · 14 days ago
  99. 6968bc4 [FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key by Timo Walther · 13 days ago
  100. f8cd4aa [FLINK-41048][container] Avoid JMX port race condition by Dale Lane · 3 weeks ago