Browse Source

fixed issue #440, enableTsdb

agapple 7 years ago
parent
commit
5aed505429

+ 5 - 4
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/AbstractMysqlEventParser.java

@@ -159,10 +159,11 @@ public abstract class AbstractMysqlEventParser extends AbstractEventParser {
 
     public void setTsdbSpringXml(String tsdbSpringXml) {
         this.tsdbSpringXml = tsdbSpringXml;
-
-        if (tableMetaTSDB == null) {
-            // 初始化
-            tableMetaTSDB = TableMetaTSDBBuilder.build(destination, tsdbSpringXml);
+        if (this.enableTsdb) {
+            if (tableMetaTSDB == null) {
+                // 初始化
+                tableMetaTSDB = TableMetaTSDBBuilder.build(destination, tsdbSpringXml);
+            }
         }
     }