From 2b89960bd689093e0e80b250b2d20fec8f6f249d Mon Sep 17 00:00:00 2001 From: mozhenghua Date: Fri, 5 May 2023 15:25:27 +0800 Subject: [PATCH] modify getTabAlias for tableMaps is not empty --- .../java/com/qlangtech/tis/datax/impl/DataxProcessor.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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;