Storage service config does not exist! #13659
Unanswered
xujiangfeng
asked this question in
Q&A
Replies: 2 comments
-
我也是遇到了这个问题,可以指教一下吗? |
Beta Was this translation helpful? Give feedback.
0 replies
-
Which version you are using? |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
org.apache.dolphinscheduler.common.exception.StorageOperateNoConfiguredException: Storage service config does not exist!
at org.apache.dolphinscheduler.server.worker.utils.TaskExecutionCheckerUtils.downloadResourcesIfNeeded(TaskExecutionCheckerUtils.java:115)
at org.apache.dolphinscheduler.server.worker.runner.WorkerTaskExecuteRunnable.beforeExecute(WorkerTaskExecuteRunnable.java:216)
at org.apache.dolphinscheduler.server.worker.runner.WorkerTaskExecuteRunnable.run(WorkerTaskExecuteRunnable.java:170)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:131)
at com.google.common.util.concurrent.InterruptibleTask.run(InterruptibleTask.java:74)
at com.google.common.util.concurrent.TrustedListenableFutureTask.run(TrustedListenableFutureTask.java:82)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
[INFO] 2023-03-01 06:19:28.458 +0000 - Get a exception when execute the task, will send the task execute result to master, the current task execute result is TaskExecutionStatus{code=6, desc='failure'}
我按照官方文档进行配置部署,如果需要使用资源中心的相关功能,需要配置了api-server/conf/common.properties和worker-server/conf/common.properties两个配置文件中的文件存储类型及相关配置,我对照本地存储方式进行了配置,结果在web端可以完成文件夹创建和文件创建上传,在工作流定义过程中也可以进行引用,但是在运行工作流时却提示“Storage service config does not exist!”,我使用idea的全文检索功能,检索源码发现如下代码:
if (!downloadFiles.isEmpty() && !PropertyUtils.getResUploadStartupState()) {
throw new StorageOperateNoConfiguredException("Storage service config does not exist!");
}
public static boolean getResUploadStartupState() {
String resUploadStartupType = PropertyUtils.getUpperCaseString(Constants.RESOURCE_STORAGE_TYPE);
ResUploadType resUploadType = ResUploadType.valueOf(
Strings.isNullOrEmpty(resUploadStartupType) ? ResUploadType.NONE.name() : resUploadStartupType);
return resUploadType != ResUploadType.NONE;
}
public static String getUpperCaseString(String key) {
String val = getString(key);
return Strings.isNullOrEmpty(val) ? val : val.toUpperCase();
}
public static String getString(String key) {
return properties.getProperty(key.trim());
}
static {
loadPropertyFile(COMMON_PROPERTIES_PATH);
}
public static final String COMMON_PROPERTIES_PATH = "/common.properties";
public static final String RESOURCE_STORAGE_TYPE = "resource.storage.type";
根据代码含义我就更疑惑了,我明明已经配置了为啥会不生效呢?
请大神指导!
Beta Was this translation helpful? Give feedback.
All reactions