[Connector-V2] [ElasticSearch] Fix ElasticSearch Connector V2 Bug (#2817)

Author: Hisoka-X

docs/en/connector-v2/sink/Elasticsearch.md

@@ -19,15 +19,15 @@ Engine Supported
 
 ## Options
 
-| name              | type   | required | default value | 
-|-------------------| ------ | -------- |---------------|
-| hosts             | array  | yes      | -             |
-| index             | string | yes      | -             |
-| index_type        | string | no       |               |
-| username          | string | no       |               |
-| password          | string | no       |               | 
-| max_retry_size    | int    | no       | 3             |
-| max_batch_size    | int    | no       | 10            |
+| name           | type   | required | default value | 
+|----------------|--------|----------|---------------|
+| hosts          | array  | yes      | -             |
+| index          | string | yes      | -             |
+| index_type     | string | no       |               |
+| username       | string | no       |               |
+| password       | string | no       |               | 
+| max_retry_size | int    | no       | 3             |
+| max_batch_size | int    | no       | 10            |
 
 
 
@@ -36,6 +36,7 @@ Engine Supported
 
 ### index [string]
 `Elasticsearch`  `index` name.Index support contains variables of field name,such as `seatunnel_${age}`,and the field must appear at seatunnel row.
+If not, we will treat it as a normal index.
 
 ### index_type [string]
 `Elasticsearch` index type, it is recommended not to specify in elasticsearch 6 and above

seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/AbstractSingleSplitSource.java

@@ -29,7 +29,7 @@ public abstract class AbstractSingleSplitSource<T> implements SeaTunnelSource<T,
 
     @Override
     public final AbstractSingleSplitReader<T> createReader(SourceReader.Context readerContext) throws Exception {
-        checkArgument(readerContext.getIndexOfSubtask() == 0, "A single split source allows only one single reader to be created.");
+        checkArgument(readerContext.getIndexOfSubtask() == 0, "A single split source allows only one single reader to be created. Please make sure source parallelism = 1");
         return createReader(new SingleSplitReaderContext(readerContext));
     }
 

seatunnel-connectors-v2/connector-elasticsearch/pom.xml

@@ -32,6 +32,7 @@
     <properties>
         <elasticsearch-rest-client.version>7.5.1</elasticsearch-rest-client.version>
         <jackson.databind.version>2.12.6</jackson.databind.version>
+        <jackson-datatype-jsr310.version>2.13.3</jackson-datatype-jsr310.version>
     </properties>
 
     <dependencies>
@@ -45,6 +46,11 @@
             <artifactId>jackson-databind</artifactId>
             <version>${jackson.databind.version}</version>
         </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.datatype</groupId>
+            <artifactId>jackson-datatype-jsr310</artifactId>
+            <version>${jackson-datatype-jsr310.version}</version>
+        </dependency>
     </dependencies>
 
 </project>