fix: dependency scope

PeterZh6 · Sep 29, 2024 · 47e8beb · 47e8beb
1 parent eb4c0d9
commit 47e8beb
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 7 deletions.
diff --git a/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/pom.xml b/inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/pom.xml
@@ -175,21 +175,23 @@
             <groupId>org.apache.pulsar</groupId>
             <artifactId>pulsar-client-api</artifactId>
             <version>3.0.2</version>
+            <scope>test</scope>
         </dependency>
 
         <!-- Elasticsearch client dependencies -->
         <dependency>
             <groupId>org.elasticsearch.client</groupId>
             <artifactId>elasticsearch-rest-client</artifactId>
             <version>7.10.2</version>
+            <scope>test</scope>
         </dependency>
         <dependency>
             <groupId>co.elastic.clients</groupId>
             <artifactId>elasticsearch-java</artifactId>
-            <version>8.9.0</version> <!-- 使用最新版本或与你的 Elasticsearch 版本兼容的版本 -->
+            <version>8.9.0</version>
+            <scope>test</scope>
         </dependency>
 
-
     </dependencies>
 
     <build>

diff --git a/...-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Pulsar2ElasticsearchTest.java b/...-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Pulsar2ElasticsearchTest.java
@@ -17,15 +17,16 @@
 
 package org.apache.inlong.sort.tests;
 
+import org.apache.inlong.sort.tests.utils.FlinkContainerTestEnvJRE8;
+import org.apache.inlong.sort.tests.utils.TestUtils;
+
 import co.elastic.clients.elasticsearch.ElasticsearchClient;
 import co.elastic.clients.elasticsearch.core.SearchRequest;
 import co.elastic.clients.elasticsearch.core.SearchResponse;
 import co.elastic.clients.elasticsearch.core.search.Hit;
 import co.elastic.clients.json.jackson.JacksonJsonpMapper;
 import co.elastic.clients.transport.rest_client.RestClientTransport;
 import org.apache.http.HttpHost;
-import org.apache.inlong.sort.tests.utils.FlinkContainerTestEnvJRE8;
-import org.apache.inlong.sort.tests.utils.TestUtils;
 import org.apache.pulsar.client.api.Producer;
 import org.apache.pulsar.client.api.PulsarClient;
 import org.apache.pulsar.client.api.Schema;
@@ -109,7 +110,8 @@ private void initializePulsarTopic() {
 
     private void initializeElasticsearchIndex() {
         // 使用 Elasticsearch 客户端创建索引
-        try (RestClient restClient = RestClient.builder(new HttpHost("localhost", ELASTICSEARCH.getMappedPort(9200), "http")).build()) {
+        try (RestClient restClient =
+                RestClient.builder(new HttpHost("localhost", ELASTICSEARCH.getMappedPort(9200), "http")).build()) {
             RestClientTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());
             ElasticsearchClient client = new ElasticsearchClient(transport);
 
@@ -147,12 +149,14 @@ public void testPulsarToElasticsearch() throws Exception {
         }
 
         // 查询 Elasticsearch 数据
-        try (RestClient restClient = RestClient.builder(new HttpHost("localhost", ELASTICSEARCH.getMappedPort(9200), "http")).build()) {
+        try (RestClient restClient =
+                RestClient.builder(new HttpHost("localhost", ELASTICSEARCH.getMappedPort(9200), "http")).build()) {
             RestClientTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());
             ElasticsearchClient client = new ElasticsearchClient(transport);
 
             // Search Request
-            SearchRequest searchRequest = new SearchRequest.Builder().index("test-index").query(q -> q.matchAll(m -> m)).build();
+            SearchRequest searchRequest =
+                    new SearchRequest.Builder().index("test-index").query(q -> q.matchAll(m -> m)).build();
             SearchResponse<Object> searchResponse = client.search(searchRequest, Object.class);
 
             List<Hit<Object>> hits = searchResponse.hits().hits();