(seatunnel) branch dev updated: [BUG][Connector-V2] Fixed conversion exception of elasticsearch array format (#5825)

[fanjia]

This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 64f19f25d9 [BUG][Connector-V2] Fixed conversion exception of 
elasticsearch array format (#5825)
64f19f25d9 is described below

commit 64f19f25d93c1e98975f3b94243274814290b1e2
Author: Carl-Zhou-CN <67902676+carl-zhou...@users.noreply.github.com>
AuthorDate: Fri Nov 10 17:52:00 2023 +0800

    [BUG][Connector-V2] Fixed conversion exception of elasticsearch array 
format (#5825)
---
 .../elasticsearch/serialize/source/DefaultSeaTunnelRowDeserializer.java | 2 +-
 .../apache/seatunnel/e2e/connector/elasticsearch/ElasticsearchIT.java   | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/source/DefaultSeaTunnelRowDeserializer.java
 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/source/DefaultSeaTunnelRowDeserializer.java
index eb9b012e0e..2d23b7dc51 100644
--- 
a/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/source/DefaultSeaTunnelRowDeserializer.java
+++ 
b/seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/source/DefaultSeaTunnelRowDeserializer.java
@@ -168,7 +168,7 @@ public class DefaultSeaTunnelRowDeserializer implements 
SeaTunnelRowDeserializer
             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/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-elasticsearch-e2e/src/test/java/org/apache/seatunnel/e2e/connector/elasticsearch/ElasticsearchIT.java
 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-elasticsearch-e2e/src/test/java/org/apache/seatunnel/e2e/connector/elasticsearch/ElasticsearchIT.java
index 793fa25133..f64097ac6e 100644
--- 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-elasticsearch-e2e/src/test/java/org/apache/seatunnel/e2e/connector/elasticsearch/ElasticsearchIT.java
+++ 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-elasticsearch-e2e/src/test/java/org/apache/seatunnel/e2e/connector/elasticsearch/ElasticsearchIT.java
@@ -157,7 +157,7 @@ public class ElasticsearchIT extends TestSuiteBase 
implements TestResource {
             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"),