Google Git
Sign in
apache/flink/HEAD
  1. 2245026 [FLINK-40447][table] Fall back to retract when input upsert key is empty or mixed by Gustavo de Morais · 15 hours ago master
  2. 9ee1037 [FLINK-40390][table] Optimised JSON_LENGTH codegen by Vasudev Kelappassery · 2 days ago
  3. 9c10153 [FLINK-40446][tests] Make CommonTestUtils.terminateJob wait for the CANCELED terminal state by Rui Fan · 2 days ago
  4. 80a5b18 [FLINK-40383][docs] Reorder Glossary entries alphabetically (#28969) by Lorenzo Nicora · 2 days ago
  5. a55e73d [FLINK-40415][python] Fix Python 3.9 dependency conflict of grpcio-tools (#28992) by Dian Fu · 2 days ago
  6. 0ba476f [FLINK-40428][table] Drop Calcite's `LogicalSnapshot` by Sergey Nuyanzin · 2 days ago
  7. 3b2a93b [FLINK-39786][s3]closeForCommit() leaks orphan multipart uploads on upload failure (#28951) by Samrat · 3 days ago
  8. 8540dcb [FLINK-40410][table-planner] Exclude VARIANT from constant folding by Moritz Manner · 3 days ago
  9. df122f5 [FLINK-39546][s3] Improve observability in flink-s3-fs-native by exposing operation-level S3 metrics by Samrat · 3 days ago
  10. 49a391c [hotfix][python] Bump io.opentelemetry:opentelemetry-api from 1.57.0 to 1.62.0 (#28983) by dependabot[bot] · 3 days ago
  11. 2b9453a [FLINK-40335][runtime] Fix Hybrid Shuffle index corruption caused by shared ByteBuffer by Mate Czagany · 3 days ago
  12. d7207f5 [FLINK-40387][s3] Add option to disable S3 SDK retry circuit breaker by Gabor Somogyi · 4 days ago
  13. b810155 [FLINK-40300][python] Fix literal expression in Python Table API (#28924) by Liu Liu · 4 days ago
  14. ffd8d88 [FLINK-40190][python] Introduce PyFlink DataFrame creation and conversion APIs (#28934) by Liu Liu · 4 days ago
  15. aa30930 [FLINK-38469][python] Bump Apache Beam to 2.75 (#28059) by florianvazelle · 5 days ago
  16. 696e6b2 [FLINK-40199][python] Add generic DataFrame I/O methods (#28974) by Liu Liu · 5 days ago
  17. 02a61e6 [hotfix][ci] Bump `github-script` to v9 in `action.yml` by Sergey Nuyanzin · 7 days ago
  18. 3c930cb [FLINK-40391][table] PTF with non default convertion-class of table arg might fail by Sergey Nuyanzin · 8 days ago
  19. dc256f3 [FLINK-40268][table] Add new JSON_TYPE built-in function by Vasudev Kelappassery · 8 days ago
  20. 3775f87 [hotfix][docs] Add feature-flag review guidelines to AGENTS.md by Roman Khachatryan · 2 weeks ago
  21. 2b97852 [FLINK-32212][runtime] Match library BLOBs by content in BlobLibraryCacheManager (#27579) by Natea Eshetu Beshada · 8 days ago
  22. 969ea74 [FLINK-40346][model-triton] Preserve null array elements when deserializing Triton responses (#28947) by Sepuri Sai Krishna · 8 days ago
  23. 7b84e3f [FLINK-40191][python] Add aggregation support to PyFlink DataFrame API (#28937) by Liu Liu · 8 days ago
  24. 2f3c205 [FLINK-40081][test] Add CdrRecoveryRaceITCase for the non-source recovery race by Roman Khachatryan · 7 weeks ago
  25. 516a8f9 [FLINK-40081] Harden RecordFilterContext for minimal and batch environments by Rui Fan · 7 weeks ago
  26. d9f5e05 [FLINK-40080][network] Remove the unbounded heap fallback from RecoveredInputChannel#requestBufferBlocking by Rui Fan · 7 weeks ago
  27. af146b6 [FLINK-40080] Switch flag-on recovery to fetch->drain; retire the in-memory backend by Rui Fan · 7 weeks ago
  28. 46ad84a [FLINK-40080][checkpoint] FetchedChannelStateDrainer: incremental drain with atomic snapshot-and-insert by Rui Fan · 7 weeks ago
  29. ddeb17e [FLINK-40080][checkpoint] ChannelStateWriter#addInputDataFromSpill: replay spilled segments into the checkpoint by Rui Fan · 7 weeks ago
  30. 41f2cdb [FLINK-40386][checkpoint] Log which channel state recovery path is taken and its progress by Rui Fan · 9 days ago
  31. 0c57688 [FLINK-40376][formats] Support `VARIANT` type in `flink-json` converters by Ferenc Csaky · 9 days ago
  32. 0a2bad7 [FLINK-40271][table] Fix SQL serialization of Table API group window properties by Timo Theusner · 9 days ago
  33. 3871786 [FLINK-25802][FLINK-30499][table] Fix TIMESTAMP codegen for `RANGE OVER` window bounds by Aleksandr Iushmanov · 9 days ago
  34. bb0163d [FLINK-40056][python][docs] Upgrade Sphinx to 7.4 for flink-python docs by Zihao Chen · 7 weeks ago
  35. 70aabf6 [FLINK-40334][table] Insert-only input should stay unmaterialized under FORCE by Gustavo de Morais · 10 days ago
  36. 1aaf0f2 [hotfix][ci] Add parallel execution to Maven compile options by Sergey Nuyanzin · 11 days ago
  37. 946c276 [FLINK-40377][table] `MatchRecognize` fails with Unsupported `RelDataType`: `UNKNOWN` while json plan generation by Sergey Nuyanzin · 10 days ago
  38. de793af [FLINK-40373][table] `JSON_VALUE` might fail on code gen for null input by Sergey Nuyanzin · 10 days ago
  39. dfa83ab [FLINK-40208] Add test coverage and blank-key validation for JobMdcRegistry by Aleksandr Iushmanov · 3 weeks ago
  40. 0b5cb41 [FLINK-39524][checkpoint] Forward-only spill reader with snapshot/resume by Rui Fan · 7 weeks ago
  41. 86099d0 [FLINK-39524][checkpoint] Rewrite ChannelStateFilteringHandler to emit into a spill segment by Rui Fan · 7 weeks ago
  42. 227805b [FLINK-39524][checkpoint] Spill-writing handlers: segmented on-disk format by Rui Fan · 7 weeks ago
  43. 71a0019 [FLINK-39524][checkpoint] Add FetchedChannelState spill-file container by Rui Fan · 7 weeks ago
  44. 9501264 [FLINK-40363][table] Make `MiscSemanticTests#COALESCE_NESTED_ROW_LEFT_JOIN` more stable by Sergey Nuyanzin · 11 days ago
  45. 077234b [hotfix][tests] Add `computeDigest` to `DummyStructuredType` by Sergey Nuyanzin · 11 days ago
  46. b47ae1a [FLINK-40361][ci] Extract license check into a separate job by Sergey Nuyanzin · 11 days ago
  47. 21567fb [FLINK-40170][table-planner] Infer update-producing changelog mode for early-fire interval join (#28877) by Weiqing Yang · 12 days ago
  48. d265215 [FLINK-40200][Checkpoint] Checkpoint sync phase timeout by Efrat Levitan · 5 weeks ago
  49. 13e1709 [FLINK-39014][table] Fix the conversion to relational algebra issue in Batch Mode (#28500) by Archit Goyal · 2 weeks ago
  50. 75d978e [FLINK-40169][table] Add target option to the EARLY_FIRE hint (#28827) by Weiqing Yang · 2 weeks ago
  51. 01c950f [FLINK-39771][tests][JUnit5 migration] Module: flink-cep by Purushottam Sinha · 2 weeks ago
  52. 4e3061e [hotfix][ci] Bump GitHub script action to version 9 by Sergey Nuyanzin · 2 weeks ago
  53. 23d7380 [FLINK-40345][checkpoint] Do not recycle the failed buffer twice in FilteringHandler by Rui Fan · 2 weeks ago
  54. bbde1d5 [FLINK-39900][forst] Add configuration option for setting the number of ForSt transfer threads by Francis · 2 weeks ago
  55. 8ec1b0b [FLINK-40326][core] Do not over-grant capacity in GatedRateLimiter by Aleksandr Savonin · 3 weeks ago
  56. 79b4843 [FLINK-40339][table] Do not read buffer entries after removing them by Gustavo de Morais · 2 weeks ago
  57. 7232ad9 [FLINK-39984][runtime][webUI] Support LITE/FULL thread dump modes by xingsuo-zbz · 5 weeks ago
  58. 90dcc69 [FLINK-40089][table] Add new JSON_LENGTH built-in function by Vasudev Kelappassery · 2 weeks ago
  59. 5eb36d4 [FLINK-40270][connector-base][runtime] Make source threads job-attributable via MDC propagation and thread names by Aleksandr Savonin · 3 weeks ago
  60. cf2df29 [FLINK-40332][table] Prevent path traversal in FileCatalogStore catalog names by Gabor Somogyi · 2 weeks ago
  61. 33a198a [FLINK-40305][core] Decode `VARIANT` strings and object keys as UTF-8 by Ramin Gharib · 2 weeks ago
  62. e095557 [FLINK-18476][python] `PythonEnvUtils#testStartPythonProcess` might fail by Sergey Nuyanzin · 2 weeks ago
  63. 5d91e07 [FLINK-40324][table] Append-only should stay unmaterialized without an ON CONFLICT clause by Gustavo de Morais · 2 weeks ago
  64. c1133c3 [FLINK-40322][python] Fix Array/Multiset from_sql_type to decode elements (#28912) by Nikolaus Schuetz · 2 weeks ago
  65. 3c8740f [hotfix][docs] Add code review guidelines to AGENTS.md by Roman Khachatryan · 3 weeks ago
  66. 6d8ce98 [FLINK-40284][tests] Archunit should fail in case of tests not matching name requirements by Sergey Nuyanzin · 3 weeks ago
  67. 2111b41 [FLINK-40284][tests] Make tests ending with `Tests` executing in CI by Sergey Nuyanzin · 3 weeks ago
  68. a357106 [FLINK-40307][table] `RestoreTestCompleteness` was never executed in CI by Sergey Nuyanzin · 3 weeks ago
  69. e700705 [FLINK-40310][tests] Rename `CsvBulkWriterIT` to `CsvBulkWriterTest` by Sergey Nuyanzin · 3 weeks ago
  70. bd1becc [FLINK-40311][tests] Rename `EndiannessAccessChecks` to `EndiannessAccessChecksTest` by Sergey Nuyanzin · 3 weeks ago
  71. 17c70e8 [hotfix][ci] Add ignore pattern in case of Azure by Sergey Nuyanzin · 3 weeks ago
  72. ae9449e [FLINK-40317][tests] Make DeletesByKeySemanticTests more stable by Sergey Nuyanzin · 3 weeks ago
  73. 12197ea [FLINK-40285][table] `MLPredictSemanticTests` fails because of `ON CONFLICT` by Sergey Nuyanzin · 3 weeks ago
  74. ea80169 [FLINK-40236][python] Fix _infer_type inferring array element type with a leading None (#28819) by Nikolaus Schuetz · 3 weeks ago
  75. 1b1258e3 [hotfix][python] Bump soupsieve from 2.8.3 to 2.8.4 (#28812) by dependabot[bot] · 3 weeks ago
  76. 6e57cc5 [FLINK-40256][docs] Include sub-package config options in the configuration reference by Purushottam Sinha · 3 weeks ago
  77. 77a017a [FLINK-40288][table] Use correct type in `ExprCodeGenerator#visitFieldAccess` by Sergey Nuyanzin · 3 weeks ago
  78. 77c47c8 [FLINK-40283][tests] Rename `CorrelateITCase2` to `Correlate2ITCase` to make executing while CI/local tests by Sergey Nuyanzin · 3 weeks ago
  79. 0b66c7e [FLINK-40286][table] Adapt keyless upsert sink should fall back to retract to `MiscSemanticTests` by Sergey Nuyanzin · 3 weeks ago
  80. 0910fc9 [FLINK-40187][python] Introduce DataType class in DataFrame API (#28843) by Liu Liu · 3 weeks ago
  81. 7835844 [FLINK-40168][table] Thread the EARLY_FIRE hint into the interval join by weiqingy · 5 weeks ago
  82. 9f867da [FLINK-40269][runtime] Fix channel state assignment for duplicate connections by Rui Fan · 3 weeks ago
  83. 7737014 [FLINK-40269][tests] Add same-upstream unaligned rescale ITCase by Rui Fan · 3 weeks ago
  84. e19fd02 [FLINK-39984][runtime] Dispatch thread dump to ioExecutor by xingsuo-zbz · 4 weeks ago
  85. b806823 [FLINK-40267][table-planner] Validate persisted columns on CREATE MATERIALIZED TABLE by Arvid Heise · 3 weeks ago
  86. d07664d [FLINK-40272][build] Add cache file for checkstyle by Sergey Nuyanzin · 3 weeks ago
  87. c0e8939 FLINK-40233][table] Correctly share the parsed JSON across `JSON_VALUE`/`JSON_QUERY` calls when the owning call is skipped because of `NULL` or not taken branch by Sergey Nuyanzin · 3 weeks ago
  88. bb8599f Revert "[FLINK-39900][forst] Add configuration option for setting the number of ForSt transfer threads (#28373)" by Sergey Nuyanzin · 3 weeks ago
  89. e1125e3 [FLINK-39490][web] Improve feedback when cluster is unreachable (#27971) by Purushottam Sinha · 3 weeks ago
  90. 01a5a7f [FLINK-39900][forst] Add configuration option for setting the number of ForSt transfer threads (#28373) by Francis · 3 weeks ago
  91. 2779964 [FLINK-40208] Add Logging Context (MDC) operational docs by Aleksandr Iushmanov · 3 weeks ago
  92. e634a6f [FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment by Aleksandr Iushmanov · 4 weeks ago
  93. 43bb871 [FLINK-40227][core] Use `readFully` to read `Variant` value/metadata in `VariantSerializer.deserialize` by Yuhan Hao · 3 weeks ago
  94. 6ce8519 [hotfix][docs] Make the `Generated-by:` line visible in the PR template by Aleksandr Savonin · 3 weeks ago
  95. b662ad8 [FLINK-40254][docs] Document checkpoint behavior after a CLAIM-mode restore from a NATIVE savepoint by Aleksandr Savonin · 3 weeks ago
  96. 755671f Revert "[FLINK-40208] Add Logging Context (MDC) operational docs" by Roman Khachatryan · 3 weeks ago
  97. 07a4ba9 Revert "Revert "Revert "[FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment""" by Roman Khachatryan · 3 weeks ago
  98. 3d23bdf Revert "Revert "[FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment"" by Roman Khachatryan · 3 weeks ago
  99. d0ce9ea Revert "[FLINK-40208] Add JobMdcRegistry for config-driven MDC enrichment" by Roman Khachatryan · 3 weeks ago
  100. ef6633f [FLINK-40208] Add Logging Context (MDC) operational docs by Aleksandr Iushmanov · 3 weeks ago