You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by ak...@apache.org on 2023/01/28 02:56:40 UTC

[hudi] branch master updated (1ecc0401eef -> ff590c6d72c)

This is an automated email from the ASF dual-hosted git repository.

akudinkin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


    from 1ecc0401eef [HUDI-5623] Increase default time to wait between retries by lock provider client (#7758)
     add ff590c6d72c [HUDI-5023] Switching default Write Executor type to `SIMPLE` (#7476)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/hudi/config/HoodieWriteConfig.java  | 48 +++++++++++---------
 .../hudi/execution/HoodieLazyInsertIterable.java   | 30 +++++++------
 .../java/org/apache/hudi/util/ExecutorFactory.java | 24 +++++-----
 .../hudi/execution/FlinkLazyInsertIterable.java    |  2 +-
 .../hudi/execution/JavaLazyInsertIterable.java     |  2 +-
 .../hudi/execution/SparkLazyInsertIterable.java    |  2 +-
 .../TestBoundedInMemoryExecutorInSpark.java        | 28 ++++++------
 .../hudi/execution/TestBoundedInMemoryQueue.java   | 23 ++++++----
 .../execution/TestDisruptorExecutionInSpark.java   | 48 ++++++++++----------
 .../hudi/execution/TestDisruptorMessageQueue.java  | 30 +++++++------
 .../hudi/execution/TestSimpleExecutionInSpark.java | 51 +++++++++-------------
 .../common/util/queue/BoundedInMemoryExecutor.java |  2 +-
 .../hudi/common/util/queue/DisruptorExecutor.java  | 19 +++++---
 .../common/util/queue/DisruptorMessageQueue.java   | 18 +++++---
 .../hudi/common/util/queue/ExecutorType.java       | 15 +------
 ...mpleHoodieExecutor.java => SimpleExecutor.java} | 51 ++++++++++------------
 .../common/util/queue/WaitStrategyFactory.java     |  8 ++--
 17 files changed, 200 insertions(+), 201 deletions(-)
 rename hudi-common/src/main/java/org/apache/hudi/common/util/queue/{SimpleHoodieExecutor.java => SimpleExecutor.java} (53%)