This is an automated email from the ASF dual-hosted git repository.
ethanli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
The following commit(s) were added to refs/heads/master by this push:
new 16ca56e [STORM-3388] Followup fix: HdfsOciResourcesLocalizer should
create necessary nonexistent parent directoires (#3407)
16ca56e is described below
commit 16ca56eae2c88db42293e926f764abfc2139f26b
Author: Meng (Ethan) Li <[email protected]>
AuthorDate: Mon Aug 16 14:17:53 2021 -0500
[STORM-3388] Followup fix: HdfsOciResourcesLocalizer should create
necessary nonexistent parent directoires (#3407)
---
.../java/org/apache/storm/container/oci/HdfsOciResourcesLocalizer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/external/storm-hdfs-oci/src/main/java/org/apache/storm/container/oci/HdfsOciResourcesLocalizer.java
b/external/storm-hdfs-oci/src/main/java/org/apache/storm/container/oci/HdfsOciResourcesLocalizer.java
index 45b5b40..56ffa95 100644
---
a/external/storm-hdfs-oci/src/main/java/org/apache/storm/container/oci/HdfsOciResourcesLocalizer.java
+++
b/external/storm-hdfs-oci/src/main/java/org/apache/storm/container/oci/HdfsOciResourcesLocalizer.java
@@ -89,7 +89,7 @@ public class HdfsOciResourcesLocalizer implements
OciResourcesLocalizerInterface
// this allows the operation to be atomic in case the supervisor
dies.
File workingDir = new File(dst.getParent() + "/working");
if (!workingDir.exists()) {
- boolean dirCreated = workingDir.mkdir();
+ boolean dirCreated = workingDir.mkdirs();
if (!dirCreated) {
throw new IOException("Couldn't create the directory: " +
workingDir);
}