Google Git
Sign in
apache / flink / HEAD
  1. bb0f442 [FLINK-35158][runtime] Error handling in StateFuture's callback by fredia · 2 weeks ago master
  2. 1c34ca0 [FLINK-35306][test] Migrate flink-tests-java17 module to JUnit5 and assertj to solve jdk17 compile fails by Rui Fan · 10 hours ago
  3. be03be9 [FLINK-35048][state] Support AsyncKeyedStateBackend for ForStKeyedStateBackend by Hangxiang Yu · 9 days ago
  4. 3e68422 [FLINK-35262][state] Bridge between AsyncKeyedStateBackend and AsyncExecutionController by Hangxiang Yu · 9 days ago
  5. 29736b8 [FLINK-35195][table] Support execute CreateMaterializedTableOperation for continuous refresh mode in SqlGateway by fengli · 2 days ago
  6. e0d342a [FLINK-35195][table] Introduce DropMaterializedTableOperation to support drop materialized table by fengli · 2 days ago
  7. 192e1e8 [FLINK-35195][table] Introduce MaterializedTableChange to support update materialized table refresh status and RefreshHandler by fengli · 2 days ago
  8. c99eb54 [FLINK-35195][table] Introduce ContinuousRefreshHandler and serializer for continuous refresh mode by fengli · 2 days ago
  9. e28e495 [FLINK-35195][table] Convert SqlCreateMaterializedTable node to CreateMaterializedTableOperation by fengli · 2 days ago
  10. d8491c0 [FLINK-35195][table] Convert CatalogMaterializedTable to CatalogTable to generate execution plan for planner by fengli · 2 days ago
  11. b037f56 [FLINK-35195][table] Introduce materialized table reflated config options by fengli · 2 days ago
  12. 84f0632 [FLINK-35195][test/test-filesystem] test-filesystem Catalog support create generic table by fengli · 8 days ago
  13. ea4112a [FLINK-35161][state] Implement StateExecutor for ForStStateBackend by Jinzhong Li · 9 days ago
  14. 88f6d06 [FLINK-35161][state] Refactor ForStGeneralMultiGetOperation and ForStWriteBatchOperation by Jinzhong Li · 9 days ago
  15. ffa3869 [FLINK-25537] [JUnit5 Migration] Migrate the api package of flink-core module to JUnit5 by gongzhongqiang · 29 hours ago
  16. afe4c79 [FLINK-32080][FLIP-306][checkpoint] Restoration of FileMergingSnapshotManager by Jinzhong Li · 8 weeks ago
  17. ca441b8 [FLINK-32852][JUnit5 Migration] Migrate the scheduler package of flink-runtime module to JUnit5 (#24732) by Yuepeng Pan · 2 days ago
  18. 1904b21 [FLINK-35155] Introduce TableRuntimeException (#24679) by Dawid Wysakowicz · 2 days ago
  19. beb0b16 [FLINK-32843][JUnit5 Migration] Migrate the jobmaster package of flink-runtime module to JUnit5 by Yuepeng Pan · 3 days ago
  20. 80af4d5 [FLINK-35217] Add missing fsync to #closeForCommit in some subclasses of RecoverableFsDataOutputStream. (#24722) by Stefan Richter · 8 days ago
  21. 8a75f8f [FLINK-34902][table] Fix IndexOutOfBoundsException for VALUES by Jeyhun Karimov · 8 days ago
  22. 44528e0 [FLINK-35194][table] Support describe job statement for SqlGateway by xuyang · 12 days ago
  23. f543cc5 [FLINK-35184][table-runtime] Fix mini-batch join hash collision when use InputSideHasNoUniqueKeyBundle by Roman Boyko · 2 weeks ago
  24. 330f524 [FLINK-35191][table-api] Support alter materialized table related syntax: suspend, resume, refresh, set and reset by Feng Jin · 9 days ago
  25. 86de622 [FLINK-35224][web] Show the JobType on Flink WebUI by Rui Fan · 2 weeks ago
  26. 917352e [FLINK-35223][rest] Add jobType in JobDetailsInfo related rest api by Rui Fan · 2 weeks ago
  27. 5263f9c [FLINK-35222][rest] Add getJobType for AccessExecutionGraph by Rui Fan · 2 weeks ago
  28. f75c518 [hotfix][docs] Fix file reference by caicancai · 11 days ago
  29. 5e924d7 [hotfix][docs] Fix typo in checkpoints documentation by cancaicai · 9 days ago
  30. cca14d4 [FLINK-34379][table] Fix OutOfMemoryError with large queries by Jeyhun Karimov · 5 weeks ago
  31. b1544e4 [FLINK-32622][table-planner] Optimize mini-batch assignment (#23470) by Jeyhun Karimov · 9 days ago
  32. e412402 [FLINK-34915][table] Support `DESCRIBE CATALOG` syntax by Yubin Li · 10 days ago
  33. 0f01a0e [FLINK-35208][python] Respect pipeline.cached-files during handling Python dependencies by Dian Fu · 14 days ago
  34. 4e6dbe2 [FLINK-35246][test] Fix incorrect address construction in SqlClientSSLTest by Weijie Guo · 12 days ago
  35. 3ff2ba4 [FLINK-35026][runtime] Implement buffer timeout of AEC by fredia · 2 weeks ago
  36. 713c30f [FLINK-35026][runtime][config] Introduce async execution configurations by fredia · 4 weeks ago
  37. 714d1cb [FLINK-35189][test-utils] Introduce test-filesystem connector and catalog based on filesystem to support materialized table by fengli · 2 weeks ago
  38. e3cda01 [FLINK-35189][connectors/filesystem] Modify the visibility of filesystem connector related methods to protected by fengli · 2 weeks ago
  39. 00d69e5 [FLINK-35189][table-common] CatalogPropertiesUtil support serialize and deserialize materialized table by fengli · 2 weeks ago
  40. f64654e add HTTP options to java-storage client by Ravi Dutt Singh · 9 months ago
  41. fb58380 [FLINK-35162][state] Attach the keyGroup and payload into RecordContext by Jinzhong Li · 2 weeks ago
  42. 1c4eb91 [FLINK-35162][state]Support grouping state get and put access by Jinzhong Li · 3 weeks ago
  43. e057010 [FLINK-35125][state] Implement ValueState for ForStStateBackend by Jinzhong Li · 3 weeks ago
  44. 512f3fb [FLINK-35190][table-api] Support create materialized table syntax by Feng Jin · 2 weeks ago
  45. 19577b0 [FLINK-35047][state] Support FlinkEnv to init ForSt by Hangxiang Yu · 3 weeks ago
  46. 417484e [FLINK-35047][state] Introduce ForStStateBackend and ForStKeyedStateBackend by Hangxiang Yu · 3 weeks ago
  47. 625d8a5 [FLINK-35047][state] Support restoring and building ForSt by Hangxiang Yu · 3 weeks ago
  48. 5f5d502 [FLINK-35047][state] Introduce ResourceContainer for ForStStateBackend by Hangxiang Yu · 3 weeks ago
  49. 8411367 [FLINK-35047][state] Introduce Metrics for ForStStateBackend by Hangxiang Yu · 3 weeks ago
  50. 92d7f65 [FLINK-35047][state] Introduce ForSt related options by Hangxiang Yu · 3 weeks ago
  51. 629c357 [FLINK-35047][state] Introduce forstjni dependency by Hangxiang Yu · 3 weeks ago
  52. 259aef0 [FLINK-31223][sqlgateway] Pass all flink parameters to the SqlGatewayRestEndpoint. by Weijie Guo · 1 year, 2 months ago
  53. 6392f81 [FLINK-31223][test] Abstract SqlClientTestBase. by Weijie Guo · 1 year, 2 months ago
  54. 63f02a0 [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to get all flink configurations copy in the form of map. by Weijie Guo · 1 year, 2 months ago
  55. 797cb9c [hotfix][runtime] Make sure run RecordContext#release() in Task thread. (#24705) by Wang FeiFan · 13 days ago
  56. df4685a [hotfix][docs] Fix the invalid link in 1.18 release note by yebukong · 2 weeks ago
  57. a87db93 [FLINK-35156][Runtime] Make operators of DataStream V2 integrate with async state processing by Zakelly · 3 weeks ago
  58. 92eef24 [FLINK-29050][JUnit5 Migration] Module: flink-hadoop-compatibility by Roc Marshal · 11 months ago
  59. 29a0455 [FLINK-29050][test-utils] Use JUnit5 to re-write AbstractTestBase, JavaProgramTestBase MultipleProgramsTestBase and tag the corresponding old implementation classes as deprecated by Roc Marshal · 11 months ago
  60. ffa639a [FLINK-29050][test-utils] Rename AbstractTestBase, JavaProgramTestBase MultipleProgramsTestBase with JUnit4 suffix. by Roc Marshal · 11 months ago
  61. 0953199 [FLINK-35088][core] Watermark alignment maxAllowedWatermarkDrift and updateInterval param need check by elon-X · 2 weeks ago
  62. 8576178 [FLINK-35188][table-api] Introduce RefreshHandler interface to support materialized table by fengli · 2 weeks ago
  63. 2a9876d [FLINK-35188][table-api] Introduce CatalogMaterializedTable interface to support materialized table by fengli · 2 weeks ago
  64. 9cc6498 [FLINK-35148][core] Improve InstantiationUtil for checking nullary public constructor by Mingliang Liu · 3 weeks ago
  65. 712d980 [FLINK-35166][runtime] Make the SortBufferAccumulator use more buffers when the parallelism is small by jiangxin · 3 weeks ago
  66. d453baf [FLINK-34444] Initial implementation of JM operator metric rest api (#24564) by Mason Chen · 2 weeks ago
  67. 8475d28 [FLINK-35158][Core/API] Move functional interfaces about consumers from core module to core-api by Zakelly · 2 weeks ago
  68. ea2eabe [FLINK-35214][runtime] Update result partition id for remote input channel when unknown input channel is updated by Yuxin Tan · 2 weeks ago
  69. 0b2e988 [FLINK-35028][runtime] Timer firing under async execution model by fredia · 3 weeks ago
  70. 51d015b [FLINK-35097][table] Use var-args in RawFormatSerDeSchemaTest by Kumar Mallikarjuna · 3 weeks ago
  71. 8ffe6d6 [FLINK-35097][table] Update RawFormatSerDeSchemaTest to validate multiple serializations/deserializations by Kumar Mallikarjuna · 3 weeks ago
  72. 3a56c2f [FLINK-35097][table] Fix 'raw' format deserialization by Kumar Mallikarjuna · 3 weeks ago
  73. 68a84fd [FLINK-35169][runtime] Recycle buffers to freeSegments before releasing data buffer for sort accumulator by Yuxin Tan · 3 weeks ago
  74. 9336760 [FLINK-35027][runtime/checkpoint] Implement checkpoint drain in AsyncExecutionController by fredia · 3 weeks ago
  75. a4c71c8 [FLINK-35175][filesystem] Avoid reading with ByteBuffer on hadoop version below 3.3.0 (#24691) by Hangxiang Yu · 3 weeks ago
  76. b3fdb07 [FLINK-32315][k8s] Support uploading "local://" artifacts in Kubernetes Application Mode (#24303) by Ferenc Csaky · 3 weeks ago
  77. 7c4dec6 [FLINK-28048][connectors] Introduce Source API alternative to FiniteTestSource (#23777) by Alexander Fedulov · 3 weeks ago
  78. 3977982 [FLINK-34954][core] Kryo Input bug fix by Qinghui Xu · 6 weeks ago
  79. 131358b [FLINK-35159] Transition ExecutionGraph to RUNNING after slot assignment by Chesnay Schepler · 3 weeks ago
  80. 10c84df [hotfix] Delete pointless test by Chesnay Schepler · 3 weeks ago
  81. a312a3b [FLINK-35045][state] Support ByteBufferReadable for HadoopDataInputStream by Hangxiang Yu · 3 weeks ago
  82. a147684 [FLINK-35045][state] Introduce ByteBufferReadable to support reading and positionable reading with ByteBuffer by Hangxiang Yu · 3 weeks ago
  83. 7d004ca [FLINK-35045][state] Introduce input stream pool to improve the performance of readFully by Hangxiang Yu · 6 weeks ago
  84. 0cfbe4c [FLINK-35045][state] ForStFlinkFileSystem supports reading and writing with ByteBuffer by Hangxiang Yu · 6 weeks ago
  85. 369bbb8 [FLINK-35045][state] Introduce ForStFlinkFileSystem by Hangxiang Yu · 7 weeks ago
  86. 43a3d50 [FLINK-34633][table] Support unnesting array constants by Jeyhun Karimov · 3 weeks ago
  87. 2c5078b [FLINK-34987][state] Implement Async Value State (#24651) by Hangxiang Yu · 3 weeks ago
  88. 1445ea8 [FLINK-34987][state] Introduce InternalKeyedState for Async State API by Hangxiang Yu · 3 weeks ago
  89. 7699a0d [FLINK-34987][state] Introduce new StateDescriptor for Async State API by Hangxiang Yu · 3 weeks ago
  90. fe8dde4 [FLINK-35025][Runtime/State] Introduce element order for async state processing by Zakelly · 3 weeks ago
  91. e1edb24 [FLINK-35025][Runtime/State] Abstract stream operators for async state processing by Zakelly · 4 weeks ago
  92. c7be45d [FLINK-35025][Runtime/State] Erase the type parameter of record within AEC and related components. by Zakelly · 4 weeks ago
  93. 31ea1a9 [FLINK-34936][Checkpointing] Register reused shared state handle to FileMergingSnapshotManager by Zakelly · 4 weeks ago
  94. 7a90a05 [FLINK-35089][runtime] Initialize lastRecordAttributes in AbstractStreamOperator during setup by sxnan · 4 weeks ago
  95. 691cc67 [FLINK-35046][state] Introduce AsyncKeyedStateBackend supporting to create StateExecutor (#24663) by Hangxiang Yu · 3 weeks ago
  96. 9cc5ab9 [FLINK-30081][runtime] Reset unused options like jvm-overhead.min/max for local executor by Mingliang Liu · 4 weeks ago
  97. 9ae9c14 [hotfix][runtime]Fix the missing methed parameter annotation problem by chenyu · 3 weeks ago
  98. 138f1f9 [FLINK-25537][JUnit5 Migration] Module flink-core with package configuration by gongzhongqiang · 3 weeks ago
  99. f886687 [FLINK-31472][connectors/base] Remove external timer service reference from AsyncSinkThrottling Test (#24481) by Ahmed Hamdy · 3 weeks ago
  100. f74dc57 [FLINK-34158][table] Migrate WindowAggregateReduceFunctionsRule to java by Sergey Nuyanzin · 3 weeks ago