diff --git a/tis-plugin/src/main/java/com/qlangtech/tis/datax/impl/DataxProcessor.java b/tis-plugin/src/main/java/com/qlangtech/tis/datax/impl/DataxProcessor.java index 312c19bfb..c3bb7949d 100644 --- a/tis-plugin/src/main/java/com/qlangtech/tis/datax/impl/DataxProcessor.java +++ b/tis-plugin/src/main/java/com/qlangtech/tis/datax/impl/DataxProcessor.java @@ -169,7 +169,10 @@ public TableAliasMapper getTabAlias(IPluginContext pluginCtx) { // || (isReaderUnStructed = this.isReaderUnStructed(null))) { if ((this.isRDBMS2RDBMS(pluginCtx)) - || (isReaderUnStructed = this.isReaderUnStructed(pluginCtx))) { + || (isReaderUnStructed = this.isReaderUnStructed(pluginCtx)) + // 支持ElasticSearch + || CollectionUtils.isNotEmpty(tableMaps) + ) { if (CollectionUtils.isEmpty(tableMaps)) { return TableAliasMapper.Null;