This is an automated email from the ASF dual-hosted git repository.
lidongdai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new 966201af86 [BUG][Resource Center] NPE caused by uninitialized
hdfsProperties (#13540)
966201af86 is described below
commit 966201af8648031c19246824e69b0f0b847adf33
Author: Aaron Wang <[email protected]>
AuthorDate: Sat Feb 11 13:12:44 2023 +0800
[BUG][Resource Center] NPE caused by uninitialized hdfsProperties (#13540)
* [BUG][Resource Center] NPE caused by uninitialized hdfsProperties
* [BUG][Resource Center] NPE caused by uninitialized hdfsProperties
---
.../dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/dolphinscheduler-storage-plugin/dolphinscheduler-storage-hdfs/src/main/java/org/apache/dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java
b/dolphinscheduler-storage-plugin/dolphinscheduler-storage-hdfs/src/main/java/org/apache/dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java
index 80edb15455..a416cd07d6 100644
---
a/dolphinscheduler-storage-plugin/dolphinscheduler-storage-hdfs/src/main/java/org/apache/dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java
+++
b/dolphinscheduler-storage-plugin/dolphinscheduler-storage-hdfs/src/main/java/org/apache/dolphinscheduler/plugin/storage/hdfs/HdfsStorageOperator.java
@@ -76,7 +76,7 @@ import com.google.common.cache.LoadingCache;
@Slf4j
public class HdfsStorageOperator implements Closeable, StorageOperate {
- private static HdfsStorageProperties hdfsProperties;
+ private static HdfsStorageProperties hdfsProperties = new
HdfsStorageProperties();
private static final String HADOOP_UTILS_KEY = "HADOOP_UTILS_KEY";
private static final LoadingCache<String, HdfsStorageOperator> cache =
CacheBuilder
@@ -85,7 +85,7 @@ public class HdfsStorageOperator implements Closeable,
StorageOperate {
.build(new CacheLoader<String, HdfsStorageOperator>() {
@Override
- public HdfsStorageOperator load(String key) throws Exception {
+ public HdfsStorageOperator load(String key) {
return new HdfsStorageOperator(hdfsProperties);
}
});