diff --git a/ql/src/java/org/apache/hadoop/hive/ql/processors/DfsProcessor.java b/ql/src/java/org/apache/hadoop/hive/ql/processors/DfsProcessor.java index cc0414d..45fe4fe 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/processors/DfsProcessor.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/processors/DfsProcessor.java @@ -18,6 +18,7 @@ package org.apache.hadoop.hive.ql.processors; +import java.io.ByteArrayOutputStream; import java.io.PrintStream; import java.util.Arrays; @@ -81,9 +82,14 @@ public CommandProcessorResponse run(String command) { System.setOut(ss.out); } + ByteArrayOutputStream dfsErrBaos = new ByteArrayOutputStream(); + PrintStream dfsErr = new PrintStream(dfsErrBaos); + System.setErr(dfsErr); + int ret = dfs.run(tokens); if (ret != 0) { console.printError("Command failed with exit code = " + ret); + return new CommandProcessorResponse(ret, dfsErrBaos.toString(), null, dfsSchema); } System.setOut(oldOut);