ESAdapter Support the same instance cross -library query (#4161)

* ESAdapter Support the same instance cross -library query * fix null point ex
alibaba · May 13, 2022 · b532e90 · b532e90
1 parent e48bc35
commit b532e90
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...dapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/ESAdapter.java b/...dapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/ESAdapter.java
@@ -163,14 +163,14 @@ public void addSyncConfigToCache(String configName, ESSyncConfig config) {
                                                                           + "-"
                                                                           + StringUtils.trimToEmpty(config.getGroupId())
                                                                           + "_"
-                                                                          + schema
+                                                                          + tableItem.getSchema() == null ? schema : tableItem.getSchema()
                                                                           + "-"
                                                                           + tableItem.getTableName(),
                         k -> new ConcurrentHashMap<>());
                 } else {
                     esSyncConfigMap = dbTableEsSyncConfig.computeIfAbsent(StringUtils.trimToEmpty(config.getDestination())
                                                                           + "_"
-                                                                          + schema
+                                                                          + tableItem.getSchema() == null ? schema : tableItem.getSchema()
                                                                           + "-"
                                                                           + tableItem.getTableName(),
                         k -> new ConcurrentHashMap<>());