Google Git
Sign in
apache / flink / HEAD
  1. ae45832 [FLINK-37722] Eliminate redundant field initialization of PojoSerializer by Zhanghao Chen · 9 months ago master
  2. d30cf4d [FLINK-38932][runtime] Fix incorrect scheduled timestamp in ProcessingTimeCallback with scheduleWithFixedDelay (#27429) by Zhanghao Chen · 21 hours ago
  3. 6c75724 [FLINK-38982][test] Migrate the JUnit5 for ClassLoaderUtilsTest of flink-core module (#27477) by Yuepeng Pan · 21 hours ago
  4. 43305db [FLINK-38345] Annotate SourceSwitchContext#getPreviousEnumerator as nullable for recovery scenarios. by mattcuento · 4 weeks ago
  5. d141ad7 [hotfix][infra] Add .metals and .bloop into .gitignore (#27480) by David Radley · 32 hours ago
  6. fdf1a2e [FLINK-38967][test] Fix flaky UnalignedCheckpointFailureHandlingITCase by Mate Czagany · 35 hours ago
  7. 76fbab4 [FLINK-38908][flink-runtime][test] Fix flaky ExecutionPartitionLifecycleTest by Mate Czagany · 35 hours ago
  8. 52f5eaa [FLINK-38812][python] Add log to show whether cython is enabled (#27458) by Liu Jiangang · 2 days ago
  9. d43d6c0 [FLINK-38983][test] Migrate the JUnit5 for TaskChangelogRegistryImplTest of flink-dstl-dfs module (#27478) by Yuepeng Pan · 2 days ago
  10. 0124ee7 [FLINK-36992][table] Migrate `SplitAggregateRule` to java by Jacky Lau · 3 days ago
  11. fd447f0 [FLINK-38890][table] Migrate `PullUpWindowTableFunctionIntoWindowAggregateRule` to java by Roman · 3 days ago
  12. ad229f9 [FLINK-38964][table] Reuse Calcite's `SqlValidatorImpl#maybeCast` by Sergey Nuyanzin · 3 days ago
  13. edbe964 [FLINK-38979][build] Enable flink-tests-java17 for jdk21 build by Sergey Nuyanzin · 3 days ago
  14. 4f530c5 [hotfix][tests] Catch `AssertionError` in `DiffRepository` instead of `AssertionFailedError` by Sergey Nuyanzin · 4 days ago
  15. 2a3d701 [FLINK-36986][table] Migrate `SplitRemoteConditionFromJoinRule` to java by Jacky Lau · 6 days ago
  16. 73993fc [FLINK-38885][table] Migrate `StreamPhysicalJoinRuleBase` and its children by Sergey Nuyanzin · 6 days ago
  17. 08648c5 [FLINK-38963][table] Altering query should be possible if `MATERIALIZED TABLE` schema contains non persisted columns by Sergey Nuyanzin · 7 days ago
  18. 721cb0a [hotfix][table] Rename vars in `CatalogViewITCase#testShowCreateViewWithTumbleWindow` by Sergey Nuyanzin · 6 days ago
  19. 4367f39 [hotfix] Use whitelisted commit SHA for rsync-deployment GHA by Martijn Visser · 6 days ago
  20. 1fd9aac [FLINK-38966][build] Update rsync for GHA to latest v8.0.2 (LTS) for legacy docs by Martijn Visser · 6 days ago
  21. ab49fae [FLINK-38799][runtime] Rename `LoadingWeight` to `TaskExecutionLoad` (#27333) by Ferenc Csaky · 7 days ago
  22. 62566c4 [FLINK-38940] Start checkpointing when all tasks are running and job is running by Roman Khachatryan · 8 days ago
  23. 2860e9a [FLINK-38960][doc] Clarify scope of state compatibility in "Upgrading" documentation by AlexYinHan · 8 days ago
  24. e3adbdc [FLINK-38777][history] HistoryServer supports application archives by Yi Zhang · 14 days ago
  25. bf9695c [FLINK-38950][table] `SqlNodeConvertUtils` should use validated query output by Sergey Nuyanzin · 7 days ago
  26. 17dda61 [FLINK-38903] Update flink-shaded to 21.0 by Mate Czagany · 8 days ago
  27. 2426faf [FLINK-38913][table] `ArrayIndexOutOfBoundsException` while unparsing `ExtendedSqlRowTypeNameSpec` by David Radley · 8 days ago
  28. 294a7c3 [hotfix] Add --omit-dir-times to legacy docs rsync to fix permission errors by Martijn Visser · 8 days ago
  29. 4452247 [hotfix] Use branch-based cache key for legacy docs workflow by Martijn Visser · 8 days ago
  30. 4f440ef [hotfix] Make it possible manually build documentation for unsupported releases by Martijn Visser · 8 days ago
  31. 679ed33 [FLINK-38925][docs] Add Matomo config to PyDocs by Martijn Visser · 9 days ago
  32. d762746 [FLINK-38955][docs] Configure canonical tag for PyDocs by Martijn Visser · 9 days ago
  33. 8226f3b [FLINK-38955][docs] Add canonical tag to generated Javadoc by Martijn Visser · 9 days ago
  34. 8f9a5a2 [FLINK-38924][docs] Actually redirect users to 404 page when trying to access non-existent page by Martijn Visser · 9 days ago
  35. bad18ae [FLINK-38778][ui] Return to application from job by Yi Zhang · 7 weeks ago
  36. 3ff5bb8 [FLINK-38778][ui] Update homepage statistics by Yi Zhang · 7 weeks ago
  37. 898b6bf [FLINK-38778][ui] Application Web UI by Yi Zhang · 8 weeks ago
  38. 175de63 [FLINK-38951][python] Bump pemja to 0.5.6 by Xuannan · 9 days ago
  39. 52f6822 [FLINK-38865][doc] Fix typos and clarify Async I/O capacity scope (#27387) by Vishal Kamlapure · 9 days ago
  40. 09da353 [FLINK-38949] Improving performance for azure unpack artifacts (#27444) by Tom Ho · 10 days ago
  41. 9e2d2b8 [FLINK-38938][table] Do not put empty operand list into compiled plan by Sergey Nuyanzin · 11 days ago
  42. 3c5c151 [hotfix][table] Show diff link in case of `DiffRepository` failure by Sergey Nuyanzin · 11 days ago
  43. 0b31cd2 [FLINK-38938][table] Restore of SQL job with `CURRENT_TIMESTAMP` fails with `CodeGenException` by Sergey Nuyanzin · 12 days ago
  44. 64f7824 [FLINK-38882][table] Introduce rules for async python scalar function by Dian Fu · 3 weeks ago
  45. 61f9ffe [FLINK-37002][table] Migrate `DecomposeGroupingSetsRule` to java by Jacky Lau · 12 days ago
  46. c8521dc [hotfix] Temporarily make it possible to build old documentation via GHA by Martijn Visser · 13 days ago
  47. 090eba5 [hotfix] Temporarily make it possible to build old documentation via GHA by Martijn Visser · 13 days ago
  48. 1047406 [FLINK-38924][docs] Redirect users to documentation home page when encountering a 404 by Martijn Visser · 2 weeks ago
  49. 380fa91 [FLINK-38922][docs] Cache Maven dependencies during documentation building by Martijn Visser · 2 weeks ago
  50. 5da177d [FLINK-38925][docs] Update Matomo URL to the right domain by Martijn Visser · 2 weeks ago
  51. a335e9f [FLINK-38923] Pass config to useInterruptibleTimers() by Roman Khachatryan · 2 weeks ago
  52. 2fe318b [FLINK-38761][runtime] Support archiving applications by Yi Zhang · 3 months ago
  53. b1831be [hotfix] Log whether interruptible timers are enabled by Roman Khachatryan · 2 weeks ago
  54. a8544c4 [FLINK-38914][docs] Add canonical tags pointing to stable docs by Martijn Visser · 2 weeks ago
  55. 07902c9 [FLINK-38914][docs] Preserve page path when linking to stable version by Martijn Visser · 4 weeks ago
  56. 4def6ef [FLINK-38530][python] Add support of Dynamic Kafka Source for PyFlink (#27409) by bowenli86 · 2 weeks ago
  57. 4980860 [hotfix][build][javadoc] Use `${target.java.version}` in javadoc plugin by Sergey Nuyanzin · 2 weeks ago
  58. 0261d49 [FLINK-38763][runtime-web] Add applicationId field for JarRunResponse by Yi Zhang · 3 weeks ago
  59. 4758c3f [FLINK-38763][runtime-web] Add REST API for JarRunApplication by Yi Zhang · 5 weeks ago
  60. b46d1bf [FLINK-36988][table] Migrate `LogicalCorrelateToJoinFromTemporalTableFunctionRule` to java by Jacky Lau · 2 weeks ago
  61. 146ea69 [FLINK-38891][table] Migrate `MiniBatchIntervalInferRule` to java by Sergey Nuyanzin · 2 weeks ago
  62. 9d067f2 [hotfix][javadoc] Use `skip-webui-build` while `javadoc:aggregate` by Sergey Nuyanzin · 2 weeks ago
  63. be9702a [hotfix] Improve test coverage of UnalignedCheckpointsInterruptibleTimersTest by Piotr Nowojski · 3 weeks ago
  64. 4d72763 [FLINK-38810] Enable splittable timers in Interval Join by Roman · 2 weeks ago
  65. a4423b1 [FLINK-38810] Pull WM processing up from KeyedCoProcessOperatorWithWatermarkDelay by Roman · 2 weeks ago
  66. eb33577 [hotfix] Set mailboxExecutor in AbstractStreamOperator constructor if available by Roman · 2 weeks ago
  67. 5e02d64 [FLINK-38542][checkpoint] Randomize UNALIGNED_ALLOW_ON_RECOVERY for testing by Rui Fan · 3 months ago
  68. 686c00f8 [FLINK-38542][checkpoint] Recover output buffers of upstream task on downstream task side directly by Rui Fan · 3 months ago
  69. cb5b955 [hotfix][checkpoint] Limit that the one buffer is only distributed to one target InputChannel by Rui Fan · 3 months ago
  70. c787fcf [hotfix][checkpoint] Refactor output buffers distribution logic via ResultSubpartitionDistributor by Rui Fan · 3 months ago
  71. 40dca97 [FLINK-38804][runtime] Ensure channelStateWriter is closed after the inputGates by Efrat Levitan · 3 weeks ago
  72. bfd13de [FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures (#27061) by Mate Czagany · 3 weeks ago
  73. 1189026 [FLINK-38884][table] Migrate IncrementalAggregateRule to java by Roman · 3 weeks ago
  74. 83ce278 [FLINK-37009][table] Migrate `PruneAggregateCallRule` to java by Jacky Lau · 3 weeks ago
  75. 6309990 [FLINK-34597][table] Migrate `SimplifyFilterConditionRule` to java by Sergey Nuyanzin · 3 weeks ago
  76. e5312c8 [hotfix] Use `source.java.version` as `maven.compiler.source` in root POM by Ferenc Csaky · 3 weeks ago
  77. 8c5735f [FLINK-38845][runtime] Add ArchivedApplicationStore to manage terminated applications by Yi Zhang · 4 weeks ago
  78. 6ffb7ed [FLINK-38189][core][python] Introduce RowFieldExtractorSchema for Row field serialization (#27353) by Nflrijal · 3 weeks ago
  79. 0ffc910 [FLINK-37902][table] Support ml_predict in batch mode (#27310) by Hao Li · 3 weeks ago
  80. fec9336 [FLINK-38762][runtime] Introduce SingleJobApplication by Yi Zhang · 3 months ago
  81. d481fb3 [hotfix][NOTICE] Update copyright NOTICE year to 2026 (#27380) by Zakelly · 3 weeks ago
  82. e02393e [FLINK-38820][table] Move ptf rule to rule folder (#27349) by Hao Li · 3 weeks ago
  83. 452479b [FLINK-38703][runtime] Update slot manager metrics in thread-safety manner by Zdenek Tison · 2 months ago
  84. 76337ad [FLINK-38856][table] Move `AnalyzeTable`, `CreateFunction`, `AlterFunction`, `DropFunction` to dedicated converters by Sergey Nuyanzin · 4 weeks ago
  85. ee484f6 [FLINK-38856][table] Move materialized table converters to `materializedtable` package by Sergey Nuyanzin · 4 weeks ago
  86. 9215bcd [FLINK-38856][table] Add support for ALTER MATERIALIZED TABLE DROP schema component by Sergey Nuyanzin · 4 weeks ago
  87. 3173d08 [FLINK-38856][table] Generalize ALTER TABLE ... DROP converters and sql objects by Sergey Nuyanzin · 4 weeks ago
  88. e93fd02 [hotfix] Move `MergeTableAsUtil` and `SchemaBuilderUtil` to `converters` package by Sergey Nuyanzin · 4 weeks ago
  89. 94c6549 [FLINK-38441][runtime] Fix ExecutionGraphCoLocationRestartTest failures (#27060) by Mate Czagany · 3 weeks ago
  90. f9b9875 [FLINK-38748][runtime] Enhance the switching logic of AdaptiveScheduler from Restarting to CreatingExecutionGraph and accelerate the transition. (#27286) by Yuepeng Pan · 3 weeks ago
  91. d97dda8 [FLINK-38225] Sets proper precondition to ensure that GCS operations are retryable (#27101) by Oleksandr Nitavskyi · 3 weeks ago
  92. b597afa [FLINK-38855] Upgrade jackson to 2.20.1 by Sergey Nuyanzin · 4 weeks ago
  93. ded9980 [FLINK-34596][table] Migrate RemoveRedundantLocalHashAggRule to java by Sergey Nuyanzin · 4 weeks ago
  94. f81d6e1 [FLINK-34895][table] Migrate FlinkRewriteSubQueryRule to java by Sergey Nuyanzin · 1 year, 11 months ago
  95. fc8b531 [FLINK-34894][table] Migrate JoinDependentConditionDerivationRule to java by Sergey Nuyanzin · 4 weeks ago
  96. 0210629 [FLINK-38717][runtime] Display the assigned task numbers for TaskManagers on the UI by Yuepeng Pan · 4 weeks ago
  97. 2c9bbeb [FLINK-38760][runtime] Add REST APIs for application query and cancellation by Yi Zhang · 6 weeks ago
  98. e287f22 [FLINK-38775][release] Generate reference data for state migration tests based on release-2.2.0 (#27317) by Hang Ruan · 4 weeks ago
  99. 4fceb46 [FLINK-38740][table] Introduce Welford's online algorithm for variance related functions to avoid catastrophic cancellation in naive algorithm by dylanhz · 5 weeks ago
  100. 4690f27 [FLINK-38759][runtime] Refactor application mode with PackagedProgramApplication by Yi Zhang · 4 months ago