@@ -93,7 +93,7 @@ public void loadTableFromCatalog() {
             List<Table> tables = database.getTables();
             for (Table table : tables) {
                 if (table.getType() == TableType.ELASTICSEARCH) {
-                    esTables.put(table.getId(), (EsTable) table);
+                    registerTable((EsTable) table);
                 }
             }
         }
 
@@ -36,7 +36,7 @@ public static void setUp() {
     @Test
     public void testTcpMetrics() {
         List<Metric> metrics = MetricRepo.getMetricsByName("snmp");
-        Assert.assertEquals(2, metrics.size());
+        Assert.assertEquals(4, metrics.size());
         for (Metric metric : metrics) {
             GaugeMetric<Long> gm = (GaugeMetric<Long>) metric;
             if (gm.getLabels().get(0).getValue().equals("tcp_retrans_segs")) {
Original file line number	Diff line number	Diff line change
`@@ -93,7 +93,7 @@ public void loadTableFromCatalog() {`
`93`	`93`	`List<Table> tables = database.getTables();`
`94`	`94`	`for (Table table : tables) {`
`95`	`95`	`if (table.getType() == TableType.ELASTICSEARCH) {`
`96`		`- esTables.put(table.getId(), (EsTable) table);`
	`96`	`+ registerTable((EsTable) table);`
`97`	`97`	`}`
`98`	`98`	`}`
`99`	`99`	`}`