From c8ef9552ec40fbd8eb032f4d8efa2a9edf2f93c8 Mon Sep 17 00:00:00 2001 From: "jianghang.loujh" Date: Fri, 13 Oct 2023 14:05:15 +0800 Subject: [PATCH] fixed #4907 , reset tsdb build context --- .../parse/inbound/mysql/AbstractMysqlEventParser.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 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 df5234c0..0c863bd5 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 @@ -1,6 +1,7 @@ package com.alibaba.otter.canal.parse.inbound.mysql; import java.nio.charset.Charset; +import java.util.Properties; import java.util.concurrent.atomic.AtomicLong; import com.alibaba.otter.canal.filter.CanalEventFilter; @@ -185,9 +186,10 @@ public abstract class AbstractMysqlEventParser extends AbstractEventParser { throw new CanalParseException(e); } finally { // reset - System.setProperty("canal.instance.tsdb.url", ""); - System.setProperty("canal.instance.tsdb.dbUsername", ""); - System.setProperty("canal.instance.tsdb.dbPassword", ""); + Properties props = System.getProperties(); + props.remove("canal.instance.tsdb.url"); + props.remove("canal.instance.tsdb.dbUsername"); + props.remove("canal.instance.tsdb.dbPassword"); } }