You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2012/11/29 18:11:54 UTC
svn commit: r1415278 -
/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ScriptOperator.java
Author: hashutosh
Date: Thu Nov 29 17:11:53 2012
New Revision: 1415278
URL: http://svn.apache.org/viewvc?rev=1415278&view=rev
Log:
HIVE-3631 : script_pipe.q fails when using JDK7 (Chris Drome via Ashutosh Chauhan)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ScriptOperator.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ScriptOperator.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ScriptOperator.java?rev=1415278&r1=1415277&r2=1415278&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ScriptOperator.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/ScriptOperator.java Thu Nov 29 17:11:53 2012
@@ -81,6 +81,7 @@ public class ScriptOperator extends Oper
transient RecordWriter scriptOutWriter = null;
static final String IO_EXCEPTION_BROKEN_PIPE_STRING = "Broken pipe";
+ static final String IO_EXCEPTION_STREAM_CLOSED = "Stream closed";
static final String IO_EXCEPTION_PIPE_ENDED_WIN = "The pipe has been ended";
static final String IO_EXCEPTION_PIPE_CLOSED_WIN = "The pipe is being closed";
@@ -253,7 +254,8 @@ public class ScriptOperator extends Oper
return errMsg.equalsIgnoreCase(IO_EXCEPTION_PIPE_CLOSED_WIN) ||
errMsg.equalsIgnoreCase(IO_EXCEPTION_PIPE_ENDED_WIN);
}
- return (e.getMessage().equalsIgnoreCase(IO_EXCEPTION_BROKEN_PIPE_STRING));
+ return (e.getMessage().equalsIgnoreCase(IO_EXCEPTION_BROKEN_PIPE_STRING) ||
+ e.getMessage().equalsIgnoreCase(IO_EXCEPTION_STREAM_CLOSED));
}
boolean allowPartialConsumption() {