1. be1da48 [FLINK-22944][state] Re-use output in StateChangeLogger by Roman Khachatryan · 11 days ago master
  2. 032f467 [FLINK-22944][state] Optimize writing changelog by Roman Khachatryan · 11 days ago
  3. 475a662 [FLINK-24168][table-planner] Update MATCH_ROWTIME function which could receive 0 argument or 1 argument by Jing · 11 days ago
  4. aa1cdd0 [FLINK-24287][python][tests] Update grpcio version in tox.ini (#17301) by Dian Fu · 2 days ago
  5. 7c8fefa [FLINK-24300] SourceOperator#getAvailableFuture reuses future by Dawid Wysakowicz · 3 days ago
  6. 7bacef0 [FLINK-24233][runtime] Ignore message about new buffer size if the reader doesn't ready yet by Anton Kalashnikov · 10 days ago
  7. 82d1dae [Hotfix][streaming] Fix a typo. by Roc Marshal · 5 days ago
  8. e18d273 [FLINK-24129][connectors-pulsar] Harden TopicRangeTest.rangeCreationHaveALimitedScope. by David Moravek · 14 days ago
  9. 0bbc91a [FLINK-24248][docs]update Gradle dependency by Daisy T · 6 days ago
  10. 8664b36 [hotfix][connectors/kafka] Rename EventDeSerializer to EventDeSerializationSchema in examples by Fabian Paul · 4 days ago
  11. a83f8f4 [FLINK-24292][connectors/kafka] Use KafkaSink in examples instead of FlinkKafkaProducer by Fabian Paul · 5 days ago
  12. 4a89552 [FLINK-24281][connectors/kafka] Migrate all format tests from FlinkKafkaProducer to KafkaSink by Fabian Paul · 5 days ago
  13. f82b2a9 [FLINK-24281][connectors/kafka] Only allow KafkaSinkBuilder creation with KafkaSink.builder() by Fabian Paul · 4 days ago
  14. f763706 [hotfix][connectors/kafka] Remove unused code from KafkaDynamicSink by Fabian Paul · 5 days ago
  15. 8debdd0 [FLINK-24317][python][tests] Optimize the implementation of Top2 in test_flat_aggregate by huangxingbo · 3 days ago
  16. 3b6b522 [FLINK-11250][runtime] Added method init for RecordWriter for initialization resources(OutputFlusher) outside of constructor (#17187) by Anton Kalashnikov · 3 days ago
  17. 164a59a [FLINK-23180] Do not initialize checkpoint base locations when checkpointing is disabled by Jiayi Liao · 3 days ago
  18. c643241 [FLINK-16203][table] Support JSON_OBJECT by Ingo Bürk · 12 days ago
  19. b30fdef [hotfix] Handle ANY during type inference by Ingo Bürk · 6 days ago
  20. 0fb8db5 [hotfix] remove duplicate case by Ingo Bürk · 6 days ago
  21. 7a6bca8 [hotfix] Make all converters @Internal by Ingo Bürk · 7 days ago
  22. 463a7d4 [hotfix] Remove unused JsonUtils by Ingo Bürk · 7 days ago
  23. f0be546 [hotfix] Introduce InputTypeStrategies#repeatingSequence by Ingo Bürk · 12 days ago
  24. cd08b4b [hotfix] Relax condition for argument count by Ingo Bürk · 12 days ago
  25. 4090a06 [hotfix] Proxy SplitContext#isArgumentNull correctly by Ingo Bürk · 12 days ago
  26. b608620 [FLINK-23969][connector/pulsar] Create e2e tests for pulsar connector. by syhily · 6 days ago
  27. d18911d [hotfix] Fix a typo in 'estimatedTimeToConsume(r)BuffersMs' by Dawid Wysakowicz · 4 days ago
  28. 5165205 [FLINK-24133][core] Network failure test replaced by comment in the code due to high expense of stabilizing such low important test by Anton Kalashnikov · 5 days ago
  29. 7487c30 [FLINK-24305][python] Limit the protobuf version<3.18 by huangxingbo · 4 days ago
  30. 647103c [FLINK-24218][docs-zh] Translate "UNLOAD Statements" page of "SQL" into Chinese (#17222) by hapihu · 4 days ago
  31. 583e20d [FLINK-24234][connectors] Time based flushing for AsyncSinkWriter by Zichen Liu · 11 days ago
  32. de36259 [FLINK-24234][connectors] Added byte based flushing for AsyncSinkWriter by Zichen Liu · 12 days ago
  33. 2da73ed [FLINK-24277][connector/kafka] Add OffsetsInitializerValidator interface for validating offset initializer in KafkaSourceBuilder by Qingsheng Ren · 6 days ago
  34. f3ef860 [FLINK-24277][connector/kafka] Remove auto-generated group id in Kafka table source by Qingsheng Ren · 6 days ago
  35. ca8bff2 [FLINK-24277][connector/kafka] Add configuration for committing offset on checkpoint and disable it if group ID is not specified by Qingsheng Ren · 6 days ago
  36. 6f07196 [FLINK-24217][docs-zh] Translate "LOAD Statements" page of "SQL" into Chinese (#17221) by hapihu · 5 days ago
  37. 113956f [hotfix][docs] Add glossary entry for 'Table program' by Timo Walther · 6 days ago
  38. 1f17e33 [FLINK-21589][docs] Document table pipeline upgrades by Timo Walther · 6 days ago
  39. f366f77 [FLINK-24139][table-planner] Push down more predicates through Join in stream mode by xuyang · 6 days ago
  40. 2ae7106 [FLINK-24282][connectors/kafka] Make topic selector for KafkaSink serializable by Fabian Paul · 5 days ago
  41. 724fb3d [FLINK-24283][connector/pulsar] Use stick key consumer in Key_Shared subscription. This would make sure Pulsar won't treat the flink reader as a shared consumer. by syhily · 5 days ago
  42. f74db4b [FLINK-22275][table] Support random past for timestamp types in datagen connector (#15703) by Yi Tang · 5 days ago
  43. d92540c [FLINK-23607][state/changelog] Document checkpointing.changelog in pom.xml by Roman Khachatryan · 4 weeks ago
  44. f224ae7 [FLINK-23607][state/changelog] Cleanup dependencies of DSTL DFS by Roman Khachatryan · 4 weeks ago
  45. 13ef5ac [FLINK-23607][state/changelog] Make Changelog Backend a transitive dependency by Roman Khachatryan · 4 weeks ago
  46. 2815aad [hotfix][docs] Fix output of test job by Marios Trivyzas · 6 days ago
  47. 94d0bea [FLINK-24266][checkpoint] Log improvement for aborting checkpoint due to tasks are finishing by Yun Gao · 7 days ago
  48. 96887f7 [hotfix][connector] Use null to replace empty pending transaction in 2pc sink by Yun Gao · 7 days ago
  49. cc2ebe5 [FLINK-24276][python] Avoid confusing output when executing in loopback mode by huangxingbo · 6 days ago
  50. e4b2f0c [FLINK-24267][python][docs] Update the example tutorial to use latest API by Dian Fu · 6 days ago
  51. 94c5077 [FLINK-24219][docs-zh] Translate "SET Statements" page of "SQL" into Chinese (#17223) by hapihu · 6 days ago
  52. d532f5f [FLINK-24212][k8s]fix the problem that kerberos krb5.conf file is mounted as empty directory, not the expected file by sammieliu · 11 days ago
  53. 5474f89 [FLINK-24206][connector/pulsar] Close the pulsar client properly. by syhily · 7 days ago
  54. c81b831 [hotfix][docs] Adding new sources on overview pages by martijnvisser · 6 days ago
  55. 6899a44 [hotfix][table] REGEXP_EXTRACT return type should always be nullable by slinkydeveloper · 9 days ago
  56. 8d94540 [FLINK-24098] Document FLIP-147 capabiliites and limitations by Dawid Wysakowicz · 2 weeks ago
  57. a9448d2 [FLINK-24243][python] Cleanup code to use latest API to avoid warnings by Dian Fu · 10 days ago
  58. 7901f26 [FLINK-23458][docs] Added the network buffer documentation along with the buffer debloat doc by Anton Kalashnikov · 4 weeks ago
  59. 0313c40 [FLINK-24221][docs-zh] Translate "JAR Statements" page of "SQL" into Chinese (#17225) by hapihu · 7 days ago
  60. a6fc9d1 [FLINK-24245][python] Fix the problem caused by multiple jobs sharing the loopback mode address stored in the environment variable in PyFlink by huangxingbo · 10 days ago
  61. 4ea9908 [FLINK-24184][task] Introduce lock to guard against race conditions around shouldInterruptOnCancel by Piotr Nowojski · 10 days ago
  62. 77f10a5 [FLINK-24043][runtime] Reuse the code of 'check savepoint preconditions'. by Roc Marshal · 3 weeks ago
  63. 33641f5 [FLINK-24220][doc]Translate "RESET Statements" page of "SQL" into Chinese (#17224) by hapihu · 7 days ago
  64. 9f1c2d8 [FLINK-24244][python] Logging whether it's executed in loopback mode by Dian Fu · 10 days ago
  65. e3d7167 [FLINK-18880][python] Respect configurations defined in flink-conf.yaml and environment variables when executing in local mode by Dian Fu · 11 days ago
  66. fdf40d2 [FLINK-24065][connector] Upgrade the state of TwoPhaseCommitSink to support empty transaction after finished by Yun Gao · 3 weeks ago
  67. ed3b613 [hotfix] Improve language for error message when checkpoint is declined due to some tasks being finished already. by Stephan Ewen · 3 weeks ago
  68. d79bb47 [FLINK-23864][docs] Add pulsar connector document (Chinese & English). by Yufan Sheng · 10 days ago
  69. 2e9d4e6 [FLINK-23864][connector/pulsar] Remove PULSAR_AUTO_UPDATE_PARTITIONS option. by Yufan Sheng · 10 days ago
  70. f8c1c63 [FLINK-23864][connector/pulsar] Release Pulsar Message if user enable poolMessage option. by Yufan Sheng · 10 days ago
  71. 172e645 [FLINK-23864][docs] Add flink-connector-pulsar module to flink-docs, auto generate the config document. by Yufan Sheng · 10 days ago
  72. f5ef5ae [FLINK-24161] Fix interplay of stop-with-savepoint w/o drain with final checkpoints by Dawid Wysakowicz · 11 days ago
  73. fb5d1b8 [FLINK-24123][python] Optimize the python operator instances of the same job to share one python environment resources in the same jvm by huangxingbo · 13 days ago
  74. d93682c [FLINK-22603][table-planner] The digest can be produced by SourceAbilitySpec by xuyang · 12 days ago
  75. 412c45f [FLINK-23944][connector/pulsar] Enable PulsarSourceITCase.testTaskManagerFailure after test framework was fixed. by Yufan Sheng · 11 days ago
  76. 0cecdca [FLINK-23345][python] Limits the version requests to 2.26.0 or above by Dian Fu · 10 days ago
  77. 713f066 [hotfix][connectors] Deduplicate config default in FutureCompletingBlockingQueue. by Stephan Ewen · 10 days ago
  78. c28dd94 [FLINK-22358][connector base] Add stability annotations to connector base and iterator sources. by Stephan Ewen · 5 months ago
  79. d666d2a [hotfix][core] Improve/fix JavaDocs in SplitEnumeratorContext class. by Stephan Ewen · 10 days ago
  80. e4b0008 [FLINK-22357][core] Upgrades API stability of unified source API to @Public (= stable). by Stephan Ewen · 5 months ago
  81. 76ee66f [FLINK-24041][connectors] First draft of API, uses FLIP-143: Unified Sink API, Increase robustness for flush, Add license header, Update JavaDoc comments, added unit and integration tests for the generic sink implementation. Corrected an inconsistency that led to prepareCommit() not fully flushing the entire contents of the buffer at checkpoint time, removed catching of RuntimeExceptions in concrete implementations, added @PublicEvolving to classes, rearranged cosmetics of classes, corrected spelling errors, changed tests to reflect removal of RuntimeException, added checks on the parameters passed to AsyncSinkWriter at construction time, simplified batch creation part of Sink, amended tests, and test harness now guarantees ordering, added Javadoc for AsyncSinkWriter, removed redundant flushIfFull, removed duplicate assertion, removed redundant overriding in SinkInitContext, refactored static class into anonymous function, cleaned up imports, all test methods now begin with "test", refactored duplication in tests, Fixed spelling error, removed ResultFuture and all references to this construct, Now using Consumer<T> to accept requeue candidates by Zichen Liu · 11 days ago
  82. ff713a8 [FLINK-23836][doc-zh] Translate "Execution Configuration" page into Chinese (#16865) by hapihu · 10 days ago
  83. 2e721ab [FLINK-24213][qs] Use single lock in ServerConnection by Chesnay Schepler · 11 days ago
  84. b5ac92e [FLINK-24213][qs] Introduce factory for established connection by Chesnay Schepler · 11 days ago
  85. 0b4855f [FLINK-24137][python] Fix the issue that tests planned to run in process mode was actually executed in loopback mode by Dian Fu · 11 days ago
  86. 7a1b2b3 [FLINK-24137][python] Fix the cases that Python boot process exits before Python SDK harness connects to the Java Operator in lookback mode by Dian Fu · 11 days ago
  87. 60046b1 [FLINK-24199][python] Expose StreamExecutionEnvironment#configure in Python API by SteNicholas · 11 days ago
  88. 1980481 [FLINK-23462] [docs-zh] Translate the abfs documentation to chinese by LB-Yu · 5 weeks ago
  89. c69193b [FLINK-24031] Extend vcs.xml by Chesnay Schepler · 11 days ago
  90. a1a645a [FLINK-24155][documentation] Sync Chinese version of documentation to configure CheckpointFailureManager (#17173) by Yuan Mei · 11 days ago
  91. 69fefdd [hotfix][rest][tests] Cleanup by Chesnay Schepler · 12 days ago
  92. 8081dfb [FLINK-24193][rest][tests] Migrate tests to ClassLoaderExtension by Chesnay Schepler · 12 days ago
  93. a5e83af [FLINK-24193][tests] Add ClassLoaderExtension by Chesnay Schepler · 12 days ago
  94. 16ab8b4 Revert "[FLINK-24041][connectors] First draft of API, Add DynamoDB sink to verify API, Add Firehose sink, Refactor to use FLIP-143: Unified Sink API, Increase robustness for flush, Add license header, Update JavaDoc comments" by Piotr Nowojski · 11 days ago
  95. 1702c9e Revert "[FLINK-24041][connectors] Added unit and integration tests for the generic sink implementation. Corrected an inconsistency that led to prepareCommit() not fully flushing the entire contents of the buffer at checkpoint time, removed catching of RuntimeExceptions in concrete implementations, added @PublicEvolving to classes, rearranged cosmetics of classes, corrected spelling errors, changed tests to reflect removal of RuntimeException, added checks on the parameters passed to AsyncSinkWriter at construction time, simplified batch creation part of Sink, amended tests, and test harness now guarantees ordering, added Javadoc for AsyncSinkWriter, removed redundant flushIfFull, removed duplicate assertion, removed redundant overriding in SinkInitContext, refactored static class into anonymous function, cleaned up imports, all test methods now begin with "test", refactored duplication in tests, Fixed spelling error, removed ResultFuture and all references to this construct. Now using Consumer<T> to accept requeue candidates" by Piotr Nowojski · 11 days ago
  96. d4c483f [FLINK-24059][Connectors/Common][test] Allow SourceReaderTestBase.NUM_SPLITS to be overridden (#17064) by Brian Zhou · 11 days ago
  97. 125cb70 [FLINK-24196][docs-zh] Translate "EXPLAIN Statements" page of "SQL" into Chinese (#17195) by hapihu · 11 days ago
  98. 7b43677 [FLINK-24195][docs-zh] Translate "DESCRIBE Statements" page of "SQL" into Chinese (#17192) by hapihu · 11 days ago
  99. 271a346 [FLINK-24041][connectors] Added unit and integration tests for the generic sink implementation. Corrected an inconsistency that led to prepareCommit() not fully flushing the entire contents of the buffer at checkpoint time, removed catching of RuntimeExceptions in concrete implementations, added @PublicEvolving to classes, rearranged cosmetics of classes, corrected spelling errors, changed tests to reflect removal of RuntimeException, added checks on the parameters passed to AsyncSinkWriter at construction time, simplified batch creation part of Sink, amended tests, and test harness now guarantees ordering, added Javadoc for AsyncSinkWriter, removed redundant flushIfFull, removed duplicate assertion, removed redundant overriding in SinkInitContext, refactored static class into anonymous function, cleaned up imports, all test methods now begin with "test", refactored duplication in tests, Fixed spelling error, removed ResultFuture and all references to this construct. Now using Consumer<T> to accept requeue candidates by Zichen Liu · 4 weeks ago
  100. 2e33a40 [FLINK-24041][connectors] First draft of API, Add DynamoDB sink to verify API, Add Firehose sink, Refactor to use FLIP-143: Unified Sink API, Increase robustness for flush, Add license header, Update JavaDoc comments by Steffen Hausmann · 5 months ago