Commented cluster re route job

Flipkart · Feb 2, 2022 · b686f1b · b686f1b
1 parent aaabab6
commit b686f1b
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 32 deletions.
diff --git a/config/local.yml b/config/local.yml
@@ -8,8 +8,8 @@ server:
 
 elasticsearch:
   hosts:
-  - localhost
-  cluster: foxtrot
+  - stg-es201.phonepe.nb6
+  cluster: stg-es67xx
   tableNamePrefix: foxtrot
   getQueryTimeout: 10000
   connectionType: HTTP
@@ -18,10 +18,10 @@ elasticsearch:
 hbase:
   secure : false
   tableName: foxtrot
-  hbaseZookeeperQuorum: localhost:2181
+  hbaseZookeeperQuorum: stg-hdp201.phonepe.nb6:2181
   hbaseZookeeperClientPort: 2181
   seggregatedTablePrefix: foxtrot-
-  hbaseZookeeperZnodeParent: /hbase-test
+  hbaseZookeeperZnodeParent: /hbase-unsecure
 
 cluster:
   name: foxtrot
@@ -48,7 +48,6 @@ cardinality:
 elasticsearchTuningConfig:
   precisionThreshold: 500
   aggregationSize: 10000
-  scrollSize: 100
   scrollTimeInSeconds: 120
   documentsLimitAllowed: 10000
 

diff --git a/foxtrot-core/src/main/java/com/flipkart/foxtrot/core/reroute/ClusterRerouteManager.java b/foxtrot-core/src/main/java/com/flipkart/foxtrot/core/reroute/ClusterRerouteManager.java
@@ -17,6 +17,7 @@
 import org.elasticsearch.action.admin.cluster.reroute.ClusterRerouteResponse;
 import org.elasticsearch.action.admin.indices.stats.IndicesStatsResponse;
 import org.elasticsearch.client.Request;
+import org.elasticsearch.client.Response;
 import org.elasticsearch.cluster.routing.allocation.command.MoveAllocationCommand;
 import org.elasticsearch.index.shard.ShardId;
 import org.joda.time.DateTime;
@@ -48,7 +49,9 @@ public ClusterRerouteManager(
         this.mapper = mapper;
     }
 
-    public void reallocate() {
+    //TODO This needs fixing to correspond to changed response from java high level client
+
+    /*public void reallocate() {
         Map<String, NodeInfo> nodeIdVsNodeInfoMap = new HashMap<>();
         BiMap<String, String> nodeNameVsNodeId = HashBiMap.create();
         this.createNodeInfoMap(nodeIdVsNodeInfoMap);
@@ -106,9 +109,10 @@ private boolean reallocateShard(ShardId shardId, String fromNode, String toNode)
     private void createNodeInfoMap(Map<String, NodeInfo> nodeIdVsNodeInfoMap) {
         nodeIdVsNodeInfoMap.clear();
         val request = new Request("GET", "/_stats");
-        val response = connection.getClient()
+        Response response = connection.getClient()
                 .getLowLevelClient()
                 .performRequest(request);
+
         val indicesStatsResponse = mapper.readValue(EntityUtils.toString(response.getEntity()),
                                                     IndicesStatsResponse.class);
         Arrays.stream(indicesStatsResponse.getShards())
@@ -179,6 +183,6 @@ private Deque<String> getVacantNodeId(
             }
         }
         return vacantNodeIds;
-    }
+    }*/
 
 }
diff --git a/foxtrot-server/src/main/java/com/flipkart/foxtrot/server/resources/ESClusterResource.java b/foxtrot-server/src/main/java/com/flipkart/foxtrot/server/resources/ESClusterResource.java
@@ -2,16 +2,13 @@
 
 import com.flipkart.foxtrot.core.reroute.ClusterRerouteManager;
 import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import ru.vyarus.dropwizard.guice.module.installer.order.Order;
-
 import javax.inject.Inject;
 import javax.inject.Singleton;
 import javax.ws.rs.Consumes;
-import javax.ws.rs.GET;
 import javax.ws.rs.Path;
 import javax.ws.rs.Produces;
 import javax.ws.rs.core.MediaType;
+import ru.vyarus.dropwizard.guice.module.installer.order.Order;
 
 /***
  Created by mudit.g on Sep, 2019

diff --git a/...src/main/java/com/flipkart/foxtrot/server/utils/response/FoxtrotIndicesStatsResponse.java b/...src/main/java/com/flipkart/foxtrot/server/utils/response/FoxtrotIndicesStatsResponse.java