From f2d86c11debaf1a6cc5fc609590d9b5970c9e0c8 Mon Sep 17 00:00:00 2001
From: CosmosNi <627165587@qq.com>
Date: Tue, 26 Mar 2024 19:03:51 +0800
Subject: [PATCH] [Bug][Connector-v2][ElasticsearchSource] Fix behavior when
 source empty. [Improve][Connector-v2][ElasticsearchSource] Support
 SourceConfig.SOURCE field empty.

---
 .../seatunnel/e2e/connector/elasticsearch/ElasticsearchIT.java | 3 ---
 1 file changed, 3 deletions(-)

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 c5e896017ce..bca6b0f0230 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
@@ -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()