From b3ebba1eabc1c63bf8058529715b7bcd9699f9aa Mon Sep 17 00:00:00 2001
From: wuyunfeng01 <wuyunfeng01@baidu.com>
Date: Sun, 28 Jun 2020 11:50:44 +0800
Subject: [PATCH] [Doris On ES][Bug-fix] Sync ES metadata failure after restart
 or upgrade FE

---
 .../org/apache/doris/external/elasticsearch/EsRepository.java   | 2 +-
 fe/src/test/java/org/apache/doris/metric/MetricsTest.java       | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/fe/src/main/java/org/apache/doris/external/elasticsearch/EsRepository.java b/fe/src/main/java/org/apache/doris/external/elasticsearch/EsRepository.java
index fe574ce5b73554..2cfcf4cdb2824b 100644
--- a/fe/src/main/java/org/apache/doris/external/elasticsearch/EsRepository.java
+++ b/fe/src/main/java/org/apache/doris/external/elasticsearch/EsRepository.java
@@ -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);
                 }
             }
         }
diff --git a/fe/src/test/java/org/apache/doris/metric/MetricsTest.java b/fe/src/test/java/org/apache/doris/metric/MetricsTest.java
index b2e9fd6497c615..7ad28e2a84430b 100644
--- a/fe/src/test/java/org/apache/doris/metric/MetricsTest.java
+++ b/fe/src/test/java/org/apache/doris/metric/MetricsTest.java
@@ -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")) {