Skip to content

Commit

Permalink
定时保存snapshot到DB的逻辑中,schema名称获取错误,在有配置canal.instance.filter.regex时,由于对…
Browse files Browse the repository at this point in the history
…应的table无法被匹配中,导致compareTableMetaDbAndMemory方法不被执行 (#3693)

* 避免重复订阅zk变更状态

* Update DatabaseTableMeta.java

获取schema的名称

* Update CanalController.java
  • Loading branch information
happyrita authored Oct 9, 2021
1 parent d67bea8 commit 9e11c3c
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -301,7 +301,7 @@ private boolean applySnapshotToDB(EntryPosition position, boolean init) {
boolean compareAll = true;
for (Schema schema : tmpMemoryTableMeta.getRepository().getSchemas()) {
for (String table : schema.showTables()) {
String fullName = schema + "." + table;
String fullName = schema.getName() + "." + table;
if (blackFilter == null || !blackFilter.filter(fullName)) {
if (filter == null || filter.filter(fullName)) {
// issue : https://github.com/alibaba/canal/issues/1168
Expand Down

0 comments on commit 9e11c3c

Please sign in to comment.