From 5aed505429694130a76115b7a4219b1a36f53346 Mon Sep 17 00:00:00 2001 From: agapple Date: Fri, 8 Dec 2017 23:21:40 +0800 Subject: [PATCH] fixed issue #440, enableTsdb --- .../parse/inbound/mysql/AbstractMysqlEventParser.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/AbstractMysqlEventParser.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/AbstractMysqlEventParser.java index 6d69a836..422bae37 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/AbstractMysqlEventParser.java +++ b/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); + } } }