Google Git
Sign in
apache/flink/HEAD
  1. 6e3768d [FLINK-39405][docs] Fix document escape display errors on sql built-in function page (#27900) by Au-Miner · 9 hours ago master
  2. 106acbc [FLINK-39387][Test] Fix flaky scheduler benchmark tests caused by thread assertion failure in async TDD creation by Liu Jiangang · 17 hours ago
  3. ef532a2 [FLINK-39151][metrics] Hide warning about UnixOperatingSystemMXBean missing on Windows (#27662) by Piotr Przybylski · 35 hours ago
  4. 62cb6c5 [FLINK-39408][tests] Fix TestNameProvider broken after JUnit 5 migration by Rui Fan · 3 days ago
  5. 795a36e [FLINK-39399][table-runtime] Fix integer overflow in HyperLogLogPlusPlus causing APPROX_COUNT_DISTINCT undercount by Jim Hughes · 2 days ago
  6. b1c858e [FLINK-38895][runtime] Introduce the /jobs/:jobid/rescales/details/:rescaleuuid endpoint in the REST API by Yuepeng Pan · 11 days ago
  7. 9bdd3a4 [hotfix] Remove redundant logs.zip entry from .gitignore by Gustavo de Morais · 3 days ago
  8. 406cfbc [hotfix] Remove duplicate .claude entry from .gitignore by Gustavo de Morais · 8 days ago
  9. 5dcf72d [FLINK-38507][tests] Fix the failed OpenTelemetryTraceReporterITCase (#27792) by HundalTaran · 3 days ago
  10. 4684e3e [FLINK-38716][docs] Describe the impact of slot.request.max-interval on balanced tasks scheduling. (#27270) by Yuepeng Pan · 3 days ago
  11. e39b252 [FLINK-38543][checkpoint] Change overall UC restore process for checkpoint during recovery by Rui Fan · 7 weeks ago
  12. aaab864 [FLINK-38543][checkpoint] Introduce bufferFilteringCompleteFuture for earlier RUNNING state transition by Rui Fan · 7 weeks ago
  13. 8f40b51 [FLINK-38543][checkpoint] Fix Mailbox loop interrupted before recovery finished by Rui Fan · 7 weeks ago
  14. d1914c6 [FLINK-39018][network] Buffer migration from RecoveredInputChannel to physical channels by Rui Fan · 7 weeks ago
  15. 4f192b3 [FLINK-39018][checkpoint] Notify PriorityEvent to downstream task even if it is blocked to ensure the checkpoint barrier can be handled by downstream task by Rui Fan · 4 weeks ago
  16. cebc174 [FLINK-39018][network] Fix LocalInputChannel priority event and buffer availability for recovered buffers by Rui Fan · 7 weeks ago
  17. 3aef093 [FLINK-39018][checkpoint] Support LocalInputChannel checkpoint snapshot for recovered buffers by Rui Fan · 7 weeks ago
  18. 9ce47b2 [hotfix][network] Fix LocalInputChannel.getBuffersInUseCount to include toBeConsumedBuffers by Rui Fan · 7 weeks ago
  19. 01070e6 [FLINK-39275][docs] Fix some issues in the "Performance Tuning" document (#27893) by Vincent-Woo · 6 days ago
  20. 9b3037b [FLINK-39359][docs] Introduce integration test cases to ensure that the generated REST-API related documentation stays consistent with the code. (#27884) by Yuepeng Pan · 7 days ago
  21. 463330c [FLINK-39395][build] Add spotless `upToDateChecking` by Sergey Nuyanzin · 8 days ago
  22. b0d0d2e [FLINK-39323][table] Support `SHOW CREATE [OR ALTER]` with relative time intervals for `FROM_NOW(<interval_expression>)` by Sergey Nuyanzin · 8 days ago
  23. 52fd096 [FLINK-39393][table] Add `TableChange` for comment by Sergey Nuyanzin · 8 days ago
  24. 39f0344 [FLINK-39393][table] Add `TableChange` for `START_MODE` by Sergey Nuyanzin · 8 days ago
  25. ec90a33 [hotfix][docs/test] Migrate the assertj assertion lines. (#27879) by Yuepeng Pan · 8 days ago
  26. 1da7029 [FLINK-39282][docs] Translate "Balanced Tasks Scheduling" page into Chinese (#27805) by Vincent-Woo · 8 days ago
  27. c24f964 [hotfix][javadoc] Fix invalid comments in Committer class by Jiaan Geng · 8 days ago
  28. 69edc37 [FLINK-39375][API / Core] Add explicit serialVersionUID to WatermarkAlignmentParams by Myracle · 9 days ago
  29. 7ea90f4 [FLINK-38372][Runtime / Metrics] Introduces whitelist to the flink-metrics-prometheus by Myracle · 7 months ago
  30. fc2a9ec [FLINK-39385][table] `TIMESTAMPDIFF` fails for `TIME` by Sergey Nuyanzin · 8 days ago
  31. 2fa3b1a [FLINK-39277][docs] Fix the problem of missing content display due to format errors (#27796) by Vincent-Woo · 9 days ago
  32. 77266f0 [hotfix][kubernetes] Fix the option typo in KubernetesConfigOptions (#27872) by Yuepeng Pan · 9 days ago
  33. b631cca [FLINK-39041][docs] Rebuild REST API docs pages to supplement the missing content. (#27855) by Yuepeng Pan · 9 days ago
  34. 738dd00 [FLINK-38815] Mask sensitive values in Pekko debug configuration logs by Vishal · 10 days ago
  35. 923a359 [hotfix][runtime] Fix DispatcherCleanupITCase.testCleanupAfterLeadershipChange by Yi Zhang · 2 weeks ago
  36. 2259862 [FLINK-39309][runtime] Check terminated applications for duplication by Yi Zhang · 3 weeks ago
  37. f302c47 [FLINK-39117][tests] Fix flaky ChainUnionTest by tolerating CHECKPOINT_COORDINATOR_SUSPEND exception (#27664) by Shekhar Prasad Rajak · 10 days ago
  38. 9b2a112 [FLINK-39371][table] `CurrentDatabase` fails for some patterns by Sergey Nuyanzin · 10 days ago
  39. 1b933bd [FLINK-38930][checkpoint] Use heap buffer fallback to avoid deadlock during recovery by Rui Fan · 2 weeks ago
  40. 23ebbb5 [FLINK-38930][checkpoint] Filtering record before processing without spilling strategy by Rui Fan · 7 weeks ago
  41. 17dfa5f [hotfix] Rename isUnalignedDuringRecoveryEnabled to isCheckpointingDuringRecoveryEnabled by Rui Fan · 2 weeks ago
  42. 8b71634 [FLINK-39302][table] Support `SHOW CREATE OR ALTER MATERIALIZED TABLE` by Sergey Nuyanzin · 10 days ago
  43. b975641 [FLINK-39360][table] `LIKE` clause doesn't support some patterns by Sergey Nuyanzin · 10 days ago
  44. 34246de [FLINK-38861][docs] Update documentation to cover new `CREATE`/`ALTER` operations for `MATERIALIZED TABLE`s by Sergey Nuyanzin · 10 days ago
  45. 64a21e7f [FLINK-39348][table] Add `Interval` to reuse code for `FRESHNESS` and `START MODE` by Sergey Nuyanzin · 10 days ago
  46. 0c4ab25 [FLINK-39241][table] Fix MultiJoinStateViews by changing GenericRowData to BinaryRowData by Dmitriy Linevich · 10 days ago
  47. dc6d128 [FLINK-39358][table] Constraint and watermark should stay while CoA MT if there is no explicit change with schema or constraint definition by Sergey Nuyanzin · 10 days ago
  48. ab3bcce [FLINK-38343][runtime] Support store rescale history with statistics by ExecutionGraphInfo. by Yuepeng Pan · 6 weeks ago
  49. 897f8ed [FLINK-38341][configuration] Introduce the rescale history configuration option. by Pan Yuepeng · 9 months ago
  50. c0265db [FLINK-39331] Add @Experimental annotation to public S3 classes by Samrat002 · 2 weeks ago
  51. e890caf [FLINK-39016][Runtime/REST] Add configurable TTL for ExecutionGraph cache independent of web refresh interval by Myracle · 9 weeks ago
  52. 64007b1 [FLINK-39355][table-planner] Fix field names in code generation for JSON_OBJECT/ARRAY/STRING by Timo Walther · 11 days ago
  53. 4734953 [FLINK-39349][table] Support deletion flag in TO_CHANGELOG by Gustavo de Morais · 11 days ago
  54. 863140e [FLINK-38342][runtime] Support record rescale information by Yuepeng Pan · 3 weeks ago
  55. b6cb13a [FLINK-39126][metrics] Support exporting metrics through grpc in batches by Aleksandr Iushmanov · 6 weeks ago
  56. 8d8bf95 [FLINK-39339][table-planner] Consider immutable cols to infer sink required updated mode traits by xuyang · 2 weeks ago
  57. ce310b5 [hotfix] Fix unused field in ImmutableColumnsConstraint by xuyang · 2 weeks ago
  58. c38b7e6 [FLINK-39260][python] Support compression formats other than '.zip' for config option 'python.files' (#27780) by RaoraoXiong · 12 days ago
  59. d62be55 [FLINK-38933][python] Expose runtime context information in Python UDX FunctionContext by yongliu · 2 weeks ago
  60. 004268a [FLINK-38968][table] Add toCatalogTable method to CatalogMaterializedTable interface by Ramin Gharib · 14 days ago
  61. 754254f [FLINK-39343][doc] Fix inconsistencies in `sql_functions.yml` documentation by Ramin Gharib · 14 days ago
  62. c0a4768 [FLINK-39304][table] Support `START_MODE` clause in the parser by Sergey Nuyanzin · 14 days ago
  63. 9d7afcd [hotfix][table] Use two spaces for `MODIFY DEFINITION QUERY` by Sergey Nuyanzin · 2 weeks ago
  64. 992062e [FLINK-39284][table] Make `CREATE OR ALTER MATERIALIZED TABLE` respect column comment change by Sergey Nuyanzin · 2 weeks ago
  65. 2e905a6 [FLINK-39284][table] Make `CREATE OR ALTER MATERIALIZED TABLE` respect watermark changes by Sergey Nuyanzin · 2 weeks ago
  66. 9a30a23 [FLINK-39284][table] Nullify types for columns while `CREATE OR ALTER MATERIALIZED TABLE` similar to `CREATE` by Sergey Nuyanzin · 2 weeks ago
  67. bbde1e2 [FLINK-39284][table] Make `CREATE OR ALTER MATERIALIZED TABLE` respect constraint changes by Sergey Nuyanzin · 2 weeks ago
  68. c7843a1 [FLINK-39284][table] Extract test for `CREATE OR ALTER MATERIALIZED TABLE` by Sergey Nuyanzin · 2 weeks ago
  69. cd16294 [FLINK-38901][runtime-web] Introduce the Rescales/Configuration sub-page for streaming jobs with the adaptive scheduler enabled by och5351 · 2 weeks ago
  70. 85fcd04 [hotfix][runtime-web] Polish the checkpoint related variables naming by och5351 · 2 weeks ago
  71. 73d71d9 [FLINK-39233][table-runtime] Support cascaded delta join runtime (#27828) by Xuyang · 2 weeks ago
  72. 072b7d3 [FLINK-39188][docs] Documentation for BITMAP type by dylanhz · 2 weeks ago
  73. eabc3ce [FLINK-38541][checkpoint] Introducing config option: execution.checkpointing.unaligned.during-recovery.enabled by Rui Fan · 3 months ago
  74. fbd2e4f [hotfix] Extract VirtualChannel as the public class by Rui Fan · 3 months ago
  75. b1b986c [hotfix][runtime] Extract RecordFilter as the interface by Rui Fan · 3 months ago
  76. 0f3889e [FLINK-39313][table-planner] Fix NDU analyzer to detect non-deterministic functions in ChangelogNormalize filter conditions by Gustavo de Morais · 2 weeks ago
  77. 36302ed [FLINK-39273][table-common] Fix argument name conflict when UDF method contains lambda expression by dylanhz · 2 weeks ago
  78. af98780 [FLINK-39326][runtime] Fix DispatcherApplicationTest.testJobResultNotMarkedCleanUntilApplicationTerminates by Yi Zhang · 2 weeks ago
  79. d538534 [hotfix][docs] Move PERCENTILE doc from arithmetic to aggregate section by dylanhz · 2 weeks ago
  80. 62e7163 [FLINK-39187][table] Add new built-in functions to allow direct cardinality return for bitmap aggregation by dylanhz · 3 weeks ago
  81. 26046c6 [FLINK-39187][table] Add the built-in function BITMAP_AND_AGG, BITMAP_OR_AGG, BITMAP_XOR_AGG by dylanhz · 3 weeks ago
  82. 1c6943c [FLINK-39187][table] Add the built-in function BITMAP_BUILD_AGG by dylanhz · 2 weeks ago
  83. 8ade28e [hotfix][core] Make RoaringBitmapData implement Serializable and Remove unused wrap method by dylanhz · 2 weeks ago
  84. ee64584 [FLINK-38976][runtime] Support zero job in an application by Yi Zhang · 4 weeks ago
  85. a6da0b9 [FLINK-38976][runtime] Support multiple batch jobs in an application by Yi Zhang · 4 weeks ago
  86. eaf99f5 [FLINK-39094][table-planner] Avoid creating duplicate function instances in code generation (#27613) by dylanhz · 2 weeks ago
  87. bbd045f [FLINK-39240][runtime] Jobs share application-level jar when possible by Yi Zhang · 4 weeks ago
  88. 31daa9d9 [FLINK-39318][table] Fix interruptible timers are not working for TemporalSort by Piotr Nowojski · 2 weeks ago
  89. 83496f4 [FLINK-39318][table] Fix interruptible timers are not working for TemporalJoin by Piotr Nowojski · 2 weeks ago
  90. 4a5b178 [FLINK-39311][runtime] Fix application-related main thread execution in Dispatcher by Yi Zhang · 2 weeks ago
  91. 45a04a7 [FLINK-39174][table-planner] Support lookup join after delta join (#27698) by Xuyang · 2 weeks ago
  92. 2e49048 [FLINK-39314][table-planner] Allow input to drop update before if filter is applied on any of upsert keys by xuyang · 2 weeks ago
  93. 370a887 [FLINK-39287][table-planner] Introduce FlinkRelMdImmutableColumns to implement the derivation logic of some simple nodes and update the logic to infer upsert key with immutable columns by xuyang · 3 weeks ago
  94. 58d7acc [FLINK-39286][table] Introduce immutable columns constraint in schema by xuyang · 3 weeks ago
  95. c0bc1e5 [FLINK-39186][table] Add the built-in function BITMAP_AND, BITMAP_ANDNOT, BITMAP_OR, BITMAP_XOR by dylanhz · 3 weeks ago
  96. 198816c [FLINK-39186][table] Add the built-in function BITMAP_TO_ARRAY, BITMAP_TO_STRING by dylanhz · 3 weeks ago
  97. 20af677 [FLINK-39186][table] Add the built-in function BITMAP_CARDINALITY by dylanhz · 3 weeks ago
  98. 9318cc0 [FLINK-39186][table] Support BITMAP literal in Table API and add BITMAP cast it cases by dylanhz · 3 weeks ago
  99. afe599d [FLINK-39186][table] Add the built-in function BITMAP_FROM_BYTES, BITMAP_TO_BYTES by dylanhz · 3 weeks ago
  100. 0071c4d [FLINK-39186][table] Add the built-in function BITMAP_BUILD by dylanhz · 3 weeks ago