Google Git
Sign in
apache/flink/HEAD
  1. 360aa97 [FLINK-39248][runtime] Fix RowDataKeySerializerSnapshot restore by Roman Khachatryan · 2 days ago master
  2. 5bf3509 [FLINK-39015][table] Fix key extractor for multi join by changing GenericRowData to BinaryRowData by Dmitriy Linevich · 2 days ago
  3. ce477c3 [FLINK-39081] Add ARTIFACT keyword option in CREATE FUNCTION's USING clause by Mika Naylor · 4 weeks ago
  4. 181d522 [FLINK-39162][checkpoints] Disable UC for CustomPartitioner by Roman Khachatryan · 10 days ago
  5. f71c6a1 [hotfix][table-planner] Fix comments in DeltaJoinTest by xuyang · 2 weeks ago
  6. d05555f [FLINK-39175][table-planner] Allow calc that contains non-deterministic func to consume duplicate changes by xuyang · 2 weeks ago
  7. e6d7a33 [FLINK-39178][table-planner] Support cascaded delta join in planner (#27734) by Xuyang · 2 days ago
  8. 74a3243 [FLINK-39242][python] Fix error when getting columns from ResolvedSchema by Mika Naylor · 3 days ago
  9. 221777c [hotfix] Fix incorrect JavaDoc for session window assigners by MUKUL GUPTA · 2 weeks ago
  10. 8833af4 [FLINK-38857][Model] Add docs for Triton inference model (#27490) by Feat Zhang · 5 days ago
  11. abf53fb [FLINK-39221][table] Add AGGREGATE_VALUES rule for constant folding of global aggregates by Fabian Paul · 8 days ago
  12. 5af78e2 [FLINK-39173][runtime] Support application-level blob storage by Yi Zhang · 14 days ago
  13. dfd785c [FLINK-38974][runtime] Handle jobs in running applications during HA recovery by Yi Zhang · 2 weeks ago
  14. 6133aec [hotfix][runtime] Associate job with application after successful JobManagerRunner creation by Yi Zhang · 9 days ago
  15. 01a8489 [hotfix][runtime] Fix statusListeners NPE after application deserialization by Yi Zhang · 9 days ago
  16. ba95b2e [FLINK-38981][table] Migrate BatchPhysicalSortMergeJoinRule to java by Jacky Lau · 8 days ago
  17. 7204c8f [FLINK-39077][table] Throw for materialized table change query operation in case of non persisted columns in schema by Sergey Nuyanzin · 8 days ago
  18. e4d4996 [FLINK-17224][table] Support precision of `TIME` type by Ramin Gharib · 6 months ago
  19. 3fb0d04 [FLINK-39182][runtime/test] Fix the flaky test class ExecutionGraphRestartTest by Yuepeng Pan · 13 days ago
  20. d70714c [FLINK-39199][table] `CREATE OR ALTER MATERIALIZED TABLE` doesn't support table options changes by Sergey Nuyanzin · 9 days ago
  21. 919f644 [FLINK-39150][runtime] Fix join operator crashes jobs when using custom types or custom type serializers by noorall · 2 weeks ago
  22. 6cfeb2e [FLINK-38832][table-planner] Push down single column when using count star (#27681) by Xuyang · 9 days ago
  23. c0479c7 [FLINK-39201] Add test coverage for null values and error constraint by Fabian Paul · 10 days ago
  24. ebaa7b8 [hotfix][runtime] Including task name and subtask index into channel-state-unspilling thread name by Rui Fan · 8 weeks ago
  25. 02e3618 [FLINK-39140][test] Change record type from Long to String in UnalignedCheckpointRescaleWithMixedExchangesITCase by Rui Fan · 11 days ago
  26. 17581be [FLINK-39140][test] Fix MAX_RETAINED_CHECKPOINTS not effective in UnalignedCheckpointRescaleWithMixedExchangesITCase by Rui Fan · 12 days ago
  27. abfc301 [FLINK-39140][test] Allow multiple rescales in Unaligned Checkpoint ITCases to perform checkpointing during recovery by Rui Fan · 2 weeks ago
  28. ffd01f7 [FLINK-39140][test] Disable CUSTOM_PARTITIONER in unaligned checkpoint it case since it does not work well by Rui Fan · 2 weeks ago
  29. 6278f7a [hotfix][runtime] Guard DEBUG log calls with isDebugEnabled in ZooKeeperLeaderRetrievalDriver by Martijn Visser · 11 days ago
  30. 916faa8 [FLINK-39181][ci] Scope shade plugin DEBUG logging to compile step by Martijn Visser · 13 days ago
  31. b6e7219 [hotfix][ci] Disable DEBUG logging for ZooKeeper and leader election in tests by Martijn Visser · 13 days ago
  32. 9da7811 [FLINK-39201] Skip null values during length enforcement by Fabian Paul · 11 days ago
  33. 3155daa [FLINK-38263][table] Add SecretStore related interfaces by Hao Li · 11 days ago
  34. 4e088de [FLINK-38866][flink-table-planner] Passing timestamp precision to window operators to respect BinaryRowData non-compact timestamp form by Matt Cuento · 11 days ago
  35. 2839042 [FLINK-38897][Runtime/REST] Introduce the /jobs/:jobid/rescales/config endpoint in the REST API (#27580) by Yuepeng Pan · 11 days ago
  36. 4cbe364 [FLINK-27661][Runtime / Metrics] PrometheusPushGatewayReporter support pushgateway http authentication (#27576) by Liu Jiangang · 11 days ago
  37. 4f85d30 [FLINK-38971][table] Migrate ExpandWindowTableFunctionTransposeRule to java by Roman · 11 days ago
  38. 861845a [FLINK-39157][table-common] Add ColumnList.hashCode()/equals() by Timo Walther · 12 days ago
  39. 9f20f1d [FLINK-39180][tests] Fix flaky RestClientTest.testRestClientClosedHandling by Martijn Visser · 14 days ago
  40. 5cb890d [FLINK-34644][runtime] Fix race condition in RestServerEndpoint shutdown (#27708) by Martijn Visser · 14 days ago
  41. 89e8412 [FLINK-39041][docs] Rebuild REST API docs pages to supplement the missing content. by Yuepeng Pan · 2 weeks ago
  42. 9b7c95c [FLINK-38977][ui] Expose exceptions for applications by Yi Zhang · 3 months ago
  43. e56d433 [FLINK-38977][runtime] Expose exceptions for applications by Yi Zhang · 3 weeks ago
  44. 3cf73f3 [FLINK-39164][history] Fix HistoryServerTest by adding delay to avoid identical archive timestamps by Yi Zhang · 2 weeks ago
  45. 26a0012 [FLINK-38892][runtime/rest] Introduce the scheduler and type information of the target job in the JobDetails(Info).java (#27544) by Yuepeng Pan · 2 weeks ago
  46. f6fffd7 [hotfix][runtime] Log watermark alignment duration (and all other stages) by Roman Khachatryan · 1 year, 1 month ago
  47. 4ade9f8 [FLINK-39167][runtime] Initialize source output before emitting final watermark by Roman Khachatryan · 1 year, 4 months ago
  48. 4e383d6 [FLINK-39134][test] Fix UnalignedCheckpointFailureHandlingITCase by Roman Khachatryan · 2 weeks ago
  49. 0f589a5 [FLINK-38613][tests] Force number of splits in UnalignedCheckpointRescaleWithMixedExchangesITCase by Roman Khachatryan · 3 weeks ago
  50. 2eea63f [FLINK-39158][runtime/test] Minor polish for RestAPIStabilityTestUtils to reduce redundant lines by Yuepeng Pan · 2 weeks ago
  51. 26cecfc [FLINK-39022][security] Set security.ssl.algorithms default value to modern cipher suite by balassai · 2 weeks ago
  52. 97dd9f6 [FLINK-38585][python] Fix python env set in Pyflink's thread mode when using shipped venv.zip archive by Biao Geng · 2 weeks ago
  53. 657f418 [FLINK-39155] Validate watermarks are available when using ON CONFLICT DO ERROR/NOTHING (#27687) by Dawid Wysakowicz · 2 weeks ago
  54. 4fb1308 [FLINK-39161][table] Port fix for `INTERVAL ... WEEK, QUARTER` from Calcite by Sergey Nuyanzin · 2 weeks ago
  55. 3ecbbd1 [FLINK-38928] Implement an operator for handling DO ERROR/NOTHING (#27502) (#27602) by Dawid Wysakowicz · 2 weeks ago
  56. 197c7b9 [FLINK-38973][runtime] Make jobId nullable in StreamGraph to maintain compatibility for fixed jobId by Yi Zhang · 4 weeks ago
  57. 5dbadfd [FLINK-38973][runtime] Job ID assignment and matching based on name by Yi Zhang · 7 weeks ago
  58. 67f0ceb [FLINK-38340][runtime] Introduce the rescale timeline related abstraction for performing rescale operations (#27285) by Yuepeng Pan · 2 weeks ago
  59. 9964ab4 [FLINK-39130][metrics] Allow native types in MetricConfig by Aleksandr Iushmanov · 3 weeks ago
  60. 3a13f8d [FLINK-38978][runtime] Expose JM config for applications by Yi Zhang · 3 weeks ago
  61. c0f2273 [FLINK-39133][runtime] Fix DispatcherTest to properly handle async operations for applications by Yi Zhang · 3 weeks ago
  62. dc10fa5 [FLINK-39041][docs] Rebuild REST API docs pages to supplement the missing content. by Yuepeng Pan · 5 weeks ago
  63. 5440238 [FLINK-38916][table-planner] MultiJoin produces incorrect results for OR join conditions when parallelism is greater than 1 by Stepan Stepanishchev · 3 weeks ago
  64. db3777d [FLINK-39107][metrics][test] Run otel container from a prebuilt image (#27637) by Efrat Levitan · 3 weeks ago
  65. 4d88ecf [FLINK-39084][core] variant accessor methods for handling map or array types in converters by Swapna Marru · 3 weeks ago
  66. 73fe043 [FLINK-38807][state] Add state SQL metadata based type inference by Gabor Somogyi · 3 weeks ago
  67. 8ff299d [hotfix][test] Use `assertThatExceptionOfType` instead of `assertThatThrownBy` in OverAggregateTest.scala by Sergey Nuyanzin · 3 weeks ago
  68. 35d1d8a [FLINK-38624][table] Convert FlinkLogicalOverAggregate to java by Sergey Nuyanzin · 3 weeks ago
  69. 421ec89 [FLINK-38624][table] Replace deprecated `RexBuilder#makeAbstractCast` by Sergey Nuyanzin · 3 weeks ago
  70. a5223c4 [FLINK-38624][table] Type Mismatch Exception in StreamPhysicalOverAggregateRule by Sergey Nuyanzin · 3 weeks ago
  71. de569e4 [FLINK-39088][table] Support injective casts from CHAR/VARCHAR to BINARY/VARBINARY by Gustavo de Morais · 3 weeks ago
  72. 7536cfe [FLINK-39073][runtime] Test split state timers during deferred alignment check by Efrat Levitan · 3 weeks ago
  73. 48d15cf [FLINK-39073][runtime] Improve logging of invalid split transitions by Efrat Levitan · 3 weeks ago
  74. e6de2f6 [FLINK-39073][runtime] Defer alignment check for idle splits by Efrat Levitan · 3 weeks ago
  75. e9afe8b [FLINK-38764] Update lz4-java to 1.10.3 (#27535) by Cameron · 3 weeks ago
  76. fdc2686 [FLINK-39105][rest] Fix RestClientTest.testConnectionTimeout to handle environment-dependent exception types by Martijn Visser · 3 weeks ago
  77. 45c62ca [FLINK-39103][runtime] Tolerate deserializer release failure if the corresponding channel already had errors by Roman Khachatryan · 4 weeks ago
  78. b5fbf2b [hotfix][runtime] Release all channels' deserializers before failing in StreamTaskNetworkInput by Roman Khachatryan · 4 weeks ago
  79. b1192e8 [FLINK-39029] move catalog store factory builder to new class (#27531) by Hao Li · 3 weeks ago
  80. e5eeb6c [FLINK-38523] Upgrade Pekko to 1.4.0 by Mate Czagany · 3 weeks ago
  81. 3832967 [FLINK-39088][table] Fix upsert key preservation by introducing injective cast checks for CAST by Gustavo de Morais · 3 weeks ago
  82. 8413461 [FLINK-38953] Cleanup configurations for SSL hostname verification by Mate Czagany · 3 weeks ago
  83. 825400b [hotfix] Fix formatting by Piotr Nowojski · 4 weeks ago
  84. 68aca15 [FLINK-37399][docs] Regenerate docs by Piotr Nowojski · 11 months ago
  85. 774fd07 [FLINK-37399][tests] Randomize watermark alignment buffer size in ITCases by Piotr Nowojski · 11 months ago
  86. bda5c7c [FLINK-37399][runtime][source] Buffer watermarks for watermark alignment by Piotr Nowojski · 12 months ago
  87. e03da5e [FLINK-37399][runtime] Add SamplingWatermarkRingBuffer by Piotr Nowojski · 11 months ago
  88. f4d8e4b [hotfix][tests] Create Builder for SourceOperatorTestContext by Piotr Nowojski · 11 months ago
  89. 476e27a [hotfix][tests] Refactor SourceOperatorSplitWatermarkAlignmentTest by Piotr Nowojski · 11 months ago
  90. deadc21 [hotfix][tests] Extract updateIntervalMillis in SourceOperatorAlignmentTest by Piotr Nowojski · 11 months ago
  91. fe06d66 hotfix][docs] Fix uv PATH for Chinese docs build in CI by Martijn Visser · 3 weeks ago
  92. f597bef [hotfix][docs] Add uv to PATH for Chinese docs build in CI by Martijn Visser · 3 weeks ago
  93. 1a45d0b [hotfix][docs] Remove manual venv activation from docs.sh by Martijn Visser · 3 weeks ago
  94. ae0c1e6 [hotfix][tests] De-duplicate operator IDs in RestoreUpgradedJobITCase by Roman Khachatryan · 4 weeks ago
  95. c06640f [hotfix][tests] Increase min pause between checkpoints in migration tests by Roman · 7 weeks ago
  96. 1175aa9 [FLINK-38939] Minimize checkpoint trigger delay if sources are waiting for a checkpoint by Roman Khachatryan · 8 weeks ago
  97. b2b044d [hotfix][runtime] Move checkpointing configuration code to CheckpointCoordinatorConfiguration by Roman Khachatryan · 11 months ago
  98. c0ada39 [hotfix][runtime] Try to get last checkpoint on recovery regardless of checkpointing interval by Roman · 7 weeks ago
  99. 7c90b9e [FLINK-38939][runtime] Pause Sources until the first checkpoint barrier is received by Roman Khachatryan · 8 weeks ago
  100. 259a6a7 [hotfix][tests] Close OutputWriter in SourceOperatorStreamTaskTest by Roman Khachatryan · 8 weeks ago