hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From msi...@apache.org
Subject [hadoop] branch trunk updated: HDDS-1534. freon should return non-zero exit code on failure. Contributed by Nilotpal Nandi.
Date Tue, 28 May 2019 02:23:51 GMT
This is an automated email from the ASF dual-hosted git repository.

msingh pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 72dd790  HDDS-1534. freon should return non-zero exit code on failure. Contributed
by Nilotpal Nandi.
72dd790 is described below

commit 72dd79015a00d29015bec30f1bfc7ededab6a2b1
Author: Mukul Kumar Singh <msingh@apache.org>
AuthorDate: Tue May 28 07:52:56 2019 +0530

    HDDS-1534. freon should return non-zero exit code on failure. Contributed by Nilotpal
Nandi.
---
 .../apache/hadoop/ozone/freon/RandomKeyGenerator.java   | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

diff --git a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/RandomKeyGenerator.java
b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/RandomKeyGenerator.java
index a255342..b0461cb 100644
--- a/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/RandomKeyGenerator.java
+++ b/hadoop-ozone/tools/src/main/java/org/apache/hadoop/ozone/freon/RandomKeyGenerator.java
@@ -107,7 +107,7 @@ public final class RandomKeyGenerator implements Callable<Void>
{
       LoggerFactory.getLogger(RandomKeyGenerator.class);
 
   private boolean completed = false;
-  private boolean exception = false;
+  private Exception exception = null;
 
   @Option(names = "--numOfThreads",
       description = "number of threads to be launched for the run",
@@ -278,7 +278,7 @@ public final class RandomKeyGenerator implements Callable<Void>
{
     processor.awaitTermination(Integer.MAX_VALUE, TimeUnit.MILLISECONDS);
     completed = true;
 
-    if (exception) {
+    if (exception != null) {
       progressbar.terminate();
     } else {
       progressbar.shutdown();
@@ -288,6 +288,9 @@ public final class RandomKeyGenerator implements Callable<Void>
{
       validator.join();
     }
     ozoneClient.close();
+    if (exception != null) {
+      throw exception;
+    }
     return null;
   }
 
@@ -337,7 +340,7 @@ public final class RandomKeyGenerator implements Callable<Void>
{
 
     out.println();
     out.println("***************************************************");
-    out.println("Status: " + (exception ? "Failed" : "Success"));
+    out.println("Status: " + (exception != null ? "Failed" : "Success"));
     out.println("Git Base Revision: " + VersionInfo.getRevision());
     out.println("Number of Volumes created: " + numberOfVolumesCreated);
     out.println("Number of Buckets created: " + numberOfBucketsCreated);
@@ -577,7 +580,7 @@ public final class RandomKeyGenerator implements Callable<Void>
{
         numberOfVolumesCreated.getAndIncrement();
         volume = objectStore.getVolume(volumeName);
       } catch (IOException e) {
-        exception = true;
+        exception = e;
         LOG.error("Could not create volume", e);
         return;
       }
@@ -644,13 +647,13 @@ public final class RandomKeyGenerator implements Callable<Void>
{
                 }
               }
             } catch (Exception e) {
-              exception = true;
+              exception = e;
               LOG.error("Exception while adding key: {} in bucket: {}" +
                   " of volume: {}.", key, bucket, volume, e);
             }
           }
         } catch (Exception e) {
-          exception = true;
+          exception = e;
           LOG.error("Exception while creating bucket: {}" +
               " in volume: {}.", bucketName, volume, e);
         }
@@ -696,7 +699,7 @@ public final class RandomKeyGenerator implements Callable<Void>
{
     private String[] tenQuantileKeyWriteTime;
 
     private FreonJobInfo() {
-      this.status = exception ? "Failed" : "Success";
+      this.status = exception != null ? "Failed" : "Success";
       this.numOfVolumes = RandomKeyGenerator.this.numOfVolumes;
       this.numOfBuckets = RandomKeyGenerator.this.numOfBuckets;
       this.numOfKeys = RandomKeyGenerator.this.numOfKeys;


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org


Mime
View raw message