Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -23,8 +23,6 @@
import org.apache.doris.common.DdlException;
import org.apache.doris.common.EnvUtils;
import org.apache.doris.common.FeConstants;
import org.apache.doris.common.plugin.CloudPluginDownloader;
import org.apache.doris.common.plugin.CloudPluginDownloader.PluginType;
import org.apache.doris.common.proc.BaseProcResult;
import org.apache.doris.common.util.TimeUtils;
import org.apache.doris.common.util.Util;
Expand Down Expand Up @@ -449,18 +447,6 @@ private static String checkAndReturnDefaultDriverUrl(String driverUrl) {
} else if (oldTargetFile.exists()) {
// File exists in old default directory
return "file://" + oldTargetPath;
} else if (Config.isCloudMode()) {
// Cloud mode: download from cloud to default directory
try {
String downloadedPath = CloudPluginDownloader.downloadFromCloud(
PluginType.JDBC_DRIVERS, driverUrl, targetPath);
return "file://" + downloadedPath;
} catch (Exception e) {
LOG.warn("failed to download jdbc driver url: " + driverUrl, e);
throw new RuntimeException("Cannot download JDBC driver from cloud: " + driverUrl
+ ". Please retry later or check your driver has been uploaded to cloud. Error: "
+ Util.getRootCauseMessage(e));
}
} else {
// File does not exist in both new and old default directory
throw new RuntimeException("JDBC driver file does not exist: " + driverUrl);
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,6 @@
import org.apache.doris.common.ErrorCode;
import org.apache.doris.common.ErrorReport;
import org.apache.doris.common.FeConstants;
import org.apache.doris.common.plugin.CloudPluginDownloader;
import org.apache.doris.common.util.URI;
import org.apache.doris.common.util.Util;
import org.apache.doris.mysql.privilege.PrivPredicate;
Expand Down Expand Up @@ -485,21 +484,6 @@ private String getRealUrl(String url) {

private String checkAndReturnDefaultJavaUdfUrl(String url) {
String defaultUrl = EnvUtils.getDorisHome() + "/plugins/java_udf";
// In cloud mode, try cloud download first
if (Config.isCloudMode()) {
String targetPath = defaultUrl + "/" + url;
try {
String downloadedPath = CloudPluginDownloader.downloadFromCloud(
CloudPluginDownloader.PluginType.JAVA_UDF, url, targetPath);
if (!downloadedPath.isEmpty()) {
return "file://" + downloadedPath;
}
} catch (Exception e) {
throw new RuntimeException("Cannot download UDF from cloud: " + url
+ ". Please retry later or check your UDF has been uploaded to cloud.");
}
}
// Return the file path (original UDF behavior)
return "file://" + defaultUrl + "/" + url;
}

Expand Down

This file was deleted.

Loading
Loading