From b532e90ff41c921a8afc97c7da93d006de1c3f1e Mon Sep 17 00:00:00 2001 From: jumao <33013959+whitewjack@users.noreply.github.com> Date: Fri, 13 May 2022 14:31:09 +0800 Subject: [PATCH] ESAdapter Support the same instance cross -library query (#4161) * ESAdapter Support the same instance cross -library query * fix null point ex --- .../alibaba/otter/canal/client/adapter/es/core/ESAdapter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/ESAdapter.java b/client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/ESAdapter.java index 56458fc0..2c1fd466 100644 --- a/client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/ESAdapter.java +++ b/client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/ESAdapter.java @@ -163,14 +163,14 @@ public abstract class ESAdapter implements OuterAdapter { + "-" + 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<>());