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 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 docs = scrollResult.getDocs().stream()