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 b6847ed38b7 HIVE-27802: Simplify 
TestTezSessionState.testSymlinkedLocalFilesAreLocalizedOnce (#4804) (Laszlo 
Bodor reviewed by Ayush Saxena)
b6847ed38b7 is described below

commit b6847ed38b7d32586ab22e224904867f159b510e
Author: Bodor Laszlo <[email protected]>
AuthorDate: Tue Oct 17 07:50:22 2023 +0200

    HIVE-27802: Simplify 
TestTezSessionState.testSymlinkedLocalFilesAreLocalizedOnce (#4804) (Laszlo 
Bodor reviewed by Ayush Saxena)
---
 .../hadoop/hive/ql/exec/tez/TestTezSessionState.java  | 19 +------------------
 1 file changed, 1 insertion(+), 18 deletions(-)

diff --git 
a/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestTezSessionState.java 
b/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestTezSessionState.java
index 521134bdfa5..8e48c0f9998 100644
--- a/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestTezSessionState.java
+++ b/ql/src/test/org/apache/hadoop/hive/ql/exec/tez/TestTezSessionState.java
@@ -28,22 +28,6 @@ import org.junit.Test;
 
 public class TestTezSessionState {
 
-  private class TestTezSessionPoolManager extends TezSessionPoolManager {
-    public TestTezSessionPoolManager() {
-      super();
-    }
-
-    @Override
-    public void setupPool(HiveConf conf) throws Exception {
-      super.setupPool(conf);
-    }
-
-    @Override
-    public TezSessionPoolSession createSession(String sessionId, HiveConf 
conf) {
-      return new SampleTezSessionState(sessionId, this, conf);
-    }
-  }
-
   @Test
   public void testSymlinkedLocalFilesAreLocalizedOnce() throws Exception {
     Path jarPath = Files.createTempFile("jar", "");
@@ -57,9 +41,8 @@ public class TestTezSessionState {
 
     HiveConf hiveConf = new HiveConf();
     hiveConf.set(HiveConf.ConfVars.HIVE_JAR_DIRECTORY.varname, "/tmp");
-    TezSessionPoolManager poolManager = new TestTezSessionPoolManager();
 
-    TezSessionState sessionState = poolManager.getSession(null, hiveConf, 
true, false);
+    TezSessionState sessionState = new TezSessionState(DagUtils.getInstance(), 
hiveConf);
 
     LocalResource l1 = 
sessionState.createJarLocalResource(jarPath.toUri().toString());
     LocalResource l2 = 
sessionState.createJarLocalResource(symlinkPath.toUri().toString());

Reply via email to