adjust

flaming-archer · Apr 7, 2024 · 277b818 · 277b818
1 parent b2638c3
commit 277b818
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 8 deletions.
diff --git a/waggle-dance-core/src/main/java/com/hotels/bdp/waggledance/server/FederatedHMSHandler.java b/waggle-dance-core/src/main/java/com/hotels/bdp/waggledance/server/FederatedHMSHandler.java
@@ -245,6 +245,7 @@ class FederatedHMSHandler extends FacebookBase implements CloseableIHMSHandler {
   private final NotifyingFederationService notifyingFederationService;
   private final WaggleDanceConfiguration waggleDanceConfiguration;
   private Configuration conf;
+
   FederatedHMSHandler(
       MappingEventListener databaseMappingService,
       NotifyingFederationService notifyingFederationService,
@@ -1555,6 +1556,7 @@ public void setConf(Configuration conf) {
     this.conf = conf;
   }
 
+  @Override
   public void init() throws MetaException {}
 
   @Override

diff --git a/waggle-dance-core/src/main/java/com/hotels/bdp/waggledance/server/MetaStoreProxyServer.java b/waggle-dance-core/src/main/java/com/hotels/bdp/waggledance/server/MetaStoreProxyServer.java
@@ -86,7 +86,7 @@ public class MetaStoreProxyServer implements ApplicationRunner {
 
   private final HiveConf hiveConf;
   private final WaggleDanceConfiguration waggleDanceConfiguration;
-  private final TSetIpAddressProcessorFactory tProcessorFactory;
+  private final TProcessorFactory tProcessorFactory;
   private final Lock startLock;
   private final Condition startCondition;
   private TServer tServer;
@@ -98,13 +98,12 @@ public class MetaStoreProxyServer implements ApplicationRunner {
   public MetaStoreProxyServer(
       HiveConf hiveConf,
       WaggleDanceConfiguration waggleDanceConfiguration,
-      TSetIpAddressProcessorFactory tProcessorFactory) {
+      TProcessorFactory tProcessorFactory) {
     this.hiveConf = hiveConf;
     this.waggleDanceConfiguration = waggleDanceConfiguration;
     this.tProcessorFactory = tProcessorFactory;
     startLock = new ReentrantLock();
     startCondition = startLock.newCondition();
-    tProcessorFactory.setMetaStoreProxyServer(this);
   }
 
   private boolean isRunning() {

diff --git a/...e-core/src/main/java/com/hotels/bdp/waggledance/server/TSetIpAddressProcessorFactory.java b/...e-core/src/main/java/com/hotels/bdp/waggledance/server/TSetIpAddressProcessorFactory.java
@@ -37,7 +37,6 @@ class TSetIpAddressProcessorFactory extends TProcessorFactory {
   private final HiveConf hiveConf;
   private final FederatedHMSHandlerFactory federatedHMSHandlerFactory;
   private final TTransportMonitor transportMonitor;
-  private MetaStoreProxyServer metaStoreProxyServer;
 
   @Autowired
   public TSetIpAddressProcessorFactory(
@@ -73,8 +72,4 @@ private IHMSHandler newRetryingHMSHandler(IHMSHandler baseHandler, HiveConf hive
     return RetryingHMSHandler.getProxy(hiveConf, baseHandler, local);
   }
 
-  public void setMetaStoreProxyServer(
-      MetaStoreProxyServer metaStoreProxyServer) {
-    this.metaStoreProxyServer = metaStoreProxyServer;
-  }
 }