File tree Expand file tree Collapse file tree 2 files changed +3
-1
lines changed Expand file tree Collapse file tree 2 files changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -154,6 +154,7 @@ public static void createClusterwithAutoscaling(
154
154
System .out .printf ("Cluster created successfully: %s" , response .getClusterName ());
155
155
156
156
} catch (ExecutionException e ) {
157
+ // If cluster creation does not complete successfully, print the error message.
157
158
System .err .println (String .format ("createClusterWithAutoscaling: %s " , e .getMessage ()));
158
159
}
159
160
}
Original file line number Diff line number Diff line change @@ -76,7 +76,7 @@ public static void submitHadoopFSJob(
76
76
77
77
Job response = submitJobAsOperationAsyncRequest .get ();
78
78
79
- // Print output from Google Cloud Storage
79
+ // Print output from Google Cloud Storage.
80
80
Matcher matches =
81
81
Pattern .compile ("gs://(.*?)/(.*)" ).matcher (response .getDriverOutputResourceUri ());
82
82
matches .matches ();
@@ -88,6 +88,7 @@ public static void submitHadoopFSJob(
88
88
String .format ("Job finished successfully: %s" , new String (blob .getContent ())));
89
89
90
90
} catch (ExecutionException e ) {
91
+ // If the job does not complete successfully, print the error message.
91
92
System .err .println (String .format ("submitHadoopFSJob: %s " , e .getMessage ()));
92
93
}
93
94
}
You can’t perform that action at this time.
0 commit comments