[ignite-332]: corrected by review results
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d6793f24 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d6793f24 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d6793f24 Branch: refs/heads/ignite-326 Commit: d6793f24b0b6c689321759d61c1cf20fcac11bf9 Parents: dc085d8 Author: iveselovskiy <iveselovs...@gridgain.com> Authored: Tue Feb 24 17:21:55 2015 +0300 Committer: iveselovskiy <iveselovs...@gridgain.com> Committed: Tue Feb 24 17:21:55 2015 +0300 ---------------------------------------------------------------------- .../apache/ignite/client/hadoop/GridHadoopClientProtocol.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d6793f24/modules/hadoop/src/main/java/org/apache/ignite/client/hadoop/GridHadoopClientProtocol.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/client/hadoop/GridHadoopClientProtocol.java b/modules/hadoop/src/main/java/org/apache/ignite/client/hadoop/GridHadoopClientProtocol.java index c7fc077..b058961 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/client/hadoop/GridHadoopClientProtocol.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/client/hadoop/GridHadoopClientProtocol.java @@ -104,9 +104,8 @@ public class GridHadoopClientProtocol implements ClientProtocol { GridHadoopJobStatus status = cli.compute().execute(GridHadoopProtocolSubmitJobTask.class.getName(), new GridHadoopProtocolTaskArguments(jobId.getJtIdentifier(), jobId.getId(), createJobInfo(conf))); - if (status == null) { - throw new IOException("Null status obtained on attempt to submit Hadoop job " + jobId); - } + if (status == null) + throw new IOException("Failed to submit job (null status obtained): " + jobId); return processStatus(status); }
