You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by vg...@apache.org on 2016/07/13 21:09:46 UTC
hive git commit: HIVE-13965: Empty resultset run into Exception when
using Thrift Binary Serde (Ziyang Zhao reviewed by Vaibhav Gumashta)
Repository: hive
Updated Branches:
refs/heads/master 9b21e17db -> ab88dbb22
HIVE-13965: Empty resultset run into Exception when using Thrift Binary Serde (Ziyang Zhao reviewed by Vaibhav Gumashta)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/ab88dbb2
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/ab88dbb2
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/ab88dbb2
Branch: refs/heads/master
Commit: ab88dbb22fa6f4b2ec871f89b1dba74c62837a8d
Parents: 9b21e17
Author: Vaibhav Gumashta <vg...@hortonworks.com>
Authored: Wed Jul 13 14:08:49 2016 -0700
Committer: Vaibhav Gumashta <vg...@hortonworks.com>
Committed: Wed Jul 13 14:08:49 2016 -0700
----------------------------------------------------------------------
.../java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/ab88dbb2/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
index 6a0e8c7..812a943 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
@@ -1027,8 +1027,10 @@ public class FileSinkOperator extends TerminalOperator<FileSinkDesc> implements
serializer.getClass().getName().equalsIgnoreCase(ThriftJDBCBinarySerDe.class.getName())) {
try {
recordValue = serializer.serialize(null, inputObjInspectors[0]);
- rowOutWriters = fpaths.outWriters;
- rowOutWriters[0].write(recordValue);
+ if ( null != fpaths ) {
+ rowOutWriters = fpaths.outWriters;
+ rowOutWriters[0].write(recordValue);
+ }
} catch (SerDeException | IOException e) {
throw new HiveException(e);
}