Skip to content

Commit 9e715b9

Browse files
committedOct 13, 2023
fixed #4907 , reset tsdb build context
1 parent ea89492 commit 9e715b9

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed
 

‎parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/AbstractMysqlEventParser.java

+5-3
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package com.alibaba.otter.canal.parse.inbound.mysql;
22

33
import java.nio.charset.Charset;
4+
import java.util.Properties;
45
import java.util.concurrent.atomic.AtomicLong;
56

67
import com.alibaba.otter.canal.filter.CanalEventFilter;
@@ -185,9 +186,10 @@ protected synchronized void buildTableMetaTSDB(String tsdbSpringXml) {
185186
throw new CanalParseException(e);
186187
} finally {
187188
// reset
188-
System.setProperty("canal.instance.tsdb.url", "");
189-
System.setProperty("canal.instance.tsdb.dbUsername", "");
190-
System.setProperty("canal.instance.tsdb.dbPassword", "");
189+
Properties props = System.getProperties();
190+
props.remove("canal.instance.tsdb.url");
191+
props.remove("canal.instance.tsdb.dbUsername");
192+
props.remove("canal.instance.tsdb.dbPassword");
191193
}
192194
}
193195

0 commit comments

Comments
 (0)