diff --git a/client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java b/client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java index 266e0b5b26..b63fc9a55c 100644 --- a/client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java +++ b/client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java @@ -150,7 +150,13 @@ public MappingMetaData getMapping(String index, String type) { logger.error(e.getMessage(), e); return null; } - mappingMetaData = mappings.get(index).get(type); + + //通过别名查询mapping返回的是真实索引名称,mappings.get(index)返回null,为兼容别名情况修改如下: + ImmutableOpenMap esIndex = mappings.get(index); + if(esIndex == null){ + esIndex = mappings.valuesIt().next(); + } + mappingMetaData = esIndex.get(type); } return mappingMetaData; }