From 0882519ed19f6a66fd1f319c598a855696f2ef17 Mon Sep 17 00:00:00 2001 From: ChineseTony Date: Fri, 27 May 2022 20:23:35 +0800 Subject: [PATCH] [warehouse]bugfix: fix td-engine store table not exist log (#150) --- .../com/usthe/warehouse/store/TdEngineDataStorage.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/warehouse/src/main/java/com/usthe/warehouse/store/TdEngineDataStorage.java b/warehouse/src/main/java/com/usthe/warehouse/store/TdEngineDataStorage.java index 68867ccfe50..1a61f4b8c9b 100644 --- a/warehouse/src/main/java/com/usthe/warehouse/store/TdEngineDataStorage.java +++ b/warehouse/src/main/java/com/usthe/warehouse/store/TdEngineDataStorage.java @@ -53,6 +53,9 @@ public class TdEngineDataStorage implements DisposableBean { private static final String QUERY_INSTANCE_SQL = "SELECT DISTINCT instance FROM %s WHERE ts >= now - 1w"; + private static final String TABLE_NOT_EXIST + = "Table does not exist"; + public TdEngineDataStorage(WarehouseWorkerPool workerPool, WarehouseProperties properties, MetricsDataExporter dataExporter) { this.workerPool = workerPool; @@ -266,7 +269,10 @@ public Map> getHistoryMetricData(Long monitorId, String app, resultSet.close(); return instanceValuesMap; } catch (SQLException sqlException) { - log.warn(sqlException.getMessage()); + String msg = sqlException.getMessage(); + if (msg != null && !msg.contains(TABLE_NOT_EXIST)) { + log.warn(sqlException.getMessage()); + } } catch (Exception e) { log.error(e.getMessage(), e); } finally {