Google Git
Sign in
apache / flink / HEAD
  1. 9e2d2b8 [FLINK-38938][table] Do not put empty operand list into compiled plan by Sergey Nuyanzin · 19 hours ago master
  2. 3c5c151 [hotfix][table] Show diff link in case of `DiffRepository` failure by Sergey Nuyanzin · 19 hours ago
  3. 0b31cd2 [FLINK-38938][table] Restore of SQL job with `CURRENT_TIMESTAMP` fails with `CodeGenException` by Sergey Nuyanzin · 2 days ago
  4. 64f7824 [FLINK-38882][table] Introduce rules for async python scalar function by Dian Fu · 11 days ago
  5. 61f9ffe [FLINK-37002][table] Migrate `DecomposeGroupingSetsRule` to java by Jacky Lau · 2 days ago
  6. c8521dc [hotfix] Temporarily make it possible to build old documentation via GHA by Martijn Visser · 3 days ago
  7. 090eba5 [hotfix] Temporarily make it possible to build old documentation via GHA by Martijn Visser · 3 days ago
  8. 1047406 [FLINK-38924][docs] Redirect users to documentation home page when encountering a 404 by Martijn Visser · 5 days ago
  9. 380fa91 [FLINK-38922][docs] Cache Maven dependencies during documentation building by Martijn Visser · 5 days ago
  10. 5da177d [FLINK-38925][docs] Update Matomo URL to the right domain by Martijn Visser · 5 days ago
  11. a335e9f [FLINK-38923] Pass config to useInterruptibleTimers() by Roman Khachatryan · 5 days ago
  12. 2fe318b [FLINK-38761][runtime] Support archiving applications by Yi Zhang · 3 months ago
  13. b1831be [hotfix] Log whether interruptible timers are enabled by Roman Khachatryan · 7 days ago
  14. a8544c4 [FLINK-38914][docs] Add canonical tags pointing to stable docs by Martijn Visser · 6 days ago
  15. 07902c9 [FLINK-38914][docs] Preserve page path when linking to stable version by Martijn Visser · 3 weeks ago
  16. 4def6ef [FLINK-38530][python] Add support of Dynamic Kafka Source for PyFlink (#27409) by bowenli86 · 5 days ago
  17. 4980860 [hotfix][build][javadoc] Use `${target.java.version}` in javadoc plugin by Sergey Nuyanzin · 5 days ago
  18. 0261d49 [FLINK-38763][runtime-web] Add applicationId field for JarRunResponse by Yi Zhang · 8 days ago
  19. 4758c3f [FLINK-38763][runtime-web] Add REST API for JarRunApplication by Yi Zhang · 4 weeks ago
  20. b46d1bf [FLINK-36988][table] Migrate `LogicalCorrelateToJoinFromTemporalTableFunctionRule` to java by Jacky Lau · 6 days ago
  21. 146ea69 [FLINK-38891][table] Migrate `MiniBatchIntervalInferRule` to java by Sergey Nuyanzin · 6 days ago
  22. 9d067f2 [hotfix][javadoc] Use `skip-webui-build` while `javadoc:aggregate` by Sergey Nuyanzin · 6 days ago
  23. be9702a [hotfix] Improve test coverage of UnalignedCheckpointsInterruptibleTimersTest by Piotr Nowojski · 12 days ago
  24. 4d72763 [FLINK-38810] Enable splittable timers in Interval Join by Roman · 7 days ago
  25. a4423b1 [FLINK-38810] Pull WM processing up from KeyedCoProcessOperatorWithWatermarkDelay by Roman · 7 days ago
  26. eb33577 [hotfix] Set mailboxExecutor in AbstractStreamOperator constructor if available by Roman · 7 days ago
  27. 5e02d64 [FLINK-38542][checkpoint] Randomize UNALIGNED_ALLOW_ON_RECOVERY for testing by Rui Fan · 3 months ago
  28. 686c00f8 [FLINK-38542][checkpoint] Recover output buffers of upstream task on downstream task side directly by Rui Fan · 3 months ago
  29. cb5b955 [hotfix][checkpoint] Limit that the one buffer is only distributed to one target InputChannel by Rui Fan · 10 weeks ago
  30. c787fcf [hotfix][checkpoint] Refactor output buffers distribution logic via ResultSubpartitionDistributor by Rui Fan · 3 months ago
  31. 40dca97 [FLINK-38804][runtime] Ensure channelStateWriter is closed after the inputGates by Efrat Levitan · 9 days ago
  32. bfd13de [FLINK-38406][runtime] Fix DefaultSchedulerCheckpointCoordinatorTest failures (#27061) by Mate Czagany · 8 days ago
  33. 1189026 [FLINK-38884][table] Migrate IncrementalAggregateRule to java by Roman · 9 days ago
  34. 83ce278 [FLINK-37009][table] Migrate `PruneAggregateCallRule` to java by Jacky Lau · 10 days ago
  35. 6309990 [FLINK-34597][table] Migrate `SimplifyFilterConditionRule` to java by Sergey Nuyanzin · 10 days ago
  36. e5312c8 [hotfix] Use `source.java.version` as `maven.compiler.source` in root POM by Ferenc Csaky · 11 days ago
  37. 8c5735f [FLINK-38845][runtime] Add ArchivedApplicationStore to manage terminated applications by Yi Zhang · 2 weeks ago
  38. 6ffb7ed [FLINK-38189][core][python] Introduce RowFieldExtractorSchema for Row field serialization (#27353) by Nflrijal · 11 days ago
  39. 0ffc910 [FLINK-37902][table] Support ml_predict in batch mode (#27310) by Hao Li · 11 days ago
  40. fec9336 [FLINK-38762][runtime] Introduce SingleJobApplication by Yi Zhang · 3 months ago
  41. d481fb3 [hotfix][NOTICE] Update copyright NOTICE year to 2026 (#27380) by Zakelly · 14 days ago
  42. e02393e [FLINK-38820][table] Move ptf rule to rule folder (#27349) by Hao Li · 14 days ago
  43. 452479b [FLINK-38703][runtime] Update slot manager metrics in thread-safety manner by Zdenek Tison · 9 weeks ago
  44. 76337ad [FLINK-38856][table] Move `AnalyzeTable`, `CreateFunction`, `AlterFunction`, `DropFunction` to dedicated converters by Sergey Nuyanzin · 2 weeks ago
  45. ee484f6 [FLINK-38856][table] Move materialized table converters to `materializedtable` package by Sergey Nuyanzin · 2 weeks ago
  46. 9215bcd [FLINK-38856][table] Add support for ALTER MATERIALIZED TABLE DROP schema component by Sergey Nuyanzin · 3 weeks ago
  47. 3173d08 [FLINK-38856][table] Generalize ALTER TABLE ... DROP converters and sql objects by Sergey Nuyanzin · 2 weeks ago
  48. e93fd02 [hotfix] Move `MergeTableAsUtil` and `SchemaBuilderUtil` to `converters` package by Sergey Nuyanzin · 2 weeks ago
  49. 94c6549 [FLINK-38441][runtime] Fix ExecutionGraphCoLocationRestartTest failures (#27060) by Mate Czagany · 14 days ago
  50. f9b9875 [FLINK-38748][runtime] Enhance the switching logic of AdaptiveScheduler from Restarting to CreatingExecutionGraph and accelerate the transition. (#27286) by Yuepeng Pan · 14 days ago
  51. d97dda8 [FLINK-38225] Sets proper precondition to ensure that GCS operations are retryable (#27101) by Oleksandr Nitavskyi · 2 weeks ago
  52. b597afa [FLINK-38855] Upgrade jackson to 2.20.1 by Sergey Nuyanzin · 2 weeks ago
  53. ded9980 [FLINK-34596][table] Migrate RemoveRedundantLocalHashAggRule to java by Sergey Nuyanzin · 3 weeks ago
  54. f81d6e1 [FLINK-34895][table] Migrate FlinkRewriteSubQueryRule to java by Sergey Nuyanzin · 1 year, 10 months ago
  55. fc8b531 [FLINK-34894][table] Migrate JoinDependentConditionDerivationRule to java by Sergey Nuyanzin · 3 weeks ago
  56. 0210629 [FLINK-38717][runtime] Display the assigned task numbers for TaskManagers on the UI by Yuepeng Pan · 3 weeks ago
  57. 2c9bbeb [FLINK-38760][runtime] Add REST APIs for application query and cancellation by Yi Zhang · 5 weeks ago
  58. e287f22 [FLINK-38775][release] Generate reference data for state migration tests based on release-2.2.0 (#27317) by Hang Ruan · 3 weeks ago
  59. 4fceb46 [FLINK-38740][table] Introduce Welford's online algorithm for variance related functions to avoid catastrophic cancellation in naive algorithm by dylanhz · 3 weeks ago
  60. 4690f27 [FLINK-38759][runtime] Refactor application mode with PackagedProgramApplication by Yi Zhang · 4 months ago
  61. ffad337 [hotfix][runtime] Minor polish for the parameter naming of ExecutionGraphWithVertexParallelism#create. (#27272) by Yuepeng Pan · 4 weeks ago
  62. e3456e3 [FLINK-38824][table] Fix incorrect default values for primitive types by dylanhz · 4 weeks ago
  63. 617244f [FLINK-38738][table] Expose more context in table connectors to correct UID by Timo Walther · 4 weeks ago
  64. 4cb44c0 [FLINK-38758][runtime] Introduce PackagedProgramApplication by Yi Zhang · 4 months ago
  65. 556dd6f [FLINK-38758][runtime] Use JobStatus instead of ApplicationStatus in JobResult by Yi Zhang · 5 weeks ago
  66. 883e33b [hotfix][table] Fix incorrect error message of `RootArgumentTypeStrategy` by dylanhz · 5 weeks ago
  67. b289496 [FLINK-38811][docs] Translate async function doc to Chinese (#27346) by Hao Li · 5 weeks ago
  68. 2260c11 [FLINK-38802][table] DDL with duplicated keys in table options should not fail by Sergey Nuyanzin · 5 weeks ago
  69. 5954b5b [FLINK-38757][runtime] Introduce the base class for application by Yi Zhang · 4 months ago
  70. 9d2daa8 [FLINK-38776][table] Fix incorrect auxiliary group field names by dylanhz · 5 weeks ago
  71. 457b3de [FLINK-38791][table] Add support for `ALTER MATERIALIZED TABLE MODIFY` by Sergey Nuyanzin · 5 weeks ago
  72. c028790 [hotfix] Pull legacyUidsEnabled as an abstract method to CommonExecTableSourceScan by Dawid Wysakowicz · 6 weeks ago
  73. bfcf13b [FLINK-38765] Fix persisted metadata handling in sink by Dawid Wysakowicz · 7 weeks ago
  74. a56134d [FLINK-38797][python] Fixed CsvSchemaBuilder.set_null_value to return self by Wren Chan · 6 weeks ago
  75. 7ba9741 [FLINK-38754][runtime] Avoid reverse DNS lookups when connecting to BlobServer by Yi Zhang · 7 weeks ago
  76. d720618 [FLINK-38796][table] `UnresolvedMetadataColumn` misses type during serializing to string by Sergey Nuyanzin · 6 weeks ago
  77. a8bbcdc [hotfix][release] Update japicmp configuration for 2.2.0 (#27312) by Hang Ruan · 6 weeks ago
  78. f79e63e [FLINK-38771][table] Allow scalar args for multi-table PTFs by Timo Walther · 6 weeks ago
  79. 4072808 [FLINK-38772][table] `CliClientITCase` is broken in IDE by Sergey Nuyanzin · 7 weeks ago
  80. 11f61d2 [FLINK-38766][table] Migrate `TableEnvironmentTest` to assertJ by Sergey Nuyanzin · 7 weeks ago
  81. fc85065 [FLINK-38766][table] Add support for `ALTER MATERIALIZED TABLE ADD` support by Sergey Nuyanzin · 8 weeks ago
  82. c4d6344 [FLINK-38403][tests] Fix the unexpected test that the second job does not restore from checkpoint (#27254) by Rui Fan · 7 weeks ago
  83. b61de59 [FLINK-38773][table] Fix batch vector search excnode context (#27311) by Hao Li · 7 weeks ago
  84. 089af1f [hotfix][release] Build 2.2 docs in GitHub Action and mark 2.2 as stable in docs (#27315) by Hang Ruan · 7 weeks ago
  85. 4d94a9b [FLINK-38661][docs] Add 2.2.0 release note (#27235) by Hang Ruan · 7 weeks ago
  86. 7cf2f5c [FLINK-38767][table] Fix vector search execnode transform name (#27304) by Hao Li · 7 weeks ago
  87. 644f461 [FLINK-38746][table-runtime] Fix StackOverflowError in RecordsWindowBuffer.addElement by Rui Fan · 8 weeks ago
  88. be6e7c5 [hotfix] WindowBuffer implements AutoCloseable to avoid declare close explicitly by Rui Fan · 8 weeks ago
  89. a451e39 [FLINK-38738][table] Fix UIDs for ScanTableSource with multiple transformations by Timo Walther · 7 weeks ago
  90. c3ea9c2 [FLINK-38747][core] Update the annotation of RateLimiter and RateLimiterStrategy interface from @Experimental to @PublicEvolving. (#27283) by Kunni · 7 weeks ago
  91. 4b7210d [FLINK-38768][table] Materialized table fails with validation exception in case of `LATERAL TABLE` by Sergey Nuyanzin · 7 weeks ago
  92. b0b6669 [FLINK-37813][runtime] Pass numberSlots via WorkerRegistration instead of SlotReport (#27100) by Weihua Hu · 7 weeks ago
  93. e46a212 [FLINK-38084][doc] Add download doc for model providers (#27296) by Hao Li · 7 weeks ago
  94. d0ab038 [FLINK-38752][table] Drop `EquivalentExprShuttle` by Sergey Nuyanzin · 7 weeks ago
  95. 23f2e39 [hotfix][docs] Use stable Fluss doc link to avoid broken link once Fluss community version bump by Leonard Xu · 7 weeks ago
  96. 321b17f [FLINK-38260][table] Add parser changes for connection sql by Hao Li · 7 weeks ago
  97. 4c7aca0 [FLINK-38750][table] Validation of queries with functions erroneously invoked under `SELECT` fails with `StackOverflow` by Sergey Nuyanzin · 7 weeks ago
  98. 512fdb2 [FLINK-38756][table] Group and reorder converters in registration logica by Sergey Nuyanzin · 7 weeks ago
  99. 77b9107 [FLINK-38756][table] Add support for ALTER MATERIALIZED TABLE ADD columns in parser by Sergey Nuyanzin · 7 weeks ago
  100. 9bc742d [hotfix][table] Rename `SqlAlterDistribution` to `SqlAlterTableDistribution` and `SqlAlterMaterializedTableAddDistribution` to `SqlAlterMaterializedTableDistribution` by Sergey Nuyanzin · 7 weeks ago