[inlong] branch master updated: [INLONG-6626][Sort] Use SortClientV2 by default (#6627)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 746ce5a0b [INLONG-6626][Sort] Use SortClientV2 by default (#6627)
746ce5a0b is described below

commit 746ce5a0b9c439565606195d185360fac3953b3b
Author: vernedeng <deng...@pku.edu.cn>
AuthorDate: Sat Nov 26 22:05:31 2022 +0800

    [INLONG-6626][Sort] Use SortClientV2 by default (#6627)
---
 .../main/java/org/apache/inlong/sdk/sort/api/SortClientFactory.java | 3 +++
 .../apache/inlong/sort/standalone/source/sortsdk/SortSdkSource.java | 6 +++---
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/SortClientFactory.java
 
b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/SortClientFactory.java
index 9fad7da4a..8feba4d06 100644
--- 
a/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/SortClientFactory.java
+++ 
b/inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/SortClientFactory.java
@@ -20,6 +20,9 @@ package org.apache.inlong.sdk.sort.api;
 import org.apache.inlong.sdk.sort.impl.SortClientImpl;
 import org.apache.inlong.sdk.sort.impl.SortClientImplV2;
 
+/**
+ * Factory of {@link SortClient}
+ */
 public class SortClientFactory {
 
     /**
diff --git 
a/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/source/sortsdk/SortSdkSource.java
 
b/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/source/sortsdk/SortSdkSource.java
index 34a6bae69..07b372aa9 100644
--- 
a/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/source/sortsdk/SortSdkSource.java
+++ 
b/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/source/sortsdk/SortSdkSource.java
@@ -192,14 +192,14 @@ public final class SortSdkSource extends AbstractSource
             if 
(SortClusterConfigType.FILE.name().equalsIgnoreCase(configType)) {
                 LOG.info("Create sort sdk client in file way:{}", configType);
                 ClassResourceQueryConsumeConfig queryConfig = new 
ClassResourceQueryConsumeConfig();
-                client = SortClientFactory.createSortClient(clientConfig,
+                client = SortClientFactory.createSortClientV2(clientConfig,
                         queryConfig,
                         new MetricReporterImpl(clientConfig),
                         new ManagerReportHandlerImpl());
             } else if 
(SortClusterConfigType.MANAGER.name().equalsIgnoreCase(configType)) {
                 LOG.info("Create sort sdk client in manager way:{}", 
configType);
                 
clientConfig.setManagerApiUrl(ManagerUrlHandler.getSortSourceConfigUrl());
-                client = SortClientFactory.createSortClient(clientConfig);
+                client = SortClientFactory.createSortClientV2(clientConfig);
             } else {
                 LOG.info("Create sort sdk client in custom way:{}", 
configType);
                 // user-defined
@@ -214,7 +214,7 @@ public final class SortSdkSource extends AbstractSource
                     return null;
                 }
                 // if it specifies the type of QueryConsumeConfig.
-                client = SortClientFactory.createSortClient(clientConfig,
+                client = SortClientFactory.createSortClientV2(clientConfig,
                         (QueryConsumeConfig) loaderObject,
                         new MetricReporterImpl(clientConfig),
                         new ManagerReportHandlerImpl());