Google Git
Sign in
apache/flink/HEAD
  1. aaf5dde [hotfix][ci] Do not run GHA if only azure pipelines are changed by Sergey Nuyanzin · 17 hours ago master
  2. 2d69d0c [FLINK-40230][table] `StringToBinary` and `RawToBinary` cast rules might generate runtime code with useless array copy by Sergey Nuyanzin · 23 hours ago
  3. 952fad4 [FLINK-40231][tests] Fix flaky `HistoryServerArchiveFetcherTest#testArchiveStateTransition` by Sergey Nuyanzin · 25 hours ago
  4. 9485109 [FLINK-40224][ci] Move common scripts out of tools/azure-pipelines by Dale Lane · 2 days ago
  5. e64a5d5 Revert "[FLINK-40228][ci] Bump frontend-maven-plugin to 2.0.1" by Sergey Nuyanzin · 2 days ago
  6. 1ea8cb0 [FLINK-40167][table] Add EARLY_FIRE join hint surface and option validation (#28353) by Weiqing Yang · 3 days ago
  7. f9485ff [FLINK-39770][tests][JUnit5 migration] Module: flink-state-processing-api by Purushottam Sinha · 4 days ago
  8. 4e99512 [FLINK-40228][ci] Bump frontend-maven-plugin to 2.0.1 by Sergey Nuyanzin · 4 days ago
  9. c43754c [FLINK-40217][table] Add `PARSE_JSON` and `TRY_PARSE_JSON` IT cases by Ramin Gharib · 5 days ago
  10. 96a45c1 [FLINK-40217][core] Reject non-finite numbers in `VARIANT` JSON conversion by Ramin Gharib · 6 days ago
  11. 11c6b47 [FLINK-39532][python] Fix race condition in Python AsyncScalarFunctionOperation by Liu Liu · 3 months ago
  12. 43a902a [FLINK-40166][table] SQL query parsing fails if current catalog unreachable (#28775) by Dale Lane · 5 days ago
  13. ff3aadf [FLINK-40220][Connector/JDBC] Update the branch name of JDBC connector docs. (#28804) by Yuepeng Pan · 5 days ago
  14. aef4bb3 [FLINK-40219][table] Fix outputType computation of LateralSnapshotJoin (#28803) by Fabian Hueske · 5 days ago
  15. 1a45ad8 [hotfix][docs] Remove inconsistent parameter descriptions. (#28767) by Yuepeng Pan · 6 days ago
  16. 3e348d9 [hotfix] Fix compilation with jdk11 by Ramin Gharib · 6 days ago
  17. 9c4a95c [FLINK-40020][release] Generate reference data for state migration tests based on release-2.3.0 (#28785) by David Anderson · 6 days ago
  18. c762aa5 [FLINK-40205][table] PTF are failing in case of usage multiple `PARTITION`/`ORDER BY` by Sergey Nuyanzin · 6 days ago
  19. d866030 [FLINK-40097][docs] Document archive load modes of HistoryServer by Zihao Chen · 3 weeks ago
  20. ae20292 [FLINK-40097][historyserver] Prioritize on-demand fetching for accessed jobs by Zihao Chen · 3 weeks ago
  21. db8a7f7 [FLINK-40097][historyserver] Lazily load archives to expose job overviews earlier by Zihao Chen · 3 weeks ago
  22. f16dd6e [hotfix][ci] Bump checkout action to v7 by Sergey Nuyanzin · 7 days ago
  23. 8fd8d92 [FLINK-40131][docs] Document LATERAL SNAPSHOT join (#28737) by Fabian Hueske · 7 days ago
  24. 695ccca [FLINK-40101][runtime] Emit intermediate watermarks while firing timers by Piotr Nowojski · 3 weeks ago
  25. 67a3291 [FLINK-38262][table] Add `CreateConnectionOperation` and converter by Shekhar Prasad Rajak · 7 days ago
  26. 36d42eb [hotfix][ci] Add checkout step to fix Nightly trigger CI by Ramin Gharib · 7 days ago
  27. a0605af [FLINK-40181][ci] Make spotless checking changes since last green build in ci by Sergey Nuyanzin · 7 days ago
  28. 39c823a [FLINK-40182][table] Optimize code generated by `ArrayToStringCastRule` by Sergey Nuyanzin · 9 days ago
  29. d1f08ab [FLINK-40182][table] Optimize code generated by `RawToStringCastRule` by Sergey Nuyanzin · 9 days ago
  30. 2de0eaf [FLINK-40182][table] Optimize code generated by `CharVarCharTrimPadCastRule` by Sergey Nuyanzin · 10 days ago
  31. baab138 [FLINK-40182][table] `ArrayToArrayCastRule` and `MapToMapAndMultisetToMultisetCastRule` should check for null values in runtime by Sergey Nuyanzin · 10 days ago
  32. f2370b9 [FLINK-40079][table] Reject PTF calls with sys-args if they are disabled (#28675) by Fabian Hueske · 8 days ago
  33. f5aaf91 [FLINK-40158][table-planner] Support LATERAL SNAPSHOT join in batch mode (#28763) by Fabian Hueske · 8 days ago
  34. a77d210 [FLINK-39785][table] Add LATERAL SNAPSHOT e2e and restore tests by Fabian Hueske · 3 weeks ago
  35. c6fc527 [FLINK-39785][table] Add input-driven savepoint trigger to restore test framework by Fabian Hueske · 13 days ago
  36. 34bda76 [FLINK-39785][table] Honor source.sleep-* in TestValues watermark-push-down source by Fabian Hueske · 3 weeks ago
  37. 98ab58c [FLINK-39522] Defer task finish until recovery completes by Roman Khachatryan · 4 weeks ago
  38. 2f21971 [FLINK-39522][network] Remove recovery flags and the filtering-complete future from the gate API by Rui Fan · 3 weeks ago
  39. 44c041e [FLINK-39522] Restructure StreamTask channel-state recovery into an async future chain by Roman Khachatryan · 3 weeks ago
  40. 32afcef [FLINK-40160][table] Fix casting `NaN` to `FLOAT` or `DOUBLE` by Ramin Gharib · 11 days ago
  41. 642673e [FLINK-40157][state/ForSt] Fix MapState putAll value serialization (#28762) by Zakelly · 11 days ago
  42. 4b94ae6 [hotfix][ci] Add more artifacts to skip GHA by Sergey Nuyanzin · 11 days ago
  43. a8835bd [FLINK-40093][Runtime] Resume idle splits by alignment check if previously paused by Efrat Levitan · 3 weeks ago
  44. a9ae79b [FLINK-40015] Introduce getFunctionOutput in PTF Test Harness (#28657) by Mika Naylor · 11 days ago
  45. c830df8 [FLINK-40120][table] Persist RowData field names in RowDataSerializerSnapshot (#28717) by Weiqing Yang · 11 days ago
  46. a417739 [FLINK-40153][table] Fix resolving inherited metadata columns used by watermarks in LIKE clause by lincoln lee · 11 days ago
  47. 80f0587 [FLINK-40034][runtime-web] Refresh web-dashboard lint tooling to prettier 3 and stylelint 17 (#28710) by Purushottam Sinha · 12 days ago
  48. 6027adb [FLINK-40118][runtime-web] Use REST endpoint field instead of removed host field (#28712) by Purushottam Sinha · 12 days ago
  49. 96d0bfb [FLINK-40138][tests] Drive JUnit 5 lifecycle when generating migration test snapshots (#28753) by David Anderson · 12 days ago
  50. 5004b5b [hotfix][table] Fix compilation with jdk11 by Sergey Nuyanzin · 13 days ago
  51. 76e7898 [FLINK-37925][table] Support casting from `VARIANT` to primitive types by Ramin Gharib · 13 days ago
  52. 9b60890 [FLINK-39943][table] Fix nullability of IS JSON functions (#28741) by Fabian Hueske · 13 days ago
  53. 435062c [FLINK-40088][tests] Tolerate HTTP-level responses in RestClientITCase TLS check by Martijn Visser · 3 weeks ago
  54. 3f5129b [FLINK-39784][table] Forbid SNAPSHOT outside a LATERAL context (#28674) by Fabian Hueske · 13 days ago
  55. 47abc18 [FLINK-40113][checkpoint] Reject restore when operators on a keyed vertex disagree on max parallelism by Rion Williams · 2 weeks ago
  56. 7f707f3 [FLINK-40095][table-planner] Fix JSON aggregation functions failing in group window aggregate (#28682) by Xuyang · 13 days ago
  57. edba490 [FLINK-40067][tests] Fix race in RescaleTimelineITCase.testRescaleTerminatedByJobFinished by Martijn Visser · 3 weeks ago
  58. e9540ae [FLINK-39781][table] Add LateralSnapshotJoinOperator with two-phase LOAD/JOIN execution (#28329) by Fabian Hueske · 14 days ago
  59. d769c08 [FLINK-40086][runtime] Adds error handling to newly added preCompletionAction by Matthias Pohl · 3 weeks ago
  60. d8ba8aa [FLINK-40134][ci] Bump maven-rat-plugin to 0.17 by Sergey Nuyanzin · 14 days ago
  61. c404d7b [FLINK-40036][tests] Support custom MockEnvironment in multi-input harness and state-parameterized tests (#28589) by Kaivalya Apte · 2 weeks ago
  62. 486f529 [FLINK-39783][table] Translate LATERAL SNAPSHOT to LateralSnapshotJoinOperator (#28664) by Fabian Hueske · 2 weeks ago
  63. f5bb04d [FLINK-40035][runtime-web] Add Vitest smoke tests for the web-dashboard by Purushottam Sinha · 4 weeks ago
  64. 21b47b9 [FLINK-40124][ci] Do not store cache on every run if no dependency changed by Sergey Nuyanzin · 2 weeks ago
  65. eaeefdd [FLINK-34423][ci] Make `tools/ci/compile_ci.sh` not necessarily rely on clean phase by Sergey Nuyanzin · 2 weeks ago
  66. 9d52f18 [hotfix][runtime-web] Fix savepointPath query parameter in JarService.runJob() (#28722) by Purushottam Sinha · 2 weeks ago
  67. bfad2e8 [FLINK-40125][ci] Add auto cancel for concurrently running jobs by Sergey Nuyanzin · 2 weeks ago
  68. b464b33 [FLINK-40109] Verify Kerberos keytab logs after the YARN application is killed by Martijn Visser · 3 weeks ago
  69. 1a5f868 [hotfix] Use `systemPropertyVariables` instead of `systemProperties` by Sergey Nuyanzin · 2 weeks ago
  70. c2f0c12 [FLINK-39521][network] CheckpointedInputGate: consume EndOfFetchedChannelStateEvent by Rui Fan · 3 weeks ago
  71. bf14146 [FLINK-39521][network] Propagate needsRecovery in PartitionRequest; start view reader with zero credit by Rui Fan · 3 weeks ago
  72. e480c74 [FLINK-39521][network] Convert recovered channels via the push interface; thread needsRecovery through gates by Rui Fan · 3 weeks ago
  73. 9cb272e [FLINK-39521][network] RemoteInputChannel: push-based recovery state by Rui Fan · 3 weeks ago
  74. 5a2151f [FLINK-39521][network] LocalInputChannel: push-based recovery state by Rui Fan · 3 weeks ago
  75. f615ff7 [FLINK-39521][network] Add RecoverableInputChannel contract and recovery sentinels by Rui Fan · 3 weeks ago
  76. 6265c89 [FLINK-39521][network] BufferManager: gate credit notification behind notifyInitiallyEnabled by Rui Fan · 3 weeks ago
  77. 4afea38 [FLINK-39521][test] Temporarily remove during-recovery flag from ITCase randomization by Rui Fan · 3 weeks ago
  78. 4732a521 [FLINK-40111][table-planner] Fall back to retract for a keyless sink without an upsert key by Gustavo de Morais · 3 weeks ago
  79. 8b7ebca [FLINK-40112][table-planner] Report changelog mode mismatch instead of a generic planning error by Gustavo de Morais · 3 weeks ago
  80. 913207b [FLINK-39191][runtime-web] Upgrade monaco-editor to 0.55.1 (#27745) by Gyula Komlossi · 3 weeks ago
  81. f9d81b2 [FLINK-39583][table-planner] Normalize Calcite correl variables for more effective sub-plan digest reuse (#27959) by Ferenc Csaky · 3 weeks ago
  82. 1ebd43c [FLINK-40099] Fix flaky YARNSessionFIFOSecuredITCase by verifying Kerberos keytab logs before the application is killed by Ramin Gharib · 3 weeks ago
  83. 3c1e1d9 [FLINK-40084][build] maven-shade-plugin does not respect multi release jars by Sergey Nuyanzin · 3 weeks ago
  84. 8cd1c0e [FLINK-39520][network] Additive logging overload; widen releaseAllResources visibility by Rui Fan · 3 weeks ago
  85. ed2a5d4 [FLINK-39520][network] Add InputGate#getChannel(InputChannelInfo) by Rui Fan · 3 weeks ago
  86. 0076de5 [FLINK-39520][checkpoint] Extract AbstractInputChannelRecoveredStateHandler with concrete no-filtering/filtering handlers by Rui Fan · 3 weeks ago
  87. c09a21c [FLINK-39520][network] Decouple LocalInputChannel recovery wiring from toBeConsumedBuffers by Rui Fan · 10 weeks ago
  88. 4aff729 [hotfix] Report END_OF_INPUT from multiple-input processor when all inputs finished by Roman Khachatryan · 4 weeks ago
  89. 7f770b8 [FLINK-40076][tests] Fix race in RescaleTimelineITCase.testRecordNonTerminatedRescaleMergingWithNewRecoverableFailureTriggerCause by Martijn Visser · 3 weeks ago
  90. f584601 [FLINK-40096][table] Migrate `EXPLAIN` `CTAS`/`RTAS` Explain tests to Java by Ramin Gharib · 3 weeks ago
  91. a1dcc9d [FLINK-40090][docs] Modernize cryptography export notice in distribution README (#28677) by Martijn Visser · 3 weeks ago
  92. 3e3e270 [FLINK-39923][state] Fix RocksDB Statistics native memory leak (#28489) by Keith Lee · 3 weeks ago
  93. ba41c1f [FLINK-40039][table] Fix `CTAS`/`RTAS` when used with set-semantic PTFs by Ramin Gharib · 3 weeks ago
  94. eafba3b [FLINK-36334][tests] Enable TraversableSerializerUpgradeTest by Stepan Stepanishchev · 3 weeks ago
  95. 20216e4 [FLINK-39715][table] Sync SQL and table api behavior for queries with sort by Sergey Nuyanzin · 3 weeks ago
  96. 0b16dd3 [FLINK-40032][runtime-web] Migrate web-dashboard eslint to v9 (flat config) by Purushottam Sinha · 4 weeks ago
  97. 6bdaa5e [FLINK-40045][runtime-web] Upgrade d3-flame-graph to v5 (#28601) by Purushottam Sinha · 3 weeks ago
  98. 2c0bf24 [FLINK-40082][table] Watermark generated method `extractTimestamp` might invoke code throwing exceptions by Sergey Nuyanzin · 3 weeks ago
  99. a6f1f40 [FLINK-32695][e2e] Migrate SqlToolbox watermark push-down source to Source V2 by Martijn Visser · 4 weeks ago
  100. a053de2 [FLINK-40068][tests] Do not assert apply() was called when cancelling KeyedJob window by Martijn Visser · 3 weeks ago