commit e0019a9c0f4ea76fcd0436deeb7129209fa06047 Author: Ziyang Zhao Date: Mon Jun 13 23:31:57 2016 +0000 HIVE-13965 fix empty resultset run into exception bug 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 3ec63ee..83fc3c8 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 @@ -1026,8 +1026,10 @@ public void closeOp(boolean abort) throws HiveException { 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); }