diff --git a/hudi-client/src/main/java/org/apache/hudi/config/HoodieCompactionConfig.java b/hudi-client/src/main/java/org/apache/hudi/config/HoodieCompactionConfig.java index bb087a268..d135a8151 100644 --- a/hudi-client/src/main/java/org/apache/hudi/config/HoodieCompactionConfig.java +++ b/hudi-client/src/main/java/org/apache/hudi/config/HoodieCompactionConfig.java @@ -96,7 +96,7 @@ public class HoodieCompactionConfig extends DefaultHoodieConfig { private static final String DEFAULT_CLEANER_POLICY = HoodieCleaningPolicy.KEEP_LATEST_COMMITS.name(); private static final String DEFAULT_AUTO_CLEAN = "true"; private static final String DEFAULT_INLINE_COMPACT = "false"; - private static final String DEFAULT_INCREMENTAL_CLEANER = "false"; + private static final String DEFAULT_INCREMENTAL_CLEANER = "true"; private static final String DEFAULT_INLINE_COMPACT_NUM_DELTA_COMMITS = "1"; private static final String DEFAULT_CLEANER_FILE_VERSIONS_RETAINED = "3"; private static final String DEFAULT_CLEANER_COMMITS_RETAINED = "10"; diff --git a/hudi-client/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java b/hudi-client/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java index 11931c133..3f0f61942 100644 --- a/hudi-client/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java +++ b/hudi-client/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java @@ -82,7 +82,7 @@ public class HoodieWriteConfig extends DefaultHoodieConfig { private static final String DEFAULT_FINALIZE_WRITE_PARALLELISM = DEFAULT_PARALLELISM; private static final String EMBEDDED_TIMELINE_SERVER_ENABLED = "hoodie.embed.timeline.server"; - private static final String DEFAULT_EMBEDDED_TIMELINE_SERVER_ENABLED = "false"; + private static final String DEFAULT_EMBEDDED_TIMELINE_SERVER_ENABLED = "true"; private static final String FAIL_ON_TIMELINE_ARCHIVING_ENABLED_PROP = "hoodie.fail.on.timeline.archiving"; private static final String DEFAULT_FAIL_ON_TIMELINE_ARCHIVING_ENABLED = "true"; diff --git a/hudi-client/src/test/java/org/apache/hudi/table/action/compact/TestHoodieCompactor.java b/hudi-client/src/test/java/org/apache/hudi/table/action/compact/TestHoodieCompactor.java index 0ebebed65..9aec8adbc 100644 --- a/hudi-client/src/test/java/org/apache/hudi/table/action/compact/TestHoodieCompactor.java +++ b/hudi-client/src/test/java/org/apache/hudi/table/action/compact/TestHoodieCompactor.java @@ -30,6 +30,9 @@ import org.apache.hudi.common.model.HoodieTableType; import org.apache.hudi.common.model.HoodieTestUtils; import org.apache.hudi.common.table.HoodieTableMetaClient; import org.apache.hudi.common.table.timeline.HoodieActiveTimeline; +import org.apache.hudi.common.table.timeline.HoodieInstant; +import org.apache.hudi.common.table.timeline.HoodieInstant.State; +import org.apache.hudi.common.table.timeline.HoodieTimeline; import org.apache.hudi.common.util.Option; import org.apache.hudi.config.HoodieCompactionConfig; import org.apache.hudi.config.HoodieIndexConfig; @@ -152,9 +155,13 @@ public class TestHoodieCompactor extends HoodieClientTestHarness { HoodieIndex index = new HoodieBloomIndex<>(config); updatedRecords = index.tagLocation(updatedRecordsRDD, jsc, table).collect(); - // Write them to corresponding avro logfiles + // Write them to corresponding avro logfiles. Also, set the state transition properly. HoodieTestUtils.writeRecordsToLogFiles(fs, metaClient.getBasePath(), HoodieTestDataGenerator.AVRO_SCHEMA_WITH_METADATA_FIELDS, updatedRecords); + metaClient.getActiveTimeline().transitionRequestedToInflight(new HoodieInstant(State.REQUESTED, + HoodieTimeline.DELTA_COMMIT_ACTION, newCommitTime), Option.empty()); + writeClient.commit(newCommitTime, jsc.emptyRDD(), Option.empty()); + metaClient.reloadActiveTimeline(); // Verify that all data file has one log file table = HoodieTable.create(config, hadoopConf); diff --git a/hudi-hive-sync/pom.xml b/hudi-hive-sync/pom.xml index 973cb3e03..9d4b8e275 100644 --- a/hudi-hive-sync/pom.xml +++ b/hudi-hive-sync/pom.xml @@ -171,12 +171,6 @@ test - - org.eclipse.jetty.aggregate - jetty-all - test - - org.apache.hadoop diff --git a/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/HiveTestService.java b/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/HiveTestService.java index 47d9882a4..e3a70a862 100644 --- a/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/HiveTestService.java +++ b/hudi-hive-sync/src/test/java/org/apache/hudi/hive/testutils/HiveTestService.java @@ -105,6 +105,7 @@ public class HiveTestService { executorService = Executors.newSingleThreadExecutor(); tServer = startMetaStore(bindIP, metastorePort, serverConf); + serverConf.set("hive.in.test", "true"); hiveServer = startHiveServer(serverConf); String serverHostname; diff --git a/hudi-spark/pom.xml b/hudi-spark/pom.xml index 9bd07c04d..6be663afa 100644 --- a/hudi-spark/pom.xml +++ b/hudi-spark/pom.xml @@ -225,6 +225,12 @@ org.apache.spark spark-core_${scala.binary.version} + + + javax.servlet + * + + org.apache.spark @@ -253,7 +259,17 @@ org.apache.hadoop hadoop-common - provided + + + javax.servlet + * + + + javax.servlet.jsp + * + + + provided @@ -277,16 +293,42 @@ ${hive.groupid} hive-jdbc ${hive.version} + + + javax.servlet + * + + + javax.servlet.jsp + * + + ${hive.groupid} hive-metastore ${hive.version} + + + javax.servlet + * + + + javax.servlet.jsp + * + + ${hive.groupid} hive-common ${hive.version} + + + org.eclipse.jetty.orbit + javax.servlet + + diff --git a/hudi-utilities/pom.xml b/hudi-utilities/pom.xml index 0b79414ec..360a3d48a 100644 --- a/hudi-utilities/pom.xml +++ b/hudi-utilities/pom.xml @@ -86,13 +86,8 @@ org.eclipse.jetty.aggregate jetty-all - test - - - - org.eclipse.jetty - jetty-server ${jetty.version} + uber test diff --git a/pom.xml b/pom.xml index 9fe27d788..9bcb898e9 100644 --- a/pom.xml +++ b/pom.xml @@ -102,7 +102,7 @@ 3.0.1 file://${project.basedir}/src/test/resources/log4j-surefire.properties 0.12.0 - 7.6.0.v20120127 + 9.4.15.v20190215 1.2.3 1.9.13 1.4.199 @@ -463,13 +463,6 @@ jersey-container-servlet-core ${glassfish.version} - - - org.eclipse.jetty.aggregate - jetty-all - test - ${jetty.version} -