api path change

gnehil · Aug 9, 2024 · eb722af · eb722af
1 parent b97a67c
commit eb722af
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/spark-load/spark-load-core/src/main/java/org/apache/doris/client/DorisClient.java b/spark-load/spark-load-core/src/main/java/org/apache/doris/client/DorisClient.java
@@ -17,6 +17,7 @@
 
 package org.apache.doris.client;
 
+import org.apache.doris.common.Constants;
 import org.apache.doris.common.LoadInfo;
 import org.apache.doris.common.ResponseEntity;
 import org.apache.doris.common.meta.LoadInfoResponse;
@@ -67,7 +68,7 @@ public static class FeClient {
 
         public static final String BASE_URL = "http://%s%s";
 
-        public static final String INGESTION_LOAD_URL_PATTERN = "/api/ingestion_load/%s/%s";
+        public static final String INGESTION_LOAD_URL_PATTERN = "/api/ingestion_load/%s/%s/%s";
 
         public static final String CREATE_ACTION = "_create";
 
@@ -99,7 +100,7 @@ private String parseAuth(String user, String password) {
         public LoadMeta createIngestionLoad(String db, Map<String, List<String>> tableToPartition, String label,
                                             Map<String, String> properties) throws SparkLoadException {
             try {
-                String path = String.format(INGESTION_LOAD_URL_PATTERN, db, CREATE_ACTION);
+                String path = String.format(INGESTION_LOAD_URL_PATTERN, Constants.DEFAULT_CATALOG, db, CREATE_ACTION);
                 HttpPost httpPost = new HttpPost();
                 addCommonHeaders(httpPost);
                 Map<String, Object> params = new HashMap<>();
@@ -156,7 +157,7 @@ private String executeRequest(HttpRequestBase req, String apiPath, Map<String, S
         public void updateIngestionLoad(String db, Long loadId, Map<String, String> statusInfo)
                 throws SparkLoadException {
 
-            String path = String.format(INGESTION_LOAD_URL_PATTERN, db, UPDATE_ACTION);
+            String path = String.format(INGESTION_LOAD_URL_PATTERN, Constants.DEFAULT_CATALOG, db, UPDATE_ACTION);
             HttpPost httpPost = new HttpPost();
             addCommonHeaders(httpPost);
             Map<String, Object> params = new HashMap<>();

diff --git a/spark-load/spark-load-core/src/main/java/org/apache/doris/common/Constants.java b/spark-load/spark-load-core/src/main/java/org/apache/doris/common/Constants.java
@@ -26,4 +26,6 @@ public interface Constants {
     String HADOOP_KERBEROS_PRINCIPAL = "hadoop.kerberos.principal";
     String HADOOP_KERBEROS_KEYTAB = "hadoop.kerberos.keytab";
 
+    String DEFAULT_CATALOG = "internal";
+
 }