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 8aa2d90b76..1fa276f1c9 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/DDLTask.java @@ -2926,6 +2926,8 @@ private int showCompactions(Hive db, ShowCompactionsDesc desc) throws HiveExcept DataOutputStream os = getOutputStream(desc.getResFile()); try { // Write a header + os.writeBytes("CompactionId"); + os.write(separator); os.writeBytes("Database"); os.write(separator); os.writeBytes("Table"); @@ -2947,6 +2949,8 @@ private int showCompactions(Hive db, ShowCompactionsDesc desc) throws HiveExcept if (rsp.getCompacts() != null) { for (ShowCompactResponseElement e : rsp.getCompacts()) { + os.writeLong(e.getId()); + os.write(separator); os.writeBytes(e.getDbname()); os.write(separator); os.writeBytes(e.getTablename()); diff --git ql/src/java/org/apache/hadoop/hive/ql/plan/ShowCompactionsDesc.java ql/src/java/org/apache/hadoop/hive/ql/plan/ShowCompactionsDesc.java index dc47a38fe6..a2f5eeb8b0 100644 --- ql/src/java/org/apache/hadoop/hive/ql/plan/ShowCompactionsDesc.java +++ ql/src/java/org/apache/hadoop/hive/ql/plan/ShowCompactionsDesc.java @@ -27,8 +27,8 @@ public class ShowCompactionsDesc extends DDLDesc implements Serializable { private static final long serialVersionUID = 1L; - private static final String schema = "dbname,tabname,partname,type,state,workerid," + - "starttime,duration,hadoopjobid#string:string:string:string:string:string:string:string:string"; + private static final String schema = "compactionid,dbname,tabname,partname,type,state,workerid," + + "starttime,duration,hadoopjobid#string:string:string:string:string:string:string:string:string:string"; private String resFile;