This is an automated email from the ASF dual-hosted git repository.
abstractdog pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/master by this push:
new ab02fa3d3d8 HIVE-28802: NPE in MiniHS2 with
miniHS2.clusterType=LOCALFS_ONLY (#5680) (Laszlo Bodor reviewed by Sourabh
Badhya, Kokila N)
ab02fa3d3d8 is described below
commit ab02fa3d3d810885c9849197df8b995a8b267e7b
Author: Bodor Laszlo <[email protected]>
AuthorDate: Sat Apr 12 08:21:46 2025 +0200
HIVE-28802: NPE in MiniHS2 with miniHS2.clusterType=LOCALFS_ONLY (#5680)
(Laszlo Bodor reviewed by Sourabh Badhya, Kokila N)
---
.../hadoop/hive/ql/reexec/TestReExecuteKilledTezAMQueryPlugin.java | 1 -
.../src/test/java/org/apache/hive/jdbc/AbstractJdbcTriggersTest.java | 1 -
.../java/org/apache/hive/jdbc/AbstractTestJdbcGenericUDTFGetSplits.java | 1 -
.../src/test/java/org/apache/hive/jdbc/BaseJdbcWithMiniLlap.java | 1 -
.../org/apache/hive/jdbc/TestKillQueryWithAuthorizationDisabled.java | 1 -
.../test/java/org/apache/hive/jdbc/TestTriggersMoveWorkloadManager.java | 1 -
.../src/test/java/org/apache/hive/jdbc/TestTriggersWorkloadManager.java | 1 -
.../src/test/java/org/apache/hive/jdbc/TestWMMetricsWithTrigger.java | 1 -
.../src/test/java/org/apache/hive/jdbc/miniHS2/StartMiniHS2Cluster.java | 2 --
9 files changed, 10 deletions(-)
diff --git
a/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/reexec/TestReExecuteKilledTezAMQueryPlugin.java
b/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/reexec/TestReExecuteKilledTezAMQueryPlugin.java
index 7b71432d078..35b98fa08b2 100644
---
a/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/reexec/TestReExecuteKilledTezAMQueryPlugin.java
+++
b/itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/reexec/TestReExecuteKilledTezAMQueryPlugin.java
@@ -77,7 +77,6 @@ public static void beforeTest() throws Exception {
dataFileDir = conf.get("test.data.files").replace('\\', '/').replace("c:",
"");
Map<String, String> confOverlay = new HashMap<String, String>();
miniHS2.start(confOverlay);
- miniHS2.getDFS().getFileSystem().mkdirs(new
Path("/apps_staging_dir/anonymous"));
Connection conDefault = getConnection(miniHS2.getJdbcURL(),
System.getProperty("user.name"), "bar");
diff --git
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/AbstractJdbcTriggersTest.java
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/AbstractJdbcTriggersTest.java
index 44c67ec4dae..40802951f46 100644
---
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/AbstractJdbcTriggersTest.java
+++
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/AbstractJdbcTriggersTest.java
@@ -89,7 +89,6 @@ public static void beforeTest() throws Exception {
Map<String, String> confOverlay = new HashMap<>();
miniHS2.start(confOverlay);
- miniHS2.getDFS().getFileSystem().mkdirs(new
Path("/apps_staging_dir/anonymous"));
}
@Before
diff --git
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/AbstractTestJdbcGenericUDTFGetSplits.java
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/AbstractTestJdbcGenericUDTFGetSplits.java
index def5698d513..bb73b8bbca6 100644
---
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/AbstractTestJdbcGenericUDTFGetSplits.java
+++
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/AbstractTestJdbcGenericUDTFGetSplits.java
@@ -84,7 +84,6 @@ public static void beforeTest() throws Exception {
Map<String, String> confOverlay = new HashMap<>();
miniHS2.start(confOverlay);
- miniHS2.getDFS().getFileSystem().mkdirs(new
Path("/apps_staging_dir/anonymous"));
}
@AfterClass
diff --git
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/BaseJdbcWithMiniLlap.java
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/BaseJdbcWithMiniLlap.java
index 2ec3d48e901..5859f639242 100644
---
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/BaseJdbcWithMiniLlap.java
+++
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/BaseJdbcWithMiniLlap.java
@@ -91,7 +91,6 @@ public static MiniHS2 beforeTest(HiveConf inputConf) throws
Exception {
over10KFilePath = new Path(dataFileDir, "over10k");
Map<String, String> confOverlay = new HashMap<String, String>();
miniHS2.start(confOverlay);
- miniHS2.getDFS().getFileSystem().mkdirs(new
Path("/apps_staging_dir/anonymous"));
return miniHS2;
}
diff --git
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestKillQueryWithAuthorizationDisabled.java
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestKillQueryWithAuthorizationDisabled.java
index 59b775c16e0..a08695678bc 100644
---
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestKillQueryWithAuthorizationDisabled.java
+++
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestKillQueryWithAuthorizationDisabled.java
@@ -112,7 +112,6 @@ static HiveConf defaultConf() throws Exception {
miniHS2 = new MiniHS2(conf, MiniHS2.MiniClusterType.LLAP);
Map<String, String> confOverlay = new HashMap<String, String>();
miniHS2.start(confOverlay);
- miniHS2.getDFS().getFileSystem().mkdirs(new
Path("/apps_staging_dir/anonymous"));
Connection conDefault =
BaseJdbcWithMiniLlap.getConnection(miniHS2.getJdbcURL(),
System.getProperty("user.name"), "bar");
diff --git
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestTriggersMoveWorkloadManager.java
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestTriggersMoveWorkloadManager.java
index 097a7db9759..a50931c2bc2 100644
---
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestTriggersMoveWorkloadManager.java
+++
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestTriggersMoveWorkloadManager.java
@@ -92,7 +92,6 @@ public static void beforeTest() throws Exception {
Map<String, String> confOverlay = new HashMap<>();
miniHS2.start(confOverlay);
- miniHS2.getDFS().getFileSystem().mkdirs(new
Path("/apps_staging_dir/anonymous"));
}
@Test(timeout = 60000)
diff --git
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestTriggersWorkloadManager.java
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestTriggersWorkloadManager.java
index 06dd6d04a7c..9ae60634c60 100644
---
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestTriggersWorkloadManager.java
+++
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestTriggersWorkloadManager.java
@@ -86,7 +86,6 @@ public static void beforeTest() throws Exception {
Map<String, String> confOverlay = new HashMap<>();
miniHS2.start(confOverlay);
- miniHS2.getDFS().getFileSystem().mkdirs(new
Path("/apps_staging_dir/anonymous"));
}
@Override
diff --git
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestWMMetricsWithTrigger.java
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestWMMetricsWithTrigger.java
index d9e368dae9c..d056ab3341c 100644
---
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestWMMetricsWithTrigger.java
+++
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/TestWMMetricsWithTrigger.java
@@ -106,7 +106,6 @@ public static void beforeTest() throws Exception {
miniHS2 = new MiniHS2(conf, MiniHS2.MiniClusterType.LLAP);
Map<String, String> confOverlay = new HashMap<>();
miniHS2.start(confOverlay);
- miniHS2.getDFS().getFileSystem().mkdirs(new
Path("/apps_staging_dir/anonymous"));
Connection conDefault =
BaseJdbcWithMiniLlap.getConnection(miniHS2.getJdbcURL(),
System.getProperty("user.name"), "bar");
diff --git
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/miniHS2/StartMiniHS2Cluster.java
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/miniHS2/StartMiniHS2Cluster.java
index 03df3dbef13..6edd85f6172 100644
---
a/itests/hive-unit/src/test/java/org/apache/hive/jdbc/miniHS2/StartMiniHS2Cluster.java
+++
b/itests/hive-unit/src/test/java/org/apache/hive/jdbc/miniHS2/StartMiniHS2Cluster.java
@@ -22,7 +22,6 @@
import java.util.HashMap;
import java.util.Map;
-import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hive.conf.Constants;
import org.apache.hadoop.hive.conf.HiveConf;
import org.apache.hadoop.hive.conf.HiveConf.ConfVars;
@@ -81,7 +80,6 @@ public void testRunCluster() throws Exception {
.withRemoteMetastore(isMetastoreRemote).withQueryHistory(queryHistory).build();
Map<String, String> confOverlay = new HashMap<String, String>();
miniHS2.start(confOverlay);
- miniHS2.getDFS().getFileSystem().mkdirs(new
Path("/apps_staging_dir/anonymous"));
System.out.println("JDBC URL available at " + miniHS2.getJdbcURL());
