[Bug][Connector-v2][ElasticsearchSource] Fix behavior when source empty.

[Improve][Connector-v2][ElasticsearchSource] Support SourceConfig.SOURCE field empty.
CosmosNi · Mar 26, 2024 · f2d86c1 · f2d86c1
1 parent b113a88
commit f2d86c1
Showing 1 changed file with 0 additions and 3 deletions.
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
@@ -218,9 +218,6 @@ private List<String> readSinkDataWithOutSchema() throws InterruptedException {
                             x.remove("_index");
                             x.remove("_type");
                             x.remove("_id");
-                            // I don’t know if converting the test cases in this way complies with
-                            // the CI specification
-                            x.replace("c_timestamp", Long.valueOf(x.get("c_timestamp").toString()));
                         });
         List<String> docs =
                 scrollResult.getDocs().stream()