Google Git
Sign in
apache / flink / HEAD
  1. 412fc8c [FLINK-37078] Fix for jackson-mapper-asl 1.9.13 vulnerability (#25890) by Anupam Aggarwal · 2 days ago master
  2. 45588b3 [FLINK-37695][table] Fix parsing for built-in function JSON in JSON_OBJECT for all positions by Gustavo de Morais · 2 days ago
  3. a790428 [FLINK-37745] Serialize partial deletes in ChangelogMode to JSON (#26516) by Dawid Wysakowicz · 2 days ago
  4. 8bd248e [FLINK-37728][python] Fix the wrong Global Window usage in Thread Mode by Shuyi Chen · 3 days ago
  5. 444732e [FLINK-18590][json] Support json array explode to multi messages (#26473) by Hongjia Liang · 4 days ago
  6. 95bf638 [FLINK-37693][state] Avoid reading NOT_OWNED file by local file system when restoring (#26497) by yhx · 4 days ago
  7. b523264 [FLINK-26425][yarn] Support rolling log aggregation by Ferenc Csaky · 4 days ago
  8. b47cda2 [FLINK-35014][table] SqlNode to operation conversion for models (#25834) by Hao Li · 5 days ago
  9. f8b3c4b [FLINK-37709][metrics] Add file descriptor JVM metrics by Peter Huang · 6 days ago
  10. 9fb7cc3 [FLINK-37542][table-planner] Support sink reuse in streaming mode (#26380) by xiangyu0xf · 8 days ago
  11. f0ed3f7 [FLINK-37705][rest] JobPlanInfo properties spec adjustments by Efrat Levitan · 12 days ago
  12. 2dd5f97 [hotfix][runtime] Remove the redundant 'format' calling. by Roc Marshal · 2 weeks ago
  13. 794005c [FLINK-37680][serializer] Add subclass cache for PojoSerializer by Zhanghao Chen · 2 weeks ago
  14. 8829e5e [hotfix][runtime] Delete the unused BoundedInputStream.java. by Pan Yuepeng · 2 weeks ago
  15. 4b6ea1e [FLINK-37691] Do not remove ChangelogNormalize if deduplication was requested (#26499) by Dawid Wysakowicz · 9 days ago
  16. b0607a1 [FLINK-37697][runtime] Fix application mode cluster shut down before all job termination futures complete by Yi Zhang · 2 weeks ago
  17. c724168 [FLINK-37543][table-planner] Support sink reuse in batch mode (#26379) by xiangyu0xf · 11 days ago
  18. 932fd59 [FLINK-34558][state] Support tracking state size (#25837) by hejufang · 12 days ago
  19. d14c2d5 [FLINK-37658][docs] Improve the Datagen connector docs by David Radley · 12 days ago
  20. 3cfc211 [FLINK-35652][doc] Add document for lookup custom shuffle by yunfengzhou-hub · 2 weeks ago
  21. de280fa [hotfix][runtime] Polish check hints and lines calling for StreamOperatorStateHandler#snapshotState. (#26477) by Pan Yuepeng · 2 weeks ago
  22. 7c03bc8 [FLINK-37659][release] Generate reference data for state migration tests based on release-2.0.0 by Zhanghao Chen · 3 weeks ago
  23. a2c84a7 [FLINK-37197][docs] Update MongoDB docs for 2.0.0 release by Jiabao Sun · 2 weeks ago
  24. 8fff1c0 [FLINK-37668][state] Make compaction filter related config take effect for ForStStateBackend by Hangxiang Yu · 3 weeks ago
  25. 7b5936b [FLINK-37668][state] Make compaction filter related config take effect for RocksDBStateBackend by Hangxiang Yu · 3 weeks ago
  26. 14c848b [FLINK-37668][core] TimeUtils supports to parse ISO-8601 duration format by Hangxiang Yu · 3 weeks ago
  27. 929bd15 [FLINK-37540][table-planner] Introduce SupportsTargetColumnWriting sink ability (#26361) by xiangyu0xf · 2 weeks ago
  28. 0849018 [FLINK-37670][runtime] Fix watermark alignment can deadlock job if there are no more splits to be assigned by Piotr Nowojski · 3 weeks ago
  29. 9d6ae16 [hotfix] Fix test coverage of WatermarkAlignmentITCase by Piotr Nowojski · 3 weeks ago
  30. 2ee862e [FLINK-37298] Added Pluggable Components for BatchStrategy & BufferWrapper in AsyncSinkWriter. (#26274) by PB · 2 weeks ago
  31. e98915a [FLINK-37638][clients] Avoid duplicate call on `getEffectiveConfiguration` by Jiaan Geng · 3 weeks ago
  32. 9302545 [FLINK-37605][runtime] Infer checkpoint id on endInput in sink by Arvid Heise · 4 weeks ago
  33. 98284c4 [FLINK-37605][runtime] Cleanup writer test by Arvid Heise · 3 weeks ago
  34. fe04a6e [FLINK-37605][runtime] Remove obsolete sink tests by Arvid Heise · 3 weeks ago
  35. 3342c23 [FLINK-37605][runtime] Clarify contract of endInput by Arvid Heise · 3 weeks ago
  36. e004410 [FLINK-37671] Fix ChangelogMode#toString (#26452) by Dawid Wysakowicz · 3 weeks ago
  37. 795fcbe [FLINK-37554][state/forst] Add UT for state compatibility between ForStKeyeStateBackend and ForStSyncKeyeStateBackend (#26440) by mayuehappy · 3 weeks ago
  38. 03bea48 [FLINK-37649][datagen] Datagen connector cannot set length for collection type by Weijie Guo · 3 weeks ago
  39. aff916e [hotfix] Avoid duplicate call on checkNotNull (#26429) by Jiaan Geng · 3 weeks ago
  40. 0053b41 [FLINK-37643] Support partial deletes when converting to external data structures (#26436) by Dawid Wysakowicz · 3 weeks ago
  41. 98000fb [FLINK-37623][datastream] Async state support for process() in Datastream API (#26419) by Yanfei Lei · 3 weeks ago
  42. f7b5d00 [FLINK-37642][runtime] Use the mailboxExecutor for operator in Async state processing (#26435) by Yanfei Lei · 3 weeks ago
  43. b37c985 [FLINK-37610] Check if `ORDER BY` keys exists before accessing by Bonnie Varghese · 3 weeks ago
  44. feb7ab12 [FLINK-37603] QueryOperation SQL Serialization customization (#26389) by Dawid Wysakowicz · 3 weeks ago
  45. ce171b4 [hotfix] [docs] Typo fix in several docs (#26432) by Gunnar Morling · 3 weeks ago
  46. 0a1b3ca [FLINK-37225] Remove remaining test resources of Gelly by Zhanghao Chen · 3 months ago
  47. fc51d4e [FLINK-37511] Use Jackson serialization in JobPlanInfo.Plan by Efrat Levitan · 7 weeks ago
  48. 40ffc15 [FLINK-37553] Make ForStKeyedStateBackend update NamespaceSerializer during restoring state (#26416) by mayuehappy · 3 weeks ago
  49. c0dd8f0 [hotfix] Fix size of PyFlink INT(#25511) by Lukas Schwerdtfeger · 3 weeks ago
  50. 9cfd7ca [FLINK-37628] Fix reference counting in ForSt file cache (#26415) by Zakelly · 3 weeks ago
  51. 3bc9600 [FLINK-37620][state/forst] ForSt Sync mode support remote storage (#26412) by Yanfei Lei · 3 weeks ago
  52. c57c220 [FLINK-37596][metrics] Close metric group of a finished split by Efrat Levitan · 4 weeks ago
  53. 5b864d7 [hotfix] Update copyright NOTICE year to 2025 (#26413) by Zakelly · 3 weeks ago
  54. 92c5c98a [FLINK-37598][table] Support list and map state in PTFs by Timo Walther · 3 weeks ago
  55. ec810ba [FLINK-37616][python] Fix incorrect unpickling of Row fields by Mika Naylor · 3 weeks ago
  56. b2231da [FLINK-37601] Remove Unirest dependency in PrometheusReporterTest (#26387) by r-sidd · 4 weeks ago
  57. ae09a0d [FLINK-37407][state] Add savepoint metadata SQL built-in process function by Gabor Somogyi · 4 weeks ago
  58. 4db8c48 [hotfix][docs] Fix broken tabs and PTF example argument errors by Juntao Zhang · 4 weeks ago
  59. a80d71f [hotfix] Avoid duplicate get memory segment size (#26367) by Jiaan Geng · 4 weeks ago
  60. 0d86f54 [hotfix] Avoid copy set in PekkoRpcService (#26372) by Jiaan Geng · 4 weeks ago
  61. b0ad87a [FLINK-37524][state/forst] Make ForStState Restore from previous StateMetaInfo (#26391) by mayuehappy · 4 weeks ago
  62. 5aaff07 [FLINK-37609][format] Bump parquet to 1.15.1 by Sergey Nuyanzin · 4 weeks ago
  63. bec57c1 [FLINK-35117][Table SQL/Planner] Add commons-text to allowed classloader list. This closes #26390 by Martijn Visser · 4 weeks ago
  64. 076fa80 [FLINK-37158][tests] Introduce ForSt to existing ITCases by fredia · 4 weeks ago
  65. 36eb336 [FLINK-37597][state/forst] Use ResourceGuard to make sure snapshot quit before ForSt disposal by fredia · 4 weeks ago
  66. 4a0c2e4 [FLINK-37521][runtime] Implement async state version of KeyedCoProcessOperator (#26328) by Yanfei Lei · 4 weeks ago
  67. 39aa79e [FLINK-37569] Add userKeySerializer in RegisteredKeyValueStateBackend V2 (#26364) by mayuehappy · 4 weeks ago
  68. 2921fb7 [FLINK-37151][runtime-web] Remove redundant testing dependencies and files (#26383) by Laffery · 4 weeks ago
  69. e06fddc [FLINK-19059]: Add NonTimeRangeUnboundedPrecedingFunction for OverAggregate by Bonnie Varghese · 4 weeks ago
  70. 6004194 [FLINK-37547][docs] Document PTFs by Timo Walther · 4 weeks ago
  71. 9fbd25c [hotfix][docs] update create table syntax pseudo code by Laffery · 4 weeks ago
  72. 38262ee [FLINK-37570][metrics] Export default watermark if split doesn't have any by Efrat Levitan · 5 weeks ago
  73. 7052c3b [FLINK-37472][docs] fix typo in zh content of page streaming_analytics by huangyanyanyan · 4 weeks ago
  74. 0e7b44c [FLINK-37582] Apply PushCalcPastChangelogNormalizeRule before FlinkChangelogModeInferenceProgram by Dawid Wysakowicz · 5 weeks ago
  75. 2dcdbf0 [FLINK-37584][tests] Bump AssertJ version to 3.27.3 by r-sidd · 5 weeks ago
  76. d5e1ff2 [FLINK-37576][runtime] Fix the incorrect status of the isBroadcast field in AllToAllBlockingResultInfo when submitting a job graph. by JunRuiLee · 5 weeks ago
  77. 5bd8fcb [hotfix] Replacing manual comparison logic with `Long#compare` by big face cat · 5 weeks ago
  78. 354e0e4 [FLINK-37408] Update all `docker-compose` references to `docker compose` by nilmadhab mondal · 5 weeks ago
  79. b506661 [FLINK-37556][metrics][otel] Add missing dependencies for OpenTelemetry by Mate Czagany · 5 weeks ago
  80. 56e1e76 [FLINK-37533][CI] Add action: write permission to stale PR github action (#26360) by Thomas Cooper · 5 weeks ago
  81. d5ecb07 [FLINK-37568] Improve the method flatten of class GlobalConfiguration by beliefer · 5 weeks ago
  82. 8c9d4ee [FLINK-37493][release] Update japicmp configuration for 2.0.0 by Weijie Guo · 6 weeks ago
  83. d0996ad [FLINK-37490][Docs] Add 2.0 to PreviousDocs list by Weijie Guo · 6 weeks ago
  84. 0091f39 [FLINK-37426][metrics] Extract AttributeBuilder interface by Piotr Nowojski · 6 weeks ago
  85. 5a91138 [FLINK-37426][metrics] Regenerate docs by Piotr Nowojski · 6 weeks ago
  86. 0a1af7e [FLINK-37426][metrics] Add OpenTelemetryEventReporter by Piotr Nowojski · 7 weeks ago
  87. 85e7fc1 [FLINK-37426][metrics] Add Slf4jEventReporter by Piotr Nowojski · 7 weeks ago
  88. ccde568 [FLINK-37426][metrics] Integrate EventReporters with MetricRegistry by Piotr Nowojski · 6 weeks ago
  89. 0b3ab69 [FLINK-37426][metrics] Add core support for Events by Piotr Nowojski · 7 weeks ago
  90. 1a274ab [FLINK-37426][metrics] Properly integrate traces with metric group features by Piotr Nowojski · 7 weeks ago
  91. 6ee4549 [FLINK-37426][metrics] Refactoring to avoid code duplication in reporter setup code by Piotr Nowojski · 7 weeks ago
  92. c12b861 [hotfix] Make all fields in SimpleSpan final by Piotr Nowojski · 7 weeks ago
  93. 99d6660 [hotfix] Avoid use of raw type parameter in ComponentMetricGroup. by Piotr Nowojski · 8 weeks ago
  94. fb8f60e [hotfix] Avoid use of raw type parameter in AbstractMetricGroup. by Piotr Nowojski · 8 weeks ago
  95. 486ba5f [hotfix] Avoid use of raw type parameter in MetricRegistry interface and implementations. by Piotr Nowojski · 8 weeks ago
  96. df9db31 [FLINK-37533][CI] Reduce the stale PR github action timouts to match typical apache values (90 days inactive with 30 to respond) (#26336) by Thomas Cooper · 5 weeks ago
  97. e1c609c [FLINK-37410][runtime/metrics] Split level Watermark metrics (#26276) by Efrat Levitan · 5 weeks ago
  98. 8608371 [FLINK-36443][table][test] Improve flaky tests related to partition specs (#26335) by Muhammet Orazov · 5 weeks ago
  99. c6c90b8 [hotfix][clients] Refactor PackagedProgram#getJobJarAndDependencies to reduce some redundant lines. (#26238) by Yuepeng Pan · 5 weeks ago
  100. a5d4194 [FLINK-37482][core] Refactor the code for PrintSinkOutputWriter, PrintSinkFunction and PrintSink (#26309) by Jiaan Geng · 5 weeks ago