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());