Google Git
Sign in
apache / flink / HEAD
  1. 2385cc0 [FLINK-34918][table] Support `ALTER CATALOG COMMENT` syntax by Yubin Li · 3 days ago master
  2. adfbbbd [hotfix] Fix exception when setting 'state.backend.forst.compression.per.level' in yaml by Zakelly · 2 days ago
  3. 0919ff2 [FLINK-35371][security] Add configuration for SSL keystore and truststore type by ammar-master · 2 days ago
  4. 4044b9e [FLINK-34917][table] Support `CREATE CATALOG IF NOT EXISTS` with comment by Yubin Li · 2 days ago
  5. 5497868 [FLINK-32091][checkpoint] Add file size metrics for file-merging (#24922) by Yanfei Lei · 2 days ago
  6. bc5c4b8 [FLINK-35597][test] Fix unstable LocatableSplitAssignerTest#testConcurrentSplitAssignmentForMultipleHosts by Yubin Li · 2 days ago
  7. 6f47913 [hotfix] Improve execution.checkpointing.unaligned.interruptible-timers.enabled documentation by Piotr Nowojski · 4 days ago
  8. 6c05981 [FLINK-35543][HIVE] Upgrade Hive 2.3 connector to version 2.3.10 (#24905) by Cheng Pan · 2 days ago
  9. 93b9bdf [FLINK-35157][runtime] Sources with watermark alignment get stuck once some subtasks finish (#24757) by elon-X · 2 days ago
  10. d0f9bb4 [FLINK-34172] Add support for altering a distribution via ALTER TABLE by James Hughes · 3 days ago
  11. 9d16903 [FLINK-35164][table] Support `ALTER CATALOG RESET` syntax by Yubin Li · 3 days ago
  12. f0b0127 [FLINK-35378][FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunction. This closes #24805 by Martijn Visser · 3 days ago
  13. 14fdd13 [FLINK-25537] [JUnit5 Migration] Module: flink-core with,Package: core (#24881) by gongzhongqiang · 3 days ago
  14. 26e6193 [FLINK-34482][checkpoint] Refactor checkpoint section in doc by Hangxiang Yu · 8 days ago
  15. 38070a1 [FLINK-34482][checkpoint] Rename checkpointing options by Hangxiang Yu · 13 days ago
  16. 03b3d26 [FLINK-34977][test] Introduce DataStream V2 IT Tests by Jeyhun Karimov · 8 days ago
  17. 2a6ee64 [FLINK-34977][API] Support compile-time checks for invalid states by Jeyhun Karimov · 11 days ago
  18. 9a47e37 [FLINK-34977][API] Introduce State Access on DataStream API V2 by Jeyhun Karimov · 11 days ago
  19. a3ef9b7 [FLINK-34977][API] Move State interfaces to flink-core-api by Jeyhun Karimov · 11 days ago
  20. 3c77ccc [FLINK-34977][API] Add useStates to the ProcessFunction by Jeyhun Karimov · 2 weeks ago
  21. 2998ef1 [FLINK-34977][API] Support State Declarations by Jeyhun Karimov · 2 weeks ago
  22. f0c3b98 [FLINK-34977][API] Move Reduce and Aggregate functions to flink-core-api by Jeyhun Karimov · 2 weeks ago
  23. c6c7c99 [FLINK-34977][API] Introduce Type Descriptors by Jeyhun Karimov · 2 weeks ago
  24. f91730d [FLINK-34977][API] Introduce TypeDescriptor and TypeUtils by Jeyhun Karimov · 2 weeks ago
  25. fb5fd48 [FLINK-35570][Checkpoint] Consider PlaceholderStreamStateHandle in file merging by Zakelly · 4 days ago
  26. 77cd1cd [FLINK-35528][task] Skip execution of interruptible mails when yielding by Piotr Nowojski · 3 weeks ago
  27. 986d06d [FLINK-20217][docs] Regenerate docs by Piotr Nowojski · 3 months ago
  28. 3e9d047 [FLINK-20217][task] Add support for splittable timers to AbstractStreamOperatorV2 by Piotr Nowojski · 2 months ago
  29. f26ee47 [FLINK-20217][task] Enable splittable timers in CepOperator and TableStreamOperator by Piotr Nowojski · 2 months ago
  30. f93cac3 [FLINK-20217][task] Allow certains operators to yield to unaligned checkpoint in case timers are firing. by David Moravek · 7 months ago
  31. a64c00b [FLINK-20217][task] Introduce YieldingOperator to get access to MailboxExecutor for V1 operators by Piotr Nowojski · 3 months ago
  32. 53bdac9 [FLINK-20217][task] Add MailboxExecutor::shouldInterrupt by Piotr Nowojski · 3 months ago
  33. 503593a [hotfix] Setup BufferDataOverWindowOperatorTest a bit more properly by Piotr Nowojski · 3 months ago
  34. 23fa2ae [FLINK-35533][runtime] Add a option to config the external remote tier factory class by Yuxin Tan · 10 days ago
  35. 32b563d [FLINK-35533][runtime] Refactor the APIs and implementations for supporting remote tier plugin by Yuxin Tan · 10 days ago
  36. fe74f74 [FLINK-35533][runtime] Introduce TierShuffleDescriptor and RemoteTierShuffleDescriptor by Yuxin Tan · 10 days ago
  37. 1d62a35 [FLINK-35533][runtime] Create teir factories according to the configured remote tier class by Yuxin Tan · 10 days ago
  38. 894feed Revert "[FLINK-34123][core][type] Introduce built-in serialization support for Map, List, and Collection" by Zhanghao Chen · 4 days ago
  39. ad64351 Revert "[FLINK-34123][docs][type] Add doc for built-in serialization support for Map, List, and Collection" by Zhanghao Chen · 4 days ago
  40. 65f0b40 Revert "[FLINK-35068][core][type] Introduce built-in serialization support for java.util.Set" by Zhanghao Chen · 4 days ago
  41. 526f9b0 [FLINK-35473][sql-client] Add missing annotation for ResultMode and SqlClientOptions by Jane Chan · 12 days ago
  42. 6dbe7bf [FLINK-35473][table-planner] Add issue navigator to track legacy window options by Jane Chan · 12 days ago
  43. fbacf22a [FLINK-35473][table-api][table-planner] Move LookupJoinHintOptions to table-api module by Jane Chan · 12 days ago
  44. fbf0f28 [FLINK-35473][table-api][table-planner] Deprecate the outdated optimizer config options by Jane Chan · 12 days ago
  45. b7b1fc2 [FLINK-35473][table-api][table-planner] Move optimizer-related options to OptimizerConfigOptions by Jane Chan · 12 days ago
  46. 93d49ff [FLINK-35473][table-api][table-planner] Move adaptive local hash agg option to ExecutionConfigOptions by Jane Chan · 12 days ago
  47. f33808c [FLINK-32081][test] Add Compatibility IT case for fileMerging by Jinzhong Li · 2 weeks ago
  48. 4500df1 [FLINK-32081][checkpoint] Compatibility between file-merging on and off across job runs by Jinzhong Li · 2 weeks ago
  49. e1b4568 [FLINK-35068][core][type] Introduce built-in serialization support for java.util.Set by Zhanghao Chen · 10 weeks ago
  50. b72ce53 [FLINK-35531] Avoid calling hsync in flush method in BaseHadoopFsRecoverableFsDataOutputStream by sychen · 11 days ago
  51. c9def98 [FLINK-35435][Connectors/base] Add timeout Configuration to Async Sink (#24839) by Ahmed Hamdy · 6 days ago
  52. 74b100b [FLINK-35525][yarn] Add a token services configuration to allow obtained token to be passed to Yarn AM by Zhen Wang · 6 days ago
  53. 57869c1 [FLINK-34239][core,table] Add copy() in SerializerConfig by Kumar Mallikarjuna · 3 months ago
  54. 20816c9 [FLINK-35537] Fix exception when setting 'state.backend.rocksdb.compression.per.level' in yaml by Zakelly · 10 days ago
  55. 0305111 [FLINK-35423][table] ARRAY_EXCEPT should follow set semantics by Sergey Nuyanzin · 9 days ago
  56. 4b0a395 [FLINK-31664][table] Implement ARRAY_INTERSECT function by Jacky Lau · 10 days ago
  57. 0967335 [hotfix][table] refactoring to template method to separate concerns by jingge · 7 months ago
  58. f462926 [FLINK-35201][table] Remove unnecessary logs in MaterializedTableManager by Feng Jin · 10 days ago
  59. c862fa6 [FLINK-35201][table] Enhance function names in MaterializedTableStatementITCase for better readability by Feng Jin · 10 days ago
  60. 42289bd [FLINK-35201][table] Support the execution of drop materialized table in full refresh mode by Feng Jin · 11 days ago
  61. 9708f9f [FLINK-35501] Use common IO thread pool for RocksDB data transfer by Roman Khachatryan · 3 weeks ago
  62. 5855f53 [FLINK-35501] Replace inheritance with encapsulation for RocksDBStateDataTransfer* by Roman Khachatryan · 3 weeks ago
  63. ceb4db4 [FLINK-35532][Runtime/Web Frontend] Prevent Cross-Site Authentication (XSA) attacks on Flink dashboard by Hong Teoh · 11 days ago
  64. 5b228cd [FLINK-35139][docs] Update MongoDB docs for 1.2.0 release by Danny Cranmer · 10 days ago
  65. aa4d312 [FLINK-35526] Use more up to date jq docker image for Flink e2e tests (#24892) by Robert Metzger · 10 days ago
  66. b110581 [FLINK-35522][runtime] Fix the issue that the source task may get stuck in speculative execution mode. by sunxia · 11 days ago
  67. b8d5271 [Flink 34569][e2e] fail fast if AWS cli container fails to start (#24491) by Robert Young · 11 days ago
  68. c90f30f [FLINK-35475][runtime] Introduce isInternalSorterSupport to OperatorAttributes by sxnan · 2 weeks ago
  69. 5c04781 [refactor][test] Move test to StreamingJobGraphGeneratorWithOperatorAttributesTest by sxnan · 2 weeks ago
  70. 2e158fe [FLINK-35200][table] Fix missing clusterInfo in materialized table refresh rest API return value by Feng Jin · 13 days ago
  71. 9b51711 [FLINK-35200][table] Support the execution of suspend, resume materialized table in full refresh mode by Feng Jin · 2 weeks ago
  72. 8d1e043 [FLINK-35200][table] Add dynamic options for ResumeRefreshWorkflow by Feng Jin · 2 weeks ago
  73. 62f9de8 fixup! [FLINK-35351][checkpoint] Fix fail during restore from unaligned checkpoint with custom partitioner by Piotr Nowojski · 3 weeks ago
  74. 5411956 [hotfix] Unify Preconditions import in StreamConfig by Piotr Nowojski · 3 weeks ago
  75. eb42701 [hotfix] Unify Preconditions import in Transformation by Piotr Nowojski · 3 weeks ago
  76. d5b2b3c [hotfix] Simplify SinkTransformationTranslator by Piotr Nowojski · 3 weeks ago
  77. 9c925e0 [hotfix] Rewrite Transformation#equals and #hashCode to use Objects helper methods by Piotr Nowojski · 3 weeks ago
  78. cd72203 [FLINK-26050] Manually compact small SST files by Roman Khachatryan · 4 months ago
  79. caa68c2 [hotfix] Revert "[FLINK-35282][python] Upgrade pyarrow and beam" due to CI failures by Hong Teoh · 12 days ago
  80. 91a9e06 [FLINK-35282][python] Upgrade pyarrow and beam by Antonio Vespoli · 2 weeks ago
  81. e4fa72d [FLINK-35199][table] Support the execution of create materialized table in full refresh mode by Feng Jin · 2 weeks ago
  82. 309e324 [FLINK-35199][table] Remove dynamic options and add initialization configuration to CreatePeriodicRefreshWorkflow by Feng Jin · 2 weeks ago
  83. f3a3f92 [FLINK-35483][runtime] Fix unstable BatchJobRecoveryTest. by JunRuiLee · 2 weeks ago
  84. d075c9f [FLINK-32142][build][flink-runtime-web] Upgrade frontend-maven-plugin to 1.12.1 by Elphas Toringepi · 1 year, 1 month ago
  85. 0c7b1ae [hotfix][docs] Fix example code in documentation by Zmm · 2 weeks ago
  86. 4a94d4b [hotfix][docs] maven should require v3.8.6, not higher by Luke Chen · 2 weeks ago
  87. 56cd960 [FLINK-35399][doc] Update the batch job recovery documentation. by JunRuiLee · 2 weeks ago
  88. 853989b [FLINK-35358][clients] Reintroduce recursive JAR listing in classpath load from "usrlib" by Ferenc Csaky · 5 weeks ago
  89. b1841c0 [FLINK-35484][docs] Fix the issue that document files had been removed but website still can access by gongzhongqiang · 2 weeks ago
  90. 132722e [FLINK-35461][config] Deprecate StreamPipelineOptions that only contains deprecated option by sxnan · 3 weeks ago
  91. ac6d7a3 [FLINK-35461][config] Deprecate the unnecessary option fine-grained.shuffle-mode.all-blocking by sxnan · 3 weeks ago
  92. e33fb16 [FLINK-35461][config] Deprecate taskmanager.network.max-num-tcp-connections by sxnan · 3 weeks ago
  93. b25b921 [FLINK-35461][config] Deprecate netty options that are not recommended to be used by sxnan · 3 weeks ago
  94. 312df35 [FLINK-35461][config] Deprecate or update options of shuffle compression by sxnan · 3 weeks ago
  95. b60b1e3 [FLINK-35461][config] Deprecate or update options of floating/exclusive buffer by sxnan · 3 weeks ago
  96. b9d8bb1 [FLINK-35461][config] Deprecate options related to legacy hybrid shuffle by sxnan · 3 weeks ago
  97. 501370d [FLINK-35461][config] Deprecate options related to hash-based blocking shuffle by sxnan · 3 weeks ago
  98. 6ee3094 [FLINK-32088][checkpoint] Space control in file merging by Zakelly · 4 weeks ago
  99. aabfd6e [FLINK-35399][doc] Add documents for batch job recovery from jobMaster failover. by JunRuiLee · 3 weeks ago
  100. 89c89d8 [FLINK-34456][configuration]Move all checkpoint-related options into CheckpointingOptions. by spoon-lz · 4 weeks ago