Google Git
Sign in
apache/flink/HEAD
  1. a46a571 [FLINK-39897][table] Fix SQL serialization when using limit without order by Mika Naylor · 14 hours ago master
  2. f14ce1e [FLINK-39818][ci] Filter org.eclipse.parsson:parsson false positive for Elasticsearch connector by reswqa · 10 days ago
  3. f827408 [FLINK-39711][runtime] Expose maxExceptions on exception message parameters by Jubin Soni · 18 hours ago
  4. edfeb32 [hotfix][build] Put commas into exclusion groups to avoid commas only by Sergey Nuyanzin · 33 hours ago
  5. f03c904 [FLINK-39868][table-runtime] Remove per-row logging from `parseUrl` and `subString` by Ramin Gharib · 2 days ago
  6. 4828c18 [FLINK-39894][tools/releasing] Change version in generated REST API specifications yml files when creating a new release branch (#28365) by Yuepeng Pan · 2 days ago
  7. 9a63a47 [hotfix][runtime/test] Enhance the test case CreditBasedPartitionRequestClientHandlerTest#testReceiveCompressedBuffer for checking totalQueueSizeInBytes (#28355) by Yuepeng Pan · 3 days ago
  8. afb5ef9 [FLINK-39879][tests] Stop CheckpointAcknowledgeFailureITCase hanging on slow CI by Martijn Visser · 5 days ago
  9. c46e3ae [FLINK-39884][ci] Free up additional disk space for CI runs by Martijn Visser · 4 days ago
  10. 392e032 [hotfix][ci] Do not run GHA nightly if there is no newer commits since the last run by Sergey Nuyanzin · 4 days ago
  11. f77b821 [hotfix][tests] Replace deprecated `JavaConversions` in `TableTestBase` by Sergey Nuyanzin · 4 days ago
  12. 5c2e1d0 [FLINK-39882][table] Parser can not parse unparsed polymorphic table functions with several table args by Sergey Nuyanzin · 6 days ago
  13. 6a8cb80 [FLINK-39820][docs] Update delta join documentation with new features in 2.3 (#28354) by Xuyang · 4 days ago
  14. d720d58 [hotfix] Fix some typos for connector-base, protobuf, runtime, table-planner and tests modules. (#28328) by Yuepeng Pan · 4 days ago
  15. af30def [FLINK-38809][Tests] Upgrade Testcontainers to 2.0.5 by Sergey Nuyanzin · 5 days ago
  16. a552ca3 [FLINK-39880][tests] Bump minikdc to 3.4.3 by Sergey Nuyanzin · 5 days ago
  17. 832fb18 [FLINK-39872][e2e] Add `wrapInExecutionException` to `common.sh` by Sergey Nuyanzin · 6 days ago
  18. 5c0e9a8 [FLINK-39865][ci] Replace abandoned travis-ci artifacts uploader with AWS CLI for nightly S3 upload by Martijn Visser · 7 days ago
  19. 8a56878 [FLINK-39846][tests] Restore IPv6 guard and config in IPv6HostnamesITCase under AdaptiveScheduler by Martijn Visser · 8 days ago
  20. 676365b [FLINK-39858][rest] Fail orphaned in-flight request futures on RestClient close (#28315) by Martijn Visser · 6 days ago
  21. ef04bb1 [FLINK-39823][table] Fix incorrect type inference for typed PTF table args by Timo Walther · 6 days ago
  22. 80189e4 [FLINK-39799][table] Preserve user-typed query text for materialized table and view definitions by Ramin Gharib · 6 days ago
  23. 7a915ff [FLINK-39857] Upgrade Pekko to 1.6.0 by Sergey Nuyanzin · 6 days ago
  24. a62a144 [FLINK-39421][table] Fix metadata filter contract and add coverage by Jim Hughes · 6 days ago
  25. ed1738d [FLINK-39761][runtime] Set 'Connection: close' header in `StaticFileServerHandler` when sending '304 Not Modified' responses by nattilabalint · 6 days ago
  26. 15da2ba [FLINK-39652][docs] Improve documentation for regexp functions (#28325) by Ramin Gharib · 7 days ago
  27. c3ec569 [FLINK-39845][tests] Fix SavepointITCase.testStopWithSavepointFailsOverToSavepoint under AdaptiveScheduler by Martijn Visser · 8 days ago
  28. 4e98dce [hotfix][docs] Fix typo and heading level in state backends documentation (#28173) by Dennis-Mircea Ciupitu · 8 days ago
  29. 690b6a3 [hotfix][table-runtime] Fix typo in RowTimeMiniBatchAssignerOperator class name (#28172) by Dennis-Mircea Ciupitu · 8 days ago
  30. a3072ee [FLINK-39836][runtime-web] Add missing License Header to .eslintrc.js and .stylelintrc.js in web-dashboard (#28307) by Yuepeng Pan · 8 days ago
  31. 4490b30 [FLINK-39258][table] Extend restore tests for TO_CHANGELOG and FROM_CHANGELOG by Gustavo de Morais · 8 days ago
  32. b63688e [FLINK-39829][build] Bump scala to 2.12.21 by Sergey Nuyanzin · 9 days ago
  33. cebcd70 [FLINK-39821][table] Make REGEXP_REPLACE return type nullable (#28293) by Ramin Gharib · 9 days ago
  34. 8bf4827 [FLINK-39136][filesystems] Bump google-cloud-storage to 2.68.0 in flink-gs-fs-hadoop (#28286) by Martijn Visser · 9 days ago
  35. 8ca97a3 [FLINK-39811][s3] Document adjusted part size for s5cmd by Efrat Levitan · 10 days ago
  36. 3b31886 [FLINK-39811][s3] Optionally Adjust s5cmd part size to fully ustilize s5cmd workers pool during downloads by Efrat Levitan · 2 weeks ago
  37. 0419317 [hotfix][docs] Update Kafka connector doc version by Ferenc Csaky · 9 days ago
  38. a5a7925 [FLINK-39651][table] REGEXP plan-time validation and hot-path log cleanup (#28292) by Ramin Gharib · 9 days ago
  39. 8cce8e8 [FLINK-39790][state/metrics] Fix State latency/size tracking metrics not exported without sampling by Efrat Levitan · 2 weeks ago
  40. 50ff839 [FLINK-39812][table] Migrate `FlinkTypeFactory` to java by Sergey Nuyanzin · 10 days ago
  41. ea8905a8 [FLINK-39815][tests] Mark SecurityManager related tests with `FailsOnJava25` by Sergey Nuyanzin · 10 days ago
  42. cc348d4 [FLINK-39801][table] Skip serializing empty partition/order keys for PTF table args by Ramin Gharib · 11 days ago
  43. afd806e [FLINK-37422][docs] Fix typos and translation alignment in streaming analytics zh document by Arvind Kandpal · 11 days ago
  44. f952a92 [FLINK-39717][docs] Document SET/RESET key handling for ALTER TABLE, CATALOG, MODEL and DATABASE by Ramin Gharib · 11 days ago
  45. 6c756a0 [hotfix][docs] Fix code examples and minor issues in DataStream documentation by Vishal Kamlapure · 11 days ago
  46. 810f081 [FLINK-39806][build] Add jdk25 required flags by Sergey Nuyanzin · 12 days ago
  47. 3a785f9 [FLINK-39803][e2e] Ignore jdk25 native access and deprecated method warnings by Sergey Nuyanzin · 13 days ago
  48. fa26789 [FLINK-36602][tests] Add pre Calcite 1.38.0 tests for CALCITE-7562 issue by Sergey Nuyanzin · 13 days ago
  49. 59bb8b7 [FLINK-39379][table] Add state management to PTF test harness (#28212) by Mika Naylor · 13 days ago
  50. c033b17 [FLINK-39636][table] Widen output column nullability for partial deletes by Ramin Gharib · 2 weeks ago
  51. e400c2c [FLINK-39636][table] Remove unnecessary validation in TO_CHANGELOG by Ramin Gharib · 2 weeks ago
  52. 32f9e60 [FLINK-39636][table] Emit partial DELETE rows in TO_CHANGELOG via upsert key by Ramin Gharib · 2 weeks ago
  53. d763453 [FLINK-39735][table] Expose input upsert key on TableSemantics by Ramin Gharib · 2 weeks ago
  54. 340fbf8 [FLINK-39636][table] Refactor ToChangelogTypeStrategy by Ramin Gharib · 3 weeks ago
  55. bca2c0a [FLINK-39636][table] Add produces_full_deletes parameter to TO_CHANGELOG by Ramin Gharib · 3 weeks ago
  56. 6925076 [FLINK-39425][metrics] `OpenTelemetryEventReporter` ignores `service.name` and `service.version config` by SameerDevgon · 2 weeks ago
  57. 09547ce [hotfix][table] Fix flaky TemporalJoinITCase (#28273) by Fabian Hueske · 2 weeks ago
  58. 5d9860c [FLINK-39768][tests][JUnit5 migration] Module: flink-avro - `AvroStreamingFileSinkITCase` by Purushottam Sinha · 2 weeks ago
  59. 85a8e7a [FLINK-39793][table] Bump quartz to 2.5.2 by Sergey Nuyanzin · 2 weeks ago
  60. 4ea57c1 [FLINK-39794][tests] Bind StreamNetworkBenchmarkEnvironment to loopback by Martijn Visser · 2 weeks ago
  61. 7402fd1 [FLINK-39726][table] Support `USING CONNECTION` clause in `CREATE TABLE` by Hao Li · 2 weeks ago
  62. 34f770d [FLINK-39702] Exclude netty 3.x from hadoop by Sergey Nuyanzin · 2 weeks ago
  63. 1769396 [FLINK-39773][tests] Use random ports in `ClusterEntryPointTest` by Sergey Nuyanzin · 2 weeks ago
  64. 75120b5 [FLINK-39753][state/rocksdb] Close ColumnFamilyOptions from getDescriptor() in Compactor (#28251) by Keith Lee · 2 weeks ago
  65. 383d564 [FLINK-39719][table] Drop late probe records from TemporalRowTimeJoinOperator (#28229) by Fabian Hueske · 2 weeks ago
  66. b194666 [FLINK-39751][tests] Add `FailsOnJava25` by Sergey Nuyanzin · 2 weeks ago
  67. 8eef95f [hotfix][tests] Migrate `ClusterUncaughtExceptionHandlerITCase` to JUnit5 by Sergey Nuyanzin · 2 weeks ago
  68. 8c029d0 [FLINK-39577][table] Reuse Calcite's `COALESCE` to apply simplifications from `RexSimplify` by Sergey Nuyanzin · 2 weeks ago
  69. 0b77c11 [hotfix] Fix typo 'mim' -> 'min' (#28260) by Aleksandr Savonin · 2 weeks ago
  70. 04a31ba [FLINK-39145][tests] Skip counters accumulation when state isn't initialized by Efrat Levitan · 2 weeks ago
  71. b07e12d [FLINK-39737][s3] Switch to StandardRetryStrategy with configurable backoff for throttle-aware retry by Gabor Somogyi · 2 weeks ago
  72. 587a9d8 [FLINK-39590][table] Add support for CONNECTION in catalog APIs by Hao Li · 2 weeks ago
  73. 3052f64 [hotfix] Allow security manager only if java version is less than 24 by Sergey Nuyanzin · 2 weeks ago
  74. 4ef1707 [FLINK-39762][ci] Add wget in case of java 25 by Sergey Nuyanzin · 2 weeks ago
  75. 570cb32 [FLINK-38192][table] Improve DynamicSourceUtils exception msg by Arvind Kandpal · 3 weeks ago
  76. 45295cf [FLINK-38503] Adapt `DefaultClusterClientServiceLoader` to java 25 by Sergey Nuyanzin · 2 weeks ago
  77. 00f22d1 [FLINK-39750][tests] Drop `FailsOnJava11` by Sergey Nuyanzin · 2 weeks ago
  78. 0b1da64 [FLINK-39755][tests] `RuntimeOpenRestAPIDocsCompletenessITCase` fails for jdk 21+ by Sergey Nuyanzin · 2 weeks ago
  79. 17216ce [hotfix][docs] Fix duplicate word typos in documentation by jhanishant260 · 2 weeks ago
  80. 8177d66 [FLINK-39619][docs] Add release notes for Flink 2.3 by Hao Li · 2 weeks ago
  81. f3ffe4e [FLINK-39738] Use pekko ask() instead of tell() to ack the checkpoint by Roman Khachatryan · 1 year, 2 months ago
  82. bf545fe [FLINK-39746][build] Add jdk25 profile in `common_docker.sh` by Sergey Nuyanzin · 3 weeks ago
  83. 8d83511 [FLINK-39720][table] SubQueryDecorrelator produces incorrect plans for correlated EXISTS with HAVING on aggregate outputs by lincoln lee · 3 weeks ago
  84. 6f42251 [hotfix][table/runtime] Fix RowDataKeySerializerSnapshot.resolveSchemaCompatibility() by Roman Khachatryan · 3 months ago
  85. 198ea6a [hotfix][table/runtime] Remove redundant state access in LinkedMultiSetState.add by Roman Khachatryan · 3 months ago
  86. f08eb43 [FLINK-39740][table/runtime] Fix highSqn update in LinkedMultiSetState.add by Roman Khachatryan · 3 months ago
  87. 91e58c2 [FLINK-39742][tests] FlinkImageBuilder checks for Java 25 by Sergey Nuyanzin · 3 weeks ago
  88. 4f8b4a8 [FLINK-39695][table] Outer join on nested field fails with conversion to relational algebra failed to preserve datatypes by Sergey Nuyanzin · 3 weeks ago
  89. e68a488 [FLINK-39736][build] Do not allow Security Manager for jdk24+ by Sergey Nuyanzin · 3 weeks ago
  90. e62e227 [FLINK-39734][ci] Exclude 2.1 and 2.2 from GHA nightly by Sergey Nuyanzin · 3 weeks ago
  91. 67fffa2 [FLINK-39733][build] Do not use `net.jcip.annotations` by Sergey Nuyanzin · 3 weeks ago
  92. 239e73e [FLINK-39156][docs] Document ON CONFLICT by Dawid Wysakowicz · 3 weeks ago
  93. 2741d96 [FLINK-39729][table] Fix flaky CorrelateRestoreTest by using materialized data assertion by Jim Hughes · 3 weeks ago
  94. 92ec61e [FLINK-39731][table] Port from Calcite fix for `SqlValidatorImpl` should reject `MATCH_RECOGNIZE` with duplicate `MEASURE` by Sergey Nuyanzin · 3 weeks ago
  95. 3ac4da3 [hotfix] Fix compiliation for java 11 (#28225) by Sergey Nuyanzin · 3 weeks ago
  96. 8ffb499 [hotfix][doc] Add flink-s3-fs-native in AGENTS.md by Samrat · 3 weeks ago
  97. cd34cf9 [FLINK-39708][table] Support TO_CHANGELOG retract/upsert stream -> upsert stream with set semantics (#28199) by Gustavo de Morais · 3 weeks ago
  98. 8347215 [FLINK-39709][s3]Update documentation for native-s3 Implementation (#28200) by Samrat · 3 weeks ago
  99. 9ea7601 [hotfix][docs] Fix incorrect HashMapStateBackend recommendations (#28094) by Dennis-Mircea Ciupitu · 3 weeks ago
  100. a9c40d3 [hotfix] Disable CAST with FORMAT as not supported yet by Sergey Nuyanzin · 4 weeks ago