diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java index 5cb030c..254e2b0 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java @@ -2788,23 +2788,25 @@ private int showCompactions(ShowCompactionsDesc desc) throws HiveException { os.writeBytes("Start Time"); os.write(terminator); - for (ShowCompactResponseElement e : rsp.getCompacts()) { - os.writeBytes(e.getDbname()); - os.write(separator); - os.writeBytes(e.getTablename()); - os.write(separator); - String part = e.getPartitionname(); - os.writeBytes(part == null ? "NULL" : part); - os.write(separator); - os.writeBytes(e.getType().toString()); - os.write(separator); - os.writeBytes(e.getState()); - os.write(separator); - String wid = e.getWorkerid(); - os.writeBytes(wid == null ? "NULL" : wid); - os.write(separator); - os.writeBytes(Long.toString(e.getStart())); - os.write(terminator); + if (rsp.getCompacts() != null) { + for (ShowCompactResponseElement e : rsp.getCompacts()) { + os.writeBytes(e.getDbname()); + os.write(separator); + os.writeBytes(e.getTablename()); + os.write(separator); + String part = e.getPartitionname(); + os.writeBytes(part == null ? "NULL" : part); + os.write(separator); + os.writeBytes(e.getType().toString()); + os.write(separator); + os.writeBytes(e.getState()); + os.write(separator); + String wid = e.getWorkerid(); + os.writeBytes(wid == null ? "NULL" : wid); + os.write(separator); + os.writeBytes(Long.toString(e.getStart())); + os.write(terminator); + } } os.close(); } catch (IOException e) {