diff --git a/docker/demo/config/test-suite/compact-test.properties b/docker/demo/config/test-suite/compact-test.properties index 2eca88de3a426..f87d20974c6c2 100644 --- a/docker/demo/config/test-suite/compact-test.properties +++ b/docker/demo/config/test-suite/compact-test.properties @@ -22,7 +22,7 @@ hoodie.bulkinsert.shuffle.parallelism=100 hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false hoodie.deltastreamer.source.test.max_unique_records=100000000 -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector diff --git a/docker/demo/config/test-suite/multi-writer-1.properties b/docker/demo/config/test-suite/multi-writer-1.properties index 502a1b771e8cd..692b4f911dfa3 100644 --- a/docker/demo/config/test-suite/multi-writer-1.properties +++ b/docker/demo/config/test-suite/multi-writer-1.properties @@ -25,7 +25,7 @@ hoodie.metadata.enable=false hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false hoodie.deltastreamer.source.test.max_unique_records=100000000 -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector diff --git a/docker/demo/config/test-suite/multi-writer-2.properties b/docker/demo/config/test-suite/multi-writer-2.properties index 80db8912b5406..6b9915ef95b42 100644 --- a/docker/demo/config/test-suite/multi-writer-2.properties +++ b/docker/demo/config/test-suite/multi-writer-2.properties @@ -25,7 +25,7 @@ hoodie.metadata.enable=false hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false hoodie.deltastreamer.source.test.max_unique_records=100000000 -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector diff --git a/docker/demo/config/test-suite/multi-writer-local-1.properties b/docker/demo/config/test-suite/multi-writer-local-1.properties index be16f91c17459..679067fa0e446 100644 --- a/docker/demo/config/test-suite/multi-writer-local-1.properties +++ b/docker/demo/config/test-suite/multi-writer-local-1.properties @@ -28,7 +28,7 @@ hoodie.metadata.enable=false hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false hoodie.deltastreamer.source.test.max_unique_records=100000000 -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector diff --git a/docker/demo/config/test-suite/multi-writer-local-2.properties b/docker/demo/config/test-suite/multi-writer-local-2.properties index 08f294ce1461e..2a70bf138b5e0 100644 --- a/docker/demo/config/test-suite/multi-writer-local-2.properties +++ b/docker/demo/config/test-suite/multi-writer-local-2.properties @@ -28,7 +28,7 @@ hoodie.metadata.enable=false hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false hoodie.deltastreamer.source.test.max_unique_records=100000000 -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector diff --git a/docker/demo/config/test-suite/multi-writer-local-3.properties b/docker/demo/config/test-suite/multi-writer-local-3.properties index 48f0f0b1ace8b..89b02b02f44c2 100644 --- a/docker/demo/config/test-suite/multi-writer-local-3.properties +++ b/docker/demo/config/test-suite/multi-writer-local-3.properties @@ -28,7 +28,7 @@ hoodie.metadata.enable=false hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false hoodie.deltastreamer.source.test.max_unique_records=100000000 -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector diff --git a/docker/demo/config/test-suite/multi-writer-local-4.properties b/docker/demo/config/test-suite/multi-writer-local-4.properties index 4b5120928ccb1..7a6a57487a69a 100644 --- a/docker/demo/config/test-suite/multi-writer-local-4.properties +++ b/docker/demo/config/test-suite/multi-writer-local-4.properties @@ -28,7 +28,7 @@ hoodie.metadata.enable=false hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false hoodie.deltastreamer.source.test.max_unique_records=100000000 -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector diff --git a/docker/demo/config/test-suite/templates/test.properties.template b/docker/demo/config/test-suite/templates/test.properties.template index e1b65fb730a18..1c84be89daef2 100644 --- a/docker/demo/config/test-suite/templates/test.properties.template +++ b/docker/demo/config/test-suite/templates/test.properties.template @@ -22,7 +22,7 @@ hoodie.bulkinsert.shuffle.parallelism=100 hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false hoodie.deltastreamer.source.test.max_unique_records=100000000 -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.input.selector=org.apache.hudi.integ.testsuite.helpers.DFSTestSuitePathSelector hoodie.datasource.hive_sync.skip_ro_suffix=true diff --git a/docker/demo/config/test-suite/test-aggressive-clean-archival-inline-compact.properties b/docker/demo/config/test-suite/test-aggressive-clean-archival-inline-compact.properties index 14427f323cead..c8b8820859cc1 100644 --- a/docker/demo/config/test-suite/test-aggressive-clean-archival-inline-compact.properties +++ b/docker/demo/config/test-suite/test-aggressive-clean-archival-inline-compact.properties @@ -28,7 +28,7 @@ hoodie.keep.min.commits=12 hoodie.keep.max.commits=14 hoodie.compact.inline=true -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/docker/demo/config/test-suite/test-aggressive-clean-archival.properties b/docker/demo/config/test-suite/test-aggressive-clean-archival.properties index f0d9de251b869..35c6f89d8774a 100644 --- a/docker/demo/config/test-suite/test-aggressive-clean-archival.properties +++ b/docker/demo/config/test-suite/test-aggressive-clean-archival.properties @@ -26,7 +26,7 @@ hoodie.delete.shuffle.parallelism=25 hoodie.cleaner.commits.retained=8 hoodie.keep.min.commits=12 hoodie.keep.max.commits=14 -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/docker/demo/config/test-suite/test-clustering-aggressive-clean-archival-inline-compact.properties b/docker/demo/config/test-suite/test-clustering-aggressive-clean-archival-inline-compact.properties index 748972861851d..fc63994250409 100644 --- a/docker/demo/config/test-suite/test-clustering-aggressive-clean-archival-inline-compact.properties +++ b/docker/demo/config/test-suite/test-clustering-aggressive-clean-archival-inline-compact.properties @@ -24,7 +24,7 @@ hoodie.bulkinsert.shuffle.parallelism=25 hoodie.delete.shuffle.parallelism=25 hoodie.compact.inline=true -hoodie.embed.timeline.server=false + hoodie.cleaner.commits.retained=8 hoodie.keep.min.commits=12 diff --git a/docker/demo/config/test-suite/test-clustering-aggressive-clean-archival.properties b/docker/demo/config/test-suite/test-clustering-aggressive-clean-archival.properties index b94ccabb55e09..c0ee38db09dcd 100644 --- a/docker/demo/config/test-suite/test-clustering-aggressive-clean-archival.properties +++ b/docker/demo/config/test-suite/test-clustering-aggressive-clean-archival.properties @@ -26,7 +26,7 @@ hoodie.delete.shuffle.parallelism=25 hoodie.cleaner.commits.retained=8 hoodie.keep.min.commits=12 hoodie.keep.max.commits=14 -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/docker/demo/config/test-suite/test-clustering-inline-compact.properties b/docker/demo/config/test-suite/test-clustering-inline-compact.properties index 5e86790c723a9..1585138e9d8c7 100644 --- a/docker/demo/config/test-suite/test-clustering-inline-compact.properties +++ b/docker/demo/config/test-suite/test-clustering-inline-compact.properties @@ -23,7 +23,7 @@ hoodie.upsert.shuffle.parallelism=25 hoodie.bulkinsert.shuffle.parallelism=25 hoodie.delete.shuffle.parallelism=25 -hoodie.embed.timeline.server=false + hoodie.compact.inline=true hoodie.deltastreamer.source.test.num_partitions=100 diff --git a/docker/demo/config/test-suite/test-clustering-metadata-aggressive-clean-archival-inline-compact.properties b/docker/demo/config/test-suite/test-clustering-metadata-aggressive-clean-archival-inline-compact.properties index dd3089d190184..59470745803df 100644 --- a/docker/demo/config/test-suite/test-clustering-metadata-aggressive-clean-archival-inline-compact.properties +++ b/docker/demo/config/test-suite/test-clustering-metadata-aggressive-clean-archival-inline-compact.properties @@ -29,7 +29,7 @@ hoodie.keep.max.commits=14 hoodie.compact.inline=true hoodie.metadata.enable=true -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/docker/demo/config/test-suite/test-clustering-metadata-aggressive-clean-archival.properties b/docker/demo/config/test-suite/test-clustering-metadata-aggressive-clean-archival.properties index c10d6ecc48007..ed9d140586635 100644 --- a/docker/demo/config/test-suite/test-clustering-metadata-aggressive-clean-archival.properties +++ b/docker/demo/config/test-suite/test-clustering-metadata-aggressive-clean-archival.properties @@ -27,7 +27,7 @@ hoodie.cleaner.commits.retained=8 hoodie.keep.min.commits=12 hoodie.keep.max.commits=14 -hoodie.embed.timeline.server=false + hoodie.metadata.enable=true hoodie.deltastreamer.source.test.num_partitions=100 diff --git a/docker/demo/config/test-suite/test-clustering.properties b/docker/demo/config/test-suite/test-clustering.properties index 677cf96751d77..4fb5fd858100c 100644 --- a/docker/demo/config/test-suite/test-clustering.properties +++ b/docker/demo/config/test-suite/test-clustering.properties @@ -23,7 +23,7 @@ hoodie.upsert.shuffle.parallelism=25 hoodie.bulkinsert.shuffle.parallelism=25 hoodie.delete.shuffle.parallelism=25 -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/docker/demo/config/test-suite/test-inline-compact.properties b/docker/demo/config/test-suite/test-inline-compact.properties index 76de6bd2678e1..330d242deba50 100644 --- a/docker/demo/config/test-suite/test-inline-compact.properties +++ b/docker/demo/config/test-suite/test-inline-compact.properties @@ -25,7 +25,7 @@ hoodie.delete.shuffle.parallelism=25 hoodie.metadata.enable=false hoodie.compact.inline=true -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/docker/demo/config/test-suite/test-metadata-aggressive-clean-archival-inline-compact.properties b/docker/demo/config/test-suite/test-metadata-aggressive-clean-archival-inline-compact.properties index 7921162356e2d..37a01242c20ee 100644 --- a/docker/demo/config/test-suite/test-metadata-aggressive-clean-archival-inline-compact.properties +++ b/docker/demo/config/test-suite/test-metadata-aggressive-clean-archival-inline-compact.properties @@ -27,7 +27,7 @@ hoodie.cleaner.commits.retained=8 hoodie.keep.min.commits=12 hoodie.keep.max.commits=14 -hoodie.embed.timeline.server=false + hoodie.metadata.enable=true hoodie.compact.inline=true diff --git a/docker/demo/config/test-suite/test-metadata-aggressive-clean-archival.properties b/docker/demo/config/test-suite/test-metadata-aggressive-clean-archival.properties index 5bad7fc4ef100..c535487ecba06 100644 --- a/docker/demo/config/test-suite/test-metadata-aggressive-clean-archival.properties +++ b/docker/demo/config/test-suite/test-metadata-aggressive-clean-archival.properties @@ -28,7 +28,7 @@ hoodie.keep.min.commits=12 hoodie.keep.max.commits=14 hoodie.metadata.enable=true -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/docker/demo/config/test-suite/test-metadata-inline-compact.properties b/docker/demo/config/test-suite/test-metadata-inline-compact.properties index 5230a1488ca67..14c7e85039e18 100644 --- a/docker/demo/config/test-suite/test-metadata-inline-compact.properties +++ b/docker/demo/config/test-suite/test-metadata-inline-compact.properties @@ -25,7 +25,7 @@ hoodie.delete.shuffle.parallelism=25 hoodie.metadata.enable=true hoodie.compact.inline=true -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/docker/demo/config/test-suite/test-metadata.properties b/docker/demo/config/test-suite/test-metadata.properties index 0edcd3c63d2ef..f79c582306d25 100644 --- a/docker/demo/config/test-suite/test-metadata.properties +++ b/docker/demo/config/test-suite/test-metadata.properties @@ -24,7 +24,7 @@ hoodie.bulkinsert.shuffle.parallelism=25 hoodie.delete.shuffle.parallelism=25 hoodie.metadata.enable=true -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/docker/demo/config/test-suite/test-nonpartitioned-inline-compact.properties b/docker/demo/config/test-suite/test-nonpartitioned-inline-compact.properties index 97f2bfa4978d3..3c47517d9cfa6 100644 --- a/docker/demo/config/test-suite/test-nonpartitioned-inline-compact.properties +++ b/docker/demo/config/test-suite/test-nonpartitioned-inline-compact.properties @@ -25,7 +25,7 @@ hoodie.delete.shuffle.parallelism=25 hoodie.metadata.enable=false hoodie.compact.inline=true -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/docker/demo/config/test-suite/test-nonpartitioned-metadata-inline-compact.properties b/docker/demo/config/test-suite/test-nonpartitioned-metadata-inline-compact.properties index 2298be18fe91d..2b35b802a69cd 100644 --- a/docker/demo/config/test-suite/test-nonpartitioned-metadata-inline-compact.properties +++ b/docker/demo/config/test-suite/test-nonpartitioned-metadata-inline-compact.properties @@ -25,7 +25,7 @@ hoodie.delete.shuffle.parallelism=25 hoodie.metadata.enable=true hoodie.compact.inline=true -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/docker/demo/config/test-suite/test-nonpartitioned-metadata.properties b/docker/demo/config/test-suite/test-nonpartitioned-metadata.properties index 520534f3b3e92..05cd0ad0a30b2 100644 --- a/docker/demo/config/test-suite/test-nonpartitioned-metadata.properties +++ b/docker/demo/config/test-suite/test-nonpartitioned-metadata.properties @@ -24,7 +24,7 @@ hoodie.bulkinsert.shuffle.parallelism=25 hoodie.delete.shuffle.parallelism=25 hoodie.metadata.enable=true -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/docker/demo/config/test-suite/test-nonpartitioned.properties b/docker/demo/config/test-suite/test-nonpartitioned.properties index d51c4e5f843d3..a4ec7145de3a0 100644 --- a/docker/demo/config/test-suite/test-nonpartitioned.properties +++ b/docker/demo/config/test-suite/test-nonpartitioned.properties @@ -24,7 +24,7 @@ hoodie.bulkinsert.shuffle.parallelism=25 hoodie.delete.shuffle.parallelism=25 hoodie.metadata.enable=false -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/docker/demo/config/test-suite/test.properties b/docker/demo/config/test-suite/test.properties index 3b20d3286251a..ce8a16e3db845 100644 --- a/docker/demo/config/test-suite/test.properties +++ b/docker/demo/config/test-suite/test.properties @@ -21,7 +21,7 @@ hoodie.bulkinsert.shuffle.parallelism=25 hoodie.delete.shuffle.parallelism=25 hoodie.metadata.enable=false -hoodie.embed.timeline.server=false + hoodie.deltastreamer.source.test.num_partitions=100 hoodie.deltastreamer.source.test.datagen.use_rocksdb_for_storing_existing_keys=false diff --git a/hudi-integ-test/pom.xml b/hudi-integ-test/pom.xml index acf2f06c0279a..023883a16415f 100644 --- a/hudi-integ-test/pom.xml +++ b/hudi-integ-test/pom.xml @@ -51,16 +51,6 @@ test - - - - org.eclipse.jetty.aggregate - jetty-all - ${jetty.version} - uber - test - - org.apache.spark spark-sql_${scala.binary.version} diff --git a/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieContinousTestSuiteWriter.java b/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieContinousTestSuiteWriter.java index 76f9d7424ac90..27733bb3804c5 100644 --- a/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieContinousTestSuiteWriter.java +++ b/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieContinousTestSuiteWriter.java @@ -85,8 +85,14 @@ public HoodieContinousTestSuiteWriter(JavaSparkContext jsc, Properties props, Ho @Override public void shutdownResources() { - log.info("Shutting down deltastreamer gracefully "); - this.deltaStreamerWrapper.shutdownGracefully(); + if (this.deltaStreamerWrapper != null) { + log.info("Shutting down DS wrapper gracefully "); + this.deltaStreamerWrapper.shutdownGracefully(); + } + if (this.writeClient != null) { + log.info("Closing local write client"); + this.writeClient.close(); + } } @Override diff --git a/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieInlineTestSuiteWriter.java b/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieInlineTestSuiteWriter.java index 91a7cf358c011..46f793ef12bf6 100644 --- a/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieInlineTestSuiteWriter.java +++ b/hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieInlineTestSuiteWriter.java @@ -65,7 +65,14 @@ public HoodieInlineTestSuiteWriter(JavaSparkContext jsc, Properties props, Hoodi } public void shutdownResources() { - // no-op for non continuous mode test suite writer. + if (this.deltaStreamerWrapper != null) { + log.info("Shutting down DS wrapper gracefully "); + this.deltaStreamerWrapper.shutdownGracefully(); + } + if (this.writeClient != null) { + log.info("Closing local write client"); + this.writeClient.close(); + } } public RDD getNextBatch() throws Exception { diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java index 36cd19928489b..53bd9c5805193 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java @@ -183,7 +183,12 @@ private static TypedProperties combineProperties(Config cfg, Option ds.shutdown(false)); + ingestionService.ifPresent(ds -> { + LOG.info("Shutting down DeltaStreamer"); + ds.shutdown(false); + LOG.info("Async service shutdown complete. Closing DeltaSync "); + ds.close(); + }); } /** diff --git a/packaging/hudi-integ-test-bundle/pom.xml b/packaging/hudi-integ-test-bundle/pom.xml index d83d0154fc619..dcc53dd7f6121 100644 --- a/packaging/hudi-integ-test-bundle/pom.xml +++ b/packaging/hudi-integ-test-bundle/pom.xml @@ -266,6 +266,10 @@ org.openjdk.jol. org.apache.hudi.org.openjdk.jol. + + org.eclipse.jetty. + org.apache.hudi.org.eclipse.jetty. + @@ -306,12 +310,6 @@ - - io.javalin - javalin - 2.8.0 - - io.dropwizard.metrics metrics-core @@ -357,6 +355,13 @@ compile + + org.apache.hudi + hudi-timeline-service + ${project.version} + compile + + org.apache.hudi hudi-integ-test