(doris-spark-connector) branch master updated: [improve] remove table path from 2pc url (#154)

[diwu]

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

diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-spark-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new e118070  [improve] remove table path from 2pc url (#154)
e118070 is described below

commit e118070af5f0232a616b2c79df5cadef05d32e1a
Author: gnehil <adamlee...@gmail.com>
AuthorDate: Mon Nov 6 18:22:45 2023 +0800

    [improve] remove table path from 2pc url (#154)
---
 .../main/java/org/apache/doris/spark/load/DorisStreamLoad.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java
 
b/spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java
index 2f365a8..69287d8 100644
--- 
a/spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java
+++ 
b/spark-doris-connector/src/main/java/org/apache/doris/spark/load/DorisStreamLoad.java
@@ -82,9 +82,9 @@ public class DorisStreamLoad implements Serializable {
 
     private final static List<String> DORIS_SUCCESS_STATUS = new 
ArrayList<>(Arrays.asList("Success", "Publish Timeout"));
 
-    private static final String loadUrlPattern = 
"http://%s/api/%s/%s/_stream_load?";;
+    private static final String loadUrlPattern = 
"http://%s/api/%s/%s/_stream_load";;
 
-    private static final String abortUrlPattern = 
"http://%s/api/%s/%s/_stream_load_2pc?";;
+    private static final String abortUrlPattern = 
"http://%s/api/%s/_stream_load_2pc";;
 
     private String loadUrlStr;
     private final String db;
@@ -270,7 +270,7 @@ public class DorisStreamLoad implements Serializable {
         try (CloseableHttpClient client = getHttpClient()) {
 
             String backend = getBackend();
-            String abortUrl = String.format(abortUrlPattern, backend, db, tbl);
+            String abortUrl = String.format(abortUrlPattern, backend, db);
             HttpPut httpPut = new HttpPut(abortUrl);
             addCommonHeader(httpPut);
             httpPut.setHeader("txn_operation", "commit");
@@ -358,7 +358,7 @@ public class DorisStreamLoad implements Serializable {
     private void doAbort(Consumer<HttpPut> putConsumer) throws 
StreamLoadException {
 
         try (CloseableHttpClient client = getHttpClient()) {
-            String abortUrl = String.format(abortUrlPattern, getBackend(), db, 
tbl);
+            String abortUrl = String.format(abortUrlPattern, getBackend(), db);
             HttpPut httpPut = new HttpPut(abortUrl);
             addCommonHeader(httpPut);
             httpPut.setHeader("txn_operation", "abort");


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org