Google Git
Sign in
apache/flink/HEAD
  1. 45c62ca [FLINK-39103][runtime] Tolerate deserializer release failure if the corresponding channel already had errors by Roman Khachatryan · 3 days ago master
  2. b5fbf2b [hotfix][runtime] Release all channels' deserializers before failing in StreamTaskNetworkInput by Roman Khachatryan · 3 days ago
  3. b1192e8 [FLINK-39029] move catalog store factory builder to new class (#27531) by Hao Li · 30 hours ago
  4. e5eeb6c [FLINK-38523] Upgrade Pekko to 1.4.0 by Mate Czagany · 33 hours ago
  5. 3832967 [FLINK-39088][table] Fix upsert key preservation by introducing injective cast checks for CAST by Gustavo de Morais · 35 hours ago
  6. 8413461 [FLINK-38953] Cleanup configurations for SSL hostname verification by Mate Czagany · 35 hours ago
  7. 825400b [hotfix] Fix formatting by Piotr Nowojski · 9 days ago
  8. 68aca15 [FLINK-37399][docs] Regenerate docs by Piotr Nowojski · 11 months ago
  9. 774fd07 [FLINK-37399][tests] Randomize watermark alignment buffer size in ITCases by Piotr Nowojski · 11 months ago
  10. bda5c7c [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment by Piotr Nowojski · 11 months ago
  11. e03da5e [FLINK-37399][runtime] Add SamplingWatermarkRingBuffer by Piotr Nowojski · 11 months ago
  12. f4d8e4b [hotfix][tests] Create Builder for SourceOperatorTestContext by Piotr Nowojski · 11 months ago
  13. 476e27a [hotfix][tests] Refactor SourceOperatorSplitWatermarkAlignmentTest by Piotr Nowojski · 11 months ago
  14. deadc21 [hotfix][tests] Extract updateIntervalMillis in SourceOperatorAlignmentTest by Piotr Nowojski · 11 months ago
  15. fe06d66 hotfix][docs] Fix uv PATH for Chinese docs build in CI by Martijn Visser · 2 days ago
  16. f597bef [hotfix][docs] Add uv to PATH for Chinese docs build in CI by Martijn Visser · 2 days ago
  17. 1a45d0b [hotfix][docs] Remove manual venv activation from docs.sh by Martijn Visser · 2 days ago
  18. ae0c1e6 [hotfix][tests] De-duplicate operator IDs in RestoreUpgradedJobITCase by Roman Khachatryan · 9 days ago
  19. c06640f [hotfix][tests] Increase min pause between checkpoints in migration tests by Roman · 4 weeks ago
  20. 1175aa9 [FLINK-38939] Minimize checkpoint trigger delay if sources are waiting for a checkpoint by Roman Khachatryan · 5 weeks ago
  21. b2b044d [hotfix][runtime] Move checkpointing configuration code to CheckpointCoordinatorConfiguration by Roman Khachatryan · 11 months ago
  22. c0ada39 [hotfix][runtime] Try to get last checkpoint on recovery regardless of checkpointing interval by Roman · 4 weeks ago
  23. 7c90b9e [FLINK-38939][runtime] Pause Sources until the first checkpoint barrier is received by Roman Khachatryan · 5 weeks ago
  24. 259a6a7 [hotfix][tests] Close OutputWriter in SourceOperatorStreamTaskTest by Roman Khachatryan · 5 weeks ago
  25. da75518 [FLINK-39108][tests] Disable CheckpointIntervalDuringBacklogITCase.testNoCheckpointDuringBacklog by Roman Khachatryan · 3 days ago
  26. 0d3133b [FLINK-34099][tests] Harden CheckpointIntervalDuringBacklogITCase by Roman Khachatryan · 3 days ago
  27. b63bae8 [FLINK-38506][tests] Fix flaky SideOutputITCase by Roman Khachatryan · 2 days ago
  28. 4db49e0 [FLINK-39067][docs] Move Python documentation from Hugo to PyDocs (#27586) by Martijn Visser · 2 days ago
  29. 2db7996 [FLINK-36059][tests] Bump cp-kafka and cp-schema-registry from 7.2.2 to 7.2.9 by Martijn Visser · 3 days ago
  30. 7341131 [FLINK-39104][metrics] Add configurable gzip compression for OTel gRPC/HTTP exporters by Aleksandr Iushmanov · 9 months ago
  31. 579d803 [FLINK-39102][e2e] Fix Kubernetes E2E tests broken by Docker 29 runner update (#27619) by Martijn Visser · 3 days ago
  32. 44029ff [FLINK-39099] Update `testcontainers` to fix GitHub runner Docker compatibility issue by Aleksandr Savonin · 4 days ago
  33. 3ed9951 [FLINK-38592] Add configurable property for file system factories to allow loading multiple factories packaged in the image depending on their priority for the same schema. by Aleksandr Iushmanov · 7 days ago
  34. 4d4c309 [FLINK-39078] Disallow ON CONFLICT for non upsert sinks (#27595) by Dawid Wysakowicz · 8 days ago
  35. 1779d20 Revert "[FLINK-38928] Implement an operator for handling DO ERROR/NOTHING (#27502)" by Dawid Wysakowicz · 9 days ago
  36. 972ab832 [FLINK-39002][tests] Temporarily disable SSL in test_file_sink by Roman Khachatryan · 10 days ago
  37. 743b9bd [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING (#27502) by Dawid Wysakowicz · 9 days ago
  38. a575084 [FLINK-38969][SQL] Extend json_string to convert variant type by Swapna Marru · 9 days ago
  39. 5f2e30e [hotfix] add .worktrees to .gitignore (#27582) by Natea Eshetu Beshada · 10 days ago
  40. f5e7558 [FLINK-39017][web] Fix task click handler in job graph for Chrome 144+ by Martijn Visser · 10 days ago
  41. b68ab1e [hotfix][docs] Strip leading slash in redirect template before relURL by Martijn Visser · 10 days ago
  42. b81b124 [FLINK-35661][table] Fix MiniBatchGroupAggFunction silently dropping records by Natea Eshetu Beshada · 2 weeks ago
  43. 996c3fc [hotfix] Add .claude to gitignore by Natea Eshetu Beshada · 2 weeks ago
  44. 953ac95 [hotfix][docs] Fix redirect template to use relURL for correct base path by Martijn Visser · 10 days ago
  45. 338b734 [FLINK-39058][model-triton] Use Preconditions#checkArgument to replace raw condition validation in model-triton module by Yuepeng Pan · 11 days ago
  46. 8279696 [FLINK-39057][JUnit5 Migration] Migrate assertion lines to assertj for flink-model-triton module by Yuepeng Pan · 11 days ago
  47. 280e889 [FLINK-38945][docs] Bump Hugo to v0.124.1 to fix ref resolution for connector docs by Martijn Visser · 11 days ago
  48. 8facd40 [FLINK-38966][build] Update rsync for GHA to latest v8.0.2 (LTS) for main docs by Martijn Visser · 11 days ago
  49. ccaa2eb [FLINK-38945][docs][FLIP-561] Restructure Flink documentation (#27541) by Martijn Visser · 11 days ago
  50. 2d5e14f [FLINK-39052][python] Bump version auditwheel to 6.6.0 (#27563) by Dian Fu · 11 days ago
  51. 7b1e212 [FLINK-38943][runtime] Support Adaptive Partition Selection for RescalePartitioner & RebalancePartitioner (#27446) by Yuepeng Pan · 11 days ago
  52. 79e79fc [hotfix][runtime] Log unexpected non-terminal task state by Roman Khachatryan · 14 days ago
  53. c72f40e [FLINK-39052][python] Remove usage of pkg_resources (#27556) by Dian Fu · 12 days ago
  54. db1cf97 [FLINK-38857][model] Introduce Triton model function by averyzhang · 7 weeks ago
  55. 7488449 [FLINK-38966][build] Update rsync for GHA to latest v8.0.2 (LTS) for main docs by Martijn Visser · 2 weeks ago
  56. 09b8e64 [hotfix][docs] Update AWS connector version to 6.0 by Ferenc Csaky · 2 weeks ago
  57. c71ff20 [FLINK-21672][test] Amend unit test so it works with IBM java (#27515) by David Radley · 2 weeks ago
  58. e8ac5b1 [FLINK-39011][table-api-java] Accept UnresolvedDataType in BaseExpression.cast() by Timo Walther · 2 weeks ago
  59. 70ca7c6 [FLINK-38957][table-planner] Support `ProcessTableFunction` registration via `CompiledPlan` by Ferenc Csaky · 2 weeks ago
  60. 1a40971 [FLINK-38986][runtime][test] Update further tests with modern cipher suite by balassai · 2 weeks ago
  61. e9e5b71 [FLINK-39004][flink-table] JUnit5 Migration: Migrate the remaining test classes related to junit4 of flink-table module to junit5 by Yuepeng Pan · 3 weeks ago
  62. 48a267a [FLINK-38699][ui] Sort jobs by end and start time by default (#27464) by Yi Zhang · 2 weeks ago
  63. 5f5003a [FLINK-38941][python] Add Python building blocks for async Python scalar function by Dian Fu · 6 weeks ago
  64. fd9a1ba [FLINK-38992] Expire associated state together for non-time over windows by bvarghese1 · 3 weeks ago
  65. be24d8f [FLINK-39008][table-common] Support record types natively in DataTypeExtractor by Timo Walther · 3 weeks ago
  66. 03115f1 [FLINK-38912] Upgrade Netty to `4.2.6.Final` by Mate Czagany · 3 weeks ago
  67. 80e26ca [FLINK-37924][table]Introduce Built-in Function to Access field or element in the Variant (#27330) by Jinkun Liu · 3 weeks ago
  68. 00e4c8f [FLINK-38986][runtime][test] Update SSL tests with modern cipher suites by balassai · 3 weeks ago
  69. da5c82b [FLINK-38995][docs] Update the current Status of Disaggregated State and ForSt by Yuan Mei · 3 weeks ago
  70. 2ac5d28 [FLINK-33123][runtime] Fix the wrong dynamic replacement of partitioner from FORWARD to REBALANCE for autoscaler and adaptive scheduler by Yuepeng Pan · 4 weeks ago
  71. fdeb848 [FLINK-38993][table] Move materialized table query change validation logic from converter to operation by Sergey Nuyanzin · 3 weeks ago
  72. 7226d37 [FLINK-38927] Support ON CONFLICT in SqlParser (#27426) by Dawid Wysakowicz · 3 weeks ago
  73. ae45832 [FLINK-37722] Eliminate redundant field initialization of PojoSerializer by Zhanghao Chen · 10 months ago
  74. d30cf4d [FLINK-38932][runtime] Fix incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay (#27429) by Zhanghao Chen · 3 weeks ago
  75. 6c75724 [FLINK-38982][test] Migrate the JUnit5 for ClassLoaderUtilsTest of flink-core module (#27477) by Yuepeng Pan · 3 weeks ago
  76. 43305db [FLINK-38345] Annotate SourceSwitchContext#getPreviousEnumerator as nullable for recovery scenarios. by mattcuento · 7 weeks ago
  77. d141ad7 [hotfix][infra] Add .metals and .bloop into .gitignore (#27480) by David Radley · 3 weeks ago
  78. fdf1a2e [FLINK-38967][test] Fix flaky UnalignedCheckpointFailureHandlingITCase by Mate Czagany · 3 weeks ago
  79. 76fbab4 [FLINK-38908][flink-runtime][test] Fix flaky ExecutionPartitionLifecycleTest by Mate Czagany · 3 weeks ago
  80. 52f5eaa [FLINK-38812][python] Add log to show whether cython is enabled (#27458) by Liu Jiangang · 3 weeks ago
  81. d43d6c0 [FLINK-38983][test] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module (#27478) by Yuepeng Pan · 3 weeks ago
  82. 0124ee7 [FLINK-36992][table] Migrate `SplitAggregateRule` to java by Jacky Lau · 4 weeks ago
  83. fd447f0 [FLINK-38890][table] Migrate `PullUpWindowTableFunctionIntoWindowAggregateRule` to java by Roman · 4 weeks ago
  84. ad229f9 [FLINK-38964][table] Reuse Calcite's `SqlValidatorImpl#maybeCast` by Sergey Nuyanzin · 4 weeks ago
  85. edbe964 [FLINK-38979][build] Enable flink-tests-java17 for jdk21 build by Sergey Nuyanzin · 4 weeks ago
  86. 4f530c5 [hotfix][tests] Catch `AssertionError` in `DiffRepository` instead of `AssertionFailedError` by Sergey Nuyanzin · 4 weeks ago
  87. 2a3d701 [FLINK-36986][table] Migrate `SplitRemoteConditionFromJoinRule` to java by Jacky Lau · 4 weeks ago
  88. 73993fc [FLINK-38885][table] Migrate `StreamPhysicalJoinRuleBase` and its children by Sergey Nuyanzin · 4 weeks ago
  89. 08648c5 [FLINK-38963][table] Altering query should be possible if `MATERIALIZED TABLE` schema contains non persisted columns by Sergey Nuyanzin · 4 weeks ago
  90. 721cb0a [hotfix][table] Rename vars in `CatalogViewITCase#testShowCreateViewWithTumbleWindow` by Sergey Nuyanzin · 4 weeks ago
  91. 4367f39 [hotfix] Use whitelisted commit SHA for rsync-deployment GHA by Martijn Visser · 4 weeks ago
  92. 1fd9aac [FLINK-38966][build] Update rsync for GHA to latest v8.0.2 (LTS) for legacy docs by Martijn Visser · 4 weeks ago
  93. ab49fae [FLINK-38799][runtime] Rename `LoadingWeight` to `TaskExecutionLoad` (#27333) by Ferenc Csaky · 4 weeks ago
  94. 62566c4 [FLINK-38940] Start checkpointing when all tasks are running and job is running by Roman Khachatryan · 4 weeks ago
  95. 2860e9a [FLINK-38960][doc] Clarify scope of state compatibility in "Upgrading" documentation by AlexYinHan · 4 weeks ago
  96. e3adbdc [FLINK-38777][history] HistoryServer supports application archives by Yi Zhang · 5 weeks ago
  97. bf9695c [FLINK-38950][table] `SqlNodeConvertUtils` should use validated query output by Sergey Nuyanzin · 4 weeks ago
  98. 17dda61 [FLINK-38903] Update flink-shaded to 21.0 by Mate Czagany · 4 weeks ago
  99. 2426faf [FLINK-38913][table] `ArrayIndexOutOfBoundsException` while unparsing `ExtendedSqlRowTypeNameSpec` by David Radley · 4 weeks ago
  100. 294a7c3 [hotfix] Add --omit-dir-times to legacy docs rsync to fix permission errors by Martijn Visser · 4 weeks ago