[ambari] branch branch-2.6 updated: AMBARI-25230 improve fast-hdfs tool exception handling (benyoka) (#2915)

[benyoka]

This is an automated email from the ASF dual-hosted git repository.

benyoka pushed a commit to branch branch-2.6
in repository https://gitbox.apache.org/repos/asf/ambari.git


The following commit(s) were added to refs/heads/branch-2.6 by this push:
     new 34ecd4c  AMBARI-25230 improve fast-hdfs tool exception handling 
(benyoka) (#2915)
34ecd4c is described below

commit 34ecd4ceacbe905dca52e9118a7d327420ab285c
Author: benyoka <beny...@users.noreply.github.com>
AuthorDate: Thu Apr 11 13:47:13 2019 +0200

    AMBARI-25230 improve fast-hdfs tool exception handling (benyoka) (#2915)
---
 .../main/java/org/apache/ambari/fast_hdfs_resource/Runner.java | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/contrib/fast-hdfs-resource/src/main/java/org/apache/ambari/fast_hdfs_resource/Runner.java
 
b/contrib/fast-hdfs-resource/src/main/java/org/apache/ambari/fast_hdfs_resource/Runner.java
index 98119b0..ab0d08a 100644
--- 
a/contrib/fast-hdfs-resource/src/main/java/org/apache/ambari/fast_hdfs_resource/Runner.java
+++ 
b/contrib/fast-hdfs-resource/src/main/java/org/apache/ambari/fast_hdfs_resource/Runner.java
@@ -31,7 +31,7 @@ import com.google.gson.Gson;
 
 public class Runner {
   public static void main(String[] args)
-      throws IOException, URISyntaxException {
+      throws IOException, URISyntaxException, Exception {
     // 1 - Check arguments
     if (args.length != 1) {
       System.err.println("Incorrect number of arguments. Please provide:\n"
@@ -65,7 +65,7 @@ public class Runner {
       // 4 - Connect to HDFS
       System.out.println("Using filesystem uri: " + 
FileSystem.getDefaultUri(conf).toString());
       dfs.initialize(FileSystem.getDefaultUri(conf), conf);
-      
+
       for (Resource resource : resources) {
         System.out.println("Creating: " + resource);
 
@@ -104,12 +104,14 @@ public class Runner {
     catch(Exception e) {
        System.out.println("Exception occurred, Reason: " + e.getMessage());
        e.printStackTrace();
+       throw e;
     }
     finally {
-      dfs.close();
+      if (null != dfs) {
+        dfs.close();
+      }
     }
 
     System.out.println("All resources created.");
   }
-
 }