[BUG][Connector-V2] Fixed conversion exception of elasticsearch array…

… format (#5825)
apache · Nov 10, 2023 · 64f19f2 · 64f19f2
1 parent 50fe637
commit 64f19f2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/.../connectors/seatunnel/elasticsearch/serialize/source/DefaultSeaTunnelRowDeserializer.java b/.../connectors/seatunnel/elasticsearch/serialize/source/DefaultSeaTunnelRowDeserializer.java
@@ -168,7 +168,7 @@ Object convertValue(SeaTunnelDataType<?> fieldType, String fieldValue)
             Object arr = Array.newInstance(elementType.getTypeClass(), stringList.size());
             for (int i = 0; i < stringList.size(); i++) {
                 Object convertValue = convertValue(elementType, stringList.get(i));
-                Array.set(arr, 0, convertValue);
+                Array.set(arr, i, convertValue);
             }
             return arr;
         } else if (fieldType instanceof MapType) {

diff --git a/...h-e2e/src/test/java/org/apache/seatunnel/e2e/connector/elasticsearch/ElasticsearchIT.java b/...h-e2e/src/test/java/org/apache/seatunnel/e2e/connector/elasticsearch/ElasticsearchIT.java
@@ -157,7 +157,7 @@ private List<String> generateTestDataSet() throws JsonProcessingException {
             Object[] values =
                     new Object[] {
                         Collections.singletonMap("key", Short.parseShort(String.valueOf(i))),
-                        new Byte[] {Byte.parseByte("1")},
+                        new Byte[] {Byte.parseByte("1"), Byte.parseByte("2"), Byte.parseByte("3")},
                         "string",
                         Boolean.FALSE,
                         Byte.parseByte("1"),