You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by et...@apache.org on 2021/08/16 19:18:03 UTC

[storm] branch master updated: [STORM-3388] Followup fix: HdfsOciResourcesLocalizer should create necessary nonexistent parent directoires (#3407)

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 <et...@gmail.com>
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);
                 }