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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
