Readded system conf

ExpediaGroup · Feb 2, 2021 · 642f74d · 642f74d
1 parent 7bbba23
commit 642f74d
Show file tree

Hide file tree

Showing 6 changed files with 18 additions and 6 deletions.
diff --git a/src/main/java/com/hotels/beeju/HiveMetaStoreJUnitRule.java b/src/main/java/com/hotels/beeju/HiveMetaStoreJUnitRule.java
@@ -16,6 +16,8 @@
 package com.hotels.beeju;
 
 
+import static org.apache.hadoop.hive.metastore.conf.MetastoreConf.ConfVars.CONNECT_URL_KEY;
+
 import java.util.Map;
 
 import org.apache.hadoop.hive.metastore.HiveMetaStoreClient;
@@ -73,7 +75,7 @@ public HiveMetaStoreJUnitRule(
 
   @Override
   protected void before() throws Throwable {
-    // System.clearProperty(CONNECT_URL_KEY.getVarname());
+    System.clearProperty(CONNECT_URL_KEY.getVarname());
     super.before();
     hiveMetaStoreCore.initialise();
   }

diff --git a/src/main/java/com/hotels/beeju/HiveServer2JUnitRule.java b/src/main/java/com/hotels/beeju/HiveServer2JUnitRule.java
@@ -16,6 +16,8 @@
 package com.hotels.beeju;
 
 
+import static org.apache.hadoop.hive.metastore.conf.MetastoreConf.ConfVars.CONNECT_URL_KEY;
+
 import java.util.Map;
 
 import org.apache.hive.jdbc.HiveDriver;
@@ -65,7 +67,7 @@ public HiveServer2JUnitRule(String databaseName, Map<String, String> configurati
 
   @Override
   protected void before() throws Throwable {
-    // System.clearProperty(CONNECT_URL_KEY.getVarname());
+    System.clearProperty(CONNECT_URL_KEY.getVarname());
     hiveServer2Core.startServerSocket();
     super.before();
     hiveServer2Core.initialise();

diff --git a/src/main/java/com/hotels/beeju/ThriftHiveMetaStoreJUnitRule.java b/src/main/java/com/hotels/beeju/ThriftHiveMetaStoreJUnitRule.java
@@ -16,6 +16,8 @@
 package com.hotels.beeju;
 
 
+import static org.apache.hadoop.hive.metastore.conf.MetastoreConf.ConfVars.CONNECT_URL_KEY;
+
 import java.util.Map;
 
 import com.hotels.beeju.core.ThriftHiveMetaStoreCore;
@@ -70,7 +72,7 @@ public ThriftHiveMetaStoreJUnitRule(String databaseName, Map<String, String> pre
 
   @Override
   protected void before() throws Throwable {
-    // System.clearProperty(CONNECT_URL_KEY.getVarname());
+    System.clearProperty(CONNECT_URL_KEY.getVarname());
     super.before();
     thriftHiveMetaStoreCore.initialise();
   }

diff --git a/src/main/java/com/hotels/beeju/extensions/HiveMetaStoreJUnitExtension.java b/src/main/java/com/hotels/beeju/extensions/HiveMetaStoreJUnitExtension.java
@@ -16,6 +16,8 @@
 package com.hotels.beeju.extensions;
 
 
+import static org.apache.hadoop.hive.metastore.conf.MetastoreConf.ConfVars.CONNECT_URL_KEY;
+
 import java.util.Map;
 
 import org.apache.hadoop.hive.metastore.HiveMetaStoreClient;
@@ -62,7 +64,7 @@ public HiveMetaStoreJUnitExtension(String databaseName, Map<String, String> conf
 
   @Override
   public void beforeEach(ExtensionContext context) throws Exception {
-    // System.clearProperty(CONNECT_URL_KEY.getVarname());
+    System.clearProperty(CONNECT_URL_KEY.getVarname());
     super.beforeEach(context);
     hiveMetaStoreCore.initialise();
   }

diff --git a/src/main/java/com/hotels/beeju/extensions/HiveServer2JUnitExtension.java b/src/main/java/com/hotels/beeju/extensions/HiveServer2JUnitExtension.java
@@ -16,6 +16,8 @@
 package com.hotels.beeju.extensions;
 
 
+import static org.apache.hadoop.hive.metastore.conf.MetastoreConf.ConfVars.CONNECT_URL_KEY;
+
 import java.util.Map;
 
 import org.apache.hive.jdbc.HiveDriver;
@@ -56,7 +58,7 @@ public HiveServer2JUnitExtension(String databaseName, Map<String, String> config
 
   @Override
   public void beforeEach(ExtensionContext context) throws Exception {
-    // System.clearProperty(CONNECT_URL_KEY.getVarname());
+    System.clearProperty(CONNECT_URL_KEY.getVarname());
     hiveServer2Core.startServerSocket();
     super.beforeEach(context);
     hiveServer2Core.initialise();

diff --git a/src/main/java/com/hotels/beeju/extensions/ThriftHiveMetaStoreJUnitExtension.java b/src/main/java/com/hotels/beeju/extensions/ThriftHiveMetaStoreJUnitExtension.java
@@ -16,6 +16,8 @@
 package com.hotels.beeju.extensions;
 
 
+import static org.apache.hadoop.hive.metastore.conf.MetastoreConf.ConfVars.CONNECT_URL_KEY;
+
 import java.util.Map;
 
 import org.junit.jupiter.api.extension.ExtensionContext;
@@ -62,7 +64,7 @@ public ThriftHiveMetaStoreJUnitExtension(String databaseName, Map<String, String
 
   @Override
   public void beforeEach(ExtensionContext context) throws Exception {
-    // System.clearProperty(CONNECT_URL_KEY.getVarname());
+    System.clearProperty(CONNECT_URL_KEY.getVarname());
     super.beforeEach(context);
     thriftHiveMetaStoreCore.initialise();
   }