Google Git
Sign in
apache / flink / HEAD
  1. ecd284d [FLINK-38401][table] Add getUpsertKeys support for StreamPhysicalMultiJoin by Gustavo de Morais · 12 hours ago master
  2. 04f3047 [FLINK-38396][tests] Make `DefaultKubernetesArtifactUploaderTest` more stable by Sergey Nuyanzin · 16 hours ago
  3. 358a28e [FLINK-38391][build] Bump maven-shade-plugin to 3.6.1 by Sergey Nuyanzin · 3 days ago
  4. 1c530de [FLINK-38385][build] Bump mockito to 5.19.0 and byte-buddy to 1.17.6 by Sergey Nuyanzin · 3 days ago
  5. c3e0dbe [FLINK-38379][table] Adjust `visitMultiJoin` in `RelTimeIndicatorConverter` to use fields and not rows by Gustavo de Morais · 4 days ago
  6. 07fabaa [FLINK-38378][table] Use ValidationException in CatalogManager in case of user error by Sergey Nuyanzin · 4 days ago
  7. 933c9cf [FLINK-38352][table-planner] Make source specs forward compatible (like sink specs) by Timo Walther · 4 days ago
  8. dc8acbf [FLINK-38384][build] Bump lombok to 1.18.42 by Sergey Nuyanzin · 4 days ago
  9. 1ac32a5 [FLINK-38319][python] Allow TO_TIMESTAMP_LTZ to accept expressions other than literal in PyFlink (#26987) by Kaiqi Dong · 4 days ago
  10. 335621e [FLINK-38370] Ensure CommitterOperator commits all pending committables in batch mode by Maximilian Michels · 5 days ago
  11. d08abb7 [FLINK-37955] Add test for duplicated results from StreamingJoinOperator by Gustavo de Morais · 7 weeks ago
  12. dfdba3d [FLINK-37955] Don't load all records into main memory to avoid OOM by Roman Khachatryan · 4 months ago
  13. 80a95ef [FLINK-37295][doc] Add state ttl migration compatibility to docs by Gabor Somogyi · 6 days ago
  14. 4b7d62b [FLINK-38332][python] Bump pemja to 0.5.5 by sxnan · 14 days ago
  15. 3e41e72 [FLINK-38365][table] Make invalid operations with `MATERIALIZED TABLE`s returning more user friendly message by Sergey Nuyanzin · 6 days ago
  16. 2e7cac1 [FLINK-38311][table] Serializing and deserializing of table and materialized table with distribution by Sergey Nuyanzin · 8 days ago
  17. d7b5213 [FLINK-38311][table] Add support for `DISTRIBUTION` in materialized tables by Sergey Nuyanzin · 8 days ago
  18. 2f6b96d [FLINK-38312][table] `SHOW MATERIALIZED TABLES` should show constraint info and no columns info by Sergey Nuyanzin · 8 days ago
  19. f31ed29 [hotfix][table] Use assertJ in `CatalogTableITCase` and `CatalogViewITCase` by Sergey Nuyanzin · 5 weeks ago
  20. eb281af [hotfix][docs] Move distribution before partitioned to match implementation by Sergey Nuyanzin · 8 days ago
  21. 0748711 [FLINK-32695] Migrated Common Test cases by Poorvank · 5 weeks ago
  22. a412b58 [hotfix] Pin rsync by hash to allow docs to be build (#26993) by Martijn Visser · 7 days ago
  23. 48b4337 [FLINK-37697][Documentation] Adding Confluent to vendors list (#26992) by Martijn Visser · 7 days ago
  24. 3bc4f4f [FLINK-38352][table] Expose timestamp used in DefaultWatermarkGenerator by Timo Walther · 7 days ago
  25. 5db1ffa [FLINK-38356][table-planner] Respect terminating flag for test values source by Dawid Wysakowicz · 8 days ago
  26. 58c5066 [FLINK-37936][table-planner] Support STATE TTL hints for MultiJoin by Gustavo de Morais · 8 days ago
  27. f3bd4a4 [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in file-merging manager (#26977) by Zakelly · 12 days ago
  28. b2b99fe [FLINK-32695] Migrated SavepointReaderITTestBase to SourceV2 by Poorvank · 4 weeks ago
  29. 9e977ce [FLINK-38329][ci] Add target release label for backport PRs by David Radley · 12 days ago
  30. 5ad464d [FLINK-37245] Add tests for RowData FieldGetters by Maximilian Michels · 8 months ago
  31. d6ce0d8 [FLINK-35725][docs][docs-zh] Improve "DISTRIBUTED BY" documentation and translate into Chinese by Jinkun Liu · 13 days ago
  32. 551c3d7 [hotfix][table] Fix incorrect state ttl setting in KeyedLookupJoinWrapper by lincoln lee · 13 days ago
  33. deee02b [FLINK-38109][flink-runtime] Fix `BlobClient` address when `jobmanager.bind-host` is set by Rosa Kang · 14 days ago
  34. ee73d0f [FLINK-38327] Use vertex id instead of operator id in checkpoint file-merging manager (#26968) by Zakelly · 14 days ago
  35. 3ffbe56 [FLINK-38328][ci] Remove redundant community review label mutations (#26964) by David Radley · 2 weeks ago
  36. ae96dc0 [hotfix] Improve comment about Task's state transitions by Piotr Nowojski · 5 weeks ago
  37. dc2627b [FLINK-38180][task] Clean up task after switching to FAILED by Piotr Nowojski · 8 weeks ago
  38. 3772e4e [hotfix][task] Allow AutoCloseableRegistry to close in the registration order by Piotr Nowojski · 8 weeks ago
  39. 5689cdf [hotfix][table] Safeguard bunch of operators and functions from throwing NPE on close by Piotr Nowojski · 6 weeks ago
  40. 573e3df [hotfix][test] Rewrite ValidatingSink to not throw exception during closing by Piotr Nowojski · 6 weeks ago
  41. fcb934c [hotfix][test] Rewrite testWithRocksDbBackendIncremental to not depend on close not being called on failures by Piotr Nowojski · 6 weeks ago
  42. faa30fd [hotfix] Extract Task#transitionStateOnFailure by Piotr Nowojski · 8 weeks ago
  43. 4472b08 [hotfix] Better error message in TaskTest by Piotr Nowojski · 8 weeks ago
  44. 4e3c684 [hotfix] Improve logging in StreamTask#cleanUp by Piotr Nowojski · 8 weeks ago
  45. 7a00b0e [FLINK-38291][REST] Reduce thread lock overhead for REST handlers (#26951) by yunfengzhou-hub · 3 weeks ago
  46. 6741573 [hotfix] Use `simplifiedCondition` to check for `isAlwaysTrue` in `PushCalcPastChangelogNormalizeRule` by Sergey Nuyanzin · 3 weeks ago
  47. aa97d86 [FLINK-38317][table] Make PushCalcPastChangelogNormalizeRule tolerant to trimmed fields by Sergey Nuyanzin · 3 weeks ago
  48. 49cbd98 [FLINK-38312][table] Add support for `SHOW MATERIALIZED TABLES` by Sergey Nuyanzin · 3 weeks ago
  49. 863b051 [FLINK-38308] Reduce logging of date parse errors in DateTimeUtils by Roman Khachatryan · 3 weeks ago
  50. f4bdad4 [FLINK-38193] Bump commons-lang3 to version 3.18.0 by Jakub Stejskal · 4 weeks ago
  51. 2807674 [FLINK-38288] Enhance BlobWriter logging with offloading time in millis. by Aleksandr Iushmanov · 4 weeks ago
  52. 93cd9b6 [FLINK-38267][checkpoint] Fix the test timeout for UnalignedCheckpointRescaleWithMixedExchangesITCase.testRescaleFromUnalignedCheckpoint by Rui Fan · 4 weeks ago
  53. 6f2be0a [FLINK-37827][table] Add support for `SHOW CREATE MATERIALIZED TABLE` by Sergey Nuyanzin · 4 weeks ago
  54. 1e7525f [FLINK-32695] [Tests] Migrated ChangelogStateBackendLoadingTest to Source V2. by Poorvank · 4 weeks ago
  55. e2a2755 [FLINK-38286][table] Fix: MAP function with duplicate keys produces non-deterministic results by Ramin Gharib · 4 weeks ago
  56. f7a159b [FLINK-38257][SQL] Add module dynamic function loading possibility by Gabor Somogyi · 4 weeks ago
  57. 831f3ab [FLINK-38131][flink-runtime] Fix that JM still redistributes broadcast state when all subtask have reported their states (#26925) by zhou · 4 weeks ago
  58. d81751a [FLINK-38267][checkpoint] Only call channel state rescaling logic for exchange with channel state to avoid UnsupportedOperationException by Rui Fan · 5 weeks ago
  59. 6f171e4 [FLINK-38267][checkpoint] Refactor hasInputState and hasOutputState related logic in TaskStateAssignment by Rui Fan · 5 weeks ago
  60. 0eeab73 [FLINK-32695] [Tests] Migrated TableFactoryHarness.ScanSourceBase to Source V2 by Poorvank · 8 weeks ago
  61. a516014 [FLINK-32695] Moved TestSource in TypeFillTest to SourceV2 by Poorvank · 8 weeks ago
  62. 5753b09 [FLINK-32695]-Added-flink-test-utils-connectors module by Poorvank · 5 weeks ago
  63. 250ab88 [FLINK-38255][table] Add ITCase to verify sensitive table option redaction by yangli1206 · 5 weeks ago
  64. 469644d [FLINK-38195][table][docs] Fix markdown syntax errors in `tableApi` page by CuiYanxiang · 5 weeks ago
  65. 62ddda7 [hotfix][docs] Fix variable name in Java Batch example in `README` by Swapnil Aher · 5 weeks ago
  66. 4aac690 [FLINK-38246][table-planner] Remove unreachable code in CodeGenUtils by morvenhuang · 5 weeks ago
  67. f75312e [FLINK-38256][table] Sync unparse for `TABLE` and `SHOW CREATE TABLE` by Sergey Nuyanzin · 5 weeks ago
  68. e8a3305 [hotfix][docs] Typos and format in `state.md` and `state_v2.md` by Jackeyzhe · 5 weeks ago
  69. 8e2998f [hotfix][docs] `WITH` in `CREATE DATABASE` is optional by Sergey Nuyanzin · 5 weeks ago
  70. 788831b [FLINK-38217][table] ChangelogNormalize unnecessarily emits updates for equal rows by Sergey Nuyanzin · 6 weeks ago
  71. 5d4a191 [FLINK-38251][table-planner] Enable restore tests again by Gustavo de Morais · 6 weeks ago
  72. 4cdc679 [hotfix][release] Publish wheel for apache-flink-libraries (#26844) by David Hotham · 6 weeks ago
  73. c80a1f3 [FLINK-38234][table-planner] Enable NDU strategy for semantic tests by default by Gustavo de Morais · 6 weeks ago
  74. 60170ff [FLINK-32695] [Tests] Replace NonSerializableTupleSource with DataGeneratorSource V2 API by Poorvank · 9 weeks ago
  75. fbc7d0a [FLINK-38230][table-planner] Add visitMultiJoin to StreamNDUPlanVisitor by Gustavo de Morais · 6 weeks ago
  76. 00241a6 [FLINK-38201][table-planner] SinkUpsertMaterializer should not be inserted for retract sinks by Timo Walther · 6 weeks ago
  77. 19f27ea [FLINK-38220][table-planner] Add Values and TableFunctionScan as sources (#26887) by Gustavo de Morais · 6 weeks ago
  78. 4a98ded [FLINK-38219][table-runtime] Fix row kind in StreamingMultiJoinOperator by Gustavo de Morais · 6 weeks ago
  79. 5494e91 [FLINK-38198] Support WITH Clause in CREATE FUNCTION Statement (#26874) by Dawid Wysakowicz · 6 weeks ago
  80. cae5fb4 [FLINK-38209][table-planner] Use UniqueKeys instead of Upsertkeys for inputSpec and state management for MultiJoin by Gustavo de Morais · 7 weeks ago
  81. 1b21e37 [FLINK-38154][metrics] Add HTTP protocol support to OpenTelemetry reporters (#26850) by Kumar Mallikarjuna · 7 weeks ago
  82. 5de409e [FLINK-38135][table] Fix call to non-existent method for RAW type hashing by dylanhz · 7 weeks ago
  83. eef14cb [FLINK-38181][table] Fix various casting issues, ROW() with SMALLINT, and JSON() function by Ramin Gharib · 7 weeks ago
  84. 720172b [FLINK-37700][table-planner] Fix SQL parse exception when creating a view with PTF by Juntao Zhang · 7 weeks ago
  85. 5d914f2 [FLINK-38202][build] Allow to configure `junit.jupiter.execution.parallel.config.dynamic.factor` by Sergey Nuyanzin · 7 weeks ago
  86. f623e10 [FLINK-38202][build] Allow to customize `dynamic.max-pool-size-factor` by Sergey Nuyanzin · 7 weeks ago
  87. 59278c9 Renamed Local Sink by Poorvank · 9 weeks ago
  88. 4c49d14 [FLINK-32695] [Tests] Migrate CoGroupJoinITCase to env.fromData() and Sink V2 API by Poorvank · 9 weeks ago
  89. db91239 FLINK-32695-ReactiveModeITCase-NewSource-Migration by Poorvank · 9 weeks ago
  90. 6a31842 [FLINK-38199] Allow to specify output in AbstractStreamOperatorTestHarness by Roman Khachatryan · 7 weeks ago
  91. 9a858e7 [FLINK-38200][table] Allow to use `FIRST_VALUE` and `LAST_VALUE` with other types by Sergey Nuyanzin · 7 weeks ago
  92. bbe109c [FLINK-37314][Documentation] Fix the definition of lateness to t_w - t instead of t - t_w by Myracle · 7 weeks ago
  93. f859462 [FLINK-37735][serializer] Replace class.newInstance with constructor.newInstance by Zhanghao Chen · 7 weeks ago
  94. 160433d [hotfix] Mark PojoSerializer header flag defs as final by Zhanghao Chen · 7 weeks ago
  95. 17bedd4 [FLINK-37844][table-planner] Add new ProjectMultiJoinTransposeRule by Gustavo de Morais · 7 weeks ago
  96. 9463c9b [FLINK-32695] [Tests] Removed SourceFunction Dependency from YarnTestCacheJob. by Poorvank · 9 weeks ago
  97. 10c53c2 [FLINK-32695] Migrated StreamTaskTimerITCase to new Source V2. by Poorvank · 7 weeks ago
  98. 066a957 [hotfix] Do not run community review label on non Apache repo by Sergey Nuyanzin · 7 weeks ago
  99. a356421 [FLINK-38069][table] Fix return type nullability diffs of function ENCODE & DECODE in SQL and Table API by dylanhz · 7 weeks ago
  100. 63b2ad5 [FLINK-38138] Array OOB error when trying to get a binary from a non-zero offset from a vector by voonhous · 7 weeks ago