Skip to content

Commit 81754d2

Browse files
committed
filter one indices case
Signed-off-by: xinyual <xinyual@amazon.com>
1 parent a617b00 commit 81754d2

1 file changed

Lines changed: 8 additions & 2 deletions

File tree

opensearch/src/main/java/org/opensearch/sql/opensearch/request/system/OpenSearchDescribeIndexRequest.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -102,8 +102,14 @@ public Map<String, OpenSearchDataType> getFieldTypes() {
102102
Map<String, OpenSearchDataType> fieldTypes = new HashMap<>();
103103
Map<String, IndexMapping> indexMappings =
104104
client.getIndexMappings(getLocalIndexNames(indexName.getIndexNames()));
105-
for (IndexMapping indexMapping : indexMappings.values()) {
106-
mergeObjectAndArrayInsideMap(fieldTypes, indexMapping.getFieldMappings());
105+
if (indexMappings.size() <= 1) {
106+
for (IndexMapping indexMapping : indexMappings.values()) {
107+
fieldTypes.putAll(indexMapping.getFieldMappings());
108+
}
109+
} else {
110+
for (IndexMapping indexMapping : indexMappings.values()) {
111+
mergeObjectAndArrayInsideMap(fieldTypes, indexMapping.getFieldMappings());
112+
}
107113
}
108114
return fieldTypes;
109115
}

0 commit comments

Comments
 (0)