You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by si...@apache.org on 2022/03/28 21:05:43 UTC

[hudi] branch master updated (6ccbae4 -> d074089)

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

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


    from 6ccbae4  [HUDI-2757] Implement Hudi AWS Glue sync (#5076)
     add d074089  [HUDI-2566] Adding multi-writer test support to integ test (#5065)

No new revisions were added by this update.

Summary of changes:
 ...e-deltastreamer.yaml => multi-writer-1-ds.yaml} |  25 +--
 .../{test.properties => multi-writer-1.properties} |  17 +-
 ...w-spark-simple.yaml => multi-writer-2-sds.yaml} |  26 +--
 .../{test.properties => multi-writer-2.properties} |  17 +-
 ....properties => multi-writer-local-1.properties} |  23 +-
 ....properties => multi-writer-local-2.properties} |  23 +-
 .../hudi/config/metrics/HoodieMetricsConfig.java   |   2 +-
 .../testsuite/HoodieMultiWriterTestSuiteJob.java   | 241 +++++++++++++++++++++
 .../hudi/integ/testsuite/HoodieTestSuiteJob.java   |  37 +++-
 .../testsuite/configuration/DFSDeltaConfig.java    |  10 +-
 .../hudi/integ/testsuite/dag/WriterContext.java    |   2 +-
 .../hudi/integ/testsuite/dag/nodes/DeleteNode.java |   2 +-
 .../hudi/integ/testsuite/dag/nodes/InsertNode.java |   2 +-
 .../hudi/integ/testsuite/dag/nodes/UpsertNode.java |   2 +-
 .../integ/testsuite/generator/DeltaGenerator.java  |  61 +++---
 .../testsuite/dag/nodes/SparkBulkInsertNode.scala  |   2 +-
 .../testsuite/dag/nodes/SparkDeleteNode.scala      |  34 +--
 .../testsuite/dag/nodes/SparkInsertNode.scala      |  31 ++-
 .../testsuite/dag/nodes/SparkUpsertNode.scala      |  43 +++-
 .../dag/nodes/spark/sql/BaseSparkSqlNode.scala     |   2 +-
 .../nodes/spark/sql/SparkSqlCreateTableNode.scala  |   2 +-
 .../dag/nodes/spark/sql/SparkSqlDeleteNode.scala   |   2 +-
 .../dag/nodes/spark/sql/SparkSqlMergeNode.scala    |   2 +-
 .../dag/nodes/spark/sql/SparkSqlUpdateNode.scala   |   2 +-
 .../TestDFSHoodieTestSuiteWriterAdapter.java       |   2 +-
 25 files changed, 466 insertions(+), 146 deletions(-)
 copy docker/demo/config/test-suite/{simple-deltastreamer.yaml => multi-writer-1-ds.yaml} (82%)
 copy docker/demo/config/test-suite/{test.properties => multi-writer-1.properties} (81%)
 copy docker/demo/config/test-suite/{cow-spark-simple.yaml => multi-writer-2-sds.yaml} (78%)
 copy docker/demo/config/test-suite/{test.properties => multi-writer-2.properties} (81%)
 copy docker/demo/config/test-suite/{test-metadata-aggressive-clean-archival.properties => multi-writer-local-1.properties} (77%)
 copy docker/demo/config/test-suite/{test-metadata-aggressive-clean-archival.properties => multi-writer-local-2.properties} (77%)
 create mode 100644 hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieMultiWriterTestSuiteJob.java