[ https://issues.apache.org/jira/browse/FLINK-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14499851#comment-14499851 ]
ASF GitHub Bot commented on FLINK-1891: --------------------------------------- Github user matadorhong commented on a diff in the pull request: https://github.com/apache/flink/pull/601#discussion_r28594789 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java --- @@ -64,15 +64,19 @@ * @return the storage directory used by a BLOB service */ static File initStorageDirectory(String storageDirectory) { - File baseDir = storageDirectory != null ? - new File(storageDirectory) : - new File(System.getProperty("java.io.tmpdir")); + File baseDir; + if (storageDirectory == null || storageDirectory.isEmpty()) { --- End diff -- Yeah, you are right. Thank for you notes.I have change it. > Add isEmpty check when the input dir > ------------------------------------ > > Key: FLINK-1891 > URL: https://issues.apache.org/jira/browse/FLINK-1891 > Project: Flink > Issue Type: Bug > Components: Local Runtime > Affects Versions: master > Reporter: Sibao Hong > Assignee: Sibao Hong > > Add the input storageDirectory empty check, if input of storageDirectory is > empty, we should use tmp as the base dir -- This message was sent by Atlassian JIRA (v6.3.4#6332)