diff --git a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/FunctionalTestHarness.java b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/FunctionalTestHarness.java
index fc02e6d4d..e391abf0b 100644
--- a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/FunctionalTestHarness.java
+++ b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/FunctionalTestHarness.java
@@ -152,6 +152,8 @@ public class FunctionalTestHarness implements SparkProvider, DFSProvider, Hoodie
hdfsTestService.stop();
hdfsTestService = null;
+ jsc.close();
+ jsc = null;
spark.stop();
spark = null;
}));
@@ -166,5 +168,19 @@ public class FunctionalTestHarness implements SparkProvider, DFSProvider, Hoodie
for (FileStatus f : fileStatuses) {
fs.delete(f.getPath(), true);
}
+ if (hdfsTestService != null) {
+ hdfsTestService.stop();
+ hdfsTestService = null;
+ }
+ if (spark != null) {
+ spark.stop();
+ spark = null;
+ }
+ if (jsc != null) {
+ jsc.close();
+ jsc = null;
+ }
+ sqlContext = null;
+ context = null;
}
}
diff --git a/hudi-spark-datasource/hudi-spark2/pom.xml b/hudi-spark-datasource/hudi-spark2/pom.xml
index 9a232d128..c27bb409e 100644
--- a/hudi-spark-datasource/hudi-spark2/pom.xml
+++ b/hudi-spark-datasource/hudi-spark2/pom.xml
@@ -151,7 +151,7 @@
org.scala-lang
scala-library
- ${scala11.version}
+ ${scala.version}
diff --git a/hudi-spark-datasource/hudi-spark3/pom.xml b/hudi-spark-datasource/hudi-spark3/pom.xml
index d47e90eb5..f3c25a8a1 100644
--- a/hudi-spark-datasource/hudi-spark3/pom.xml
+++ b/hudi-spark-datasource/hudi-spark3/pom.xml
@@ -124,6 +124,13 @@
false
+
+ org.apache.maven.plugins
+ maven-surefire-plugin
+
+ ${skip.hudi-spark3.unit.tests}
+
+
org.apache.rat
apache-rat-plugin
diff --git a/hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/UtilitiesTestBase.java b/hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/UtilitiesTestBase.java
index 6efd4680c..0adef5210 100644
--- a/hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/UtilitiesTestBase.java
+++ b/hudi-utilities/src/test/java/org/apache/hudi/utilities/testutils/UtilitiesTestBase.java
@@ -124,15 +124,19 @@ public class UtilitiesTestBase {
public static void cleanupClass() {
if (hdfsTestService != null) {
hdfsTestService.stop();
+ hdfsTestService = null;
}
if (hiveServer != null) {
hiveServer.stop();
+ hiveServer = null;
}
if (hiveTestService != null) {
hiveTestService.stop();
+ hiveTestService = null;
}
if (zookeeperTestService != null) {
zookeeperTestService.stop();
+ zookeeperTestService = null;
}
}
@@ -150,6 +154,11 @@ public class UtilitiesTestBase {
TestDataSource.resetDataGen();
if (jsc != null) {
jsc.stop();
+ jsc = null;
+ }
+ if (sparkSession != null) {
+ sparkSession.close();
+ sparkSession = null;
}
if (context != null) {
context = null;
diff --git a/pom.xml b/pom.xml
index 4c950feb1..61e3ac893 100644
--- a/pom.xml
+++ b/pom.xml
@@ -133,6 +133,7 @@
${skipTests}
${skipTests}
${skipTests}
+ ${skipTests}
UTF-8
${project.basedir}
provided
@@ -1424,6 +1425,7 @@
${scala12.version}
2.12
+ true