diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/ScriptOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/ScriptOperator.java index aa5d0bf..c51c9eb 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/ScriptOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/ScriptOperator.java @@ -79,6 +79,7 @@ public class ScriptOperator extends Operator implements transient RecordWriter scriptOutWriter = null; static final String IO_EXCEPTION_BROKEN_PIPE_STRING = "Broken pipe"; + static final String IO_EXCEPTION_STREAM_CLOSED = "Stream closed"; /** * sends periodic reports back to the tracker. @@ -219,7 +220,8 @@ public class ScriptOperator extends Operator implements } boolean isBrokenPipeException(IOException e) { - return (e.getMessage().compareToIgnoreCase(IO_EXCEPTION_BROKEN_PIPE_STRING) == 0); + return (e.getMessage().compareToIgnoreCase(IO_EXCEPTION_BROKEN_PIPE_STRING) == 0 + || e.getMessage().compareToIgnoreCase(IO_EXCEPTION_STREAM_CLOSED) == 0); } boolean allowPartialConsumption() {