Skip to content

Commit b532e90

Browse files
authored
ESAdapter Support the same instance cross -library query (#4161)
* ESAdapter Support the same instance cross -library query * fix null point ex
1 parent e48bc35 commit b532e90

File tree

1 file changed

+2
-2
lines changed
  • client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core

1 file changed

+2
-2
lines changed

client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/ESAdapter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -163,14 +163,14 @@ public void addSyncConfigToCache(String configName, ESSyncConfig config) {
163163
+ "-"
164164
+ StringUtils.trimToEmpty(config.getGroupId())
165165
+ "_"
166-
+ schema
166+
+ tableItem.getSchema() == null ? schema : tableItem.getSchema()
167167
+ "-"
168168
+ tableItem.getTableName(),
169169
k -> new ConcurrentHashMap<>());
170170
} else {
171171
esSyncConfigMap = dbTableEsSyncConfig.computeIfAbsent(StringUtils.trimToEmpty(config.getDestination())
172172
+ "_"
173-
+ schema
173+
+ tableItem.getSchema() == null ? schema : tableItem.getSchema()
174174
+ "-"
175175
+ tableItem.getTableName(),
176176
k -> new ConcurrentHashMap<>());

0 commit comments

Comments
 (0)