diff --git a/ql/src/java/org/apache/hadoop/hive/ql/ddl/process/ShowTransactionsOperation.java b/ql/src/java/org/apache/hadoop/hive/ql/ddl/process/ShowTransactionsOperation.java index cf3963b707..805272e4d0 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/ddl/process/ShowTransactionsOperation.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/ddl/process/ShowTransactionsOperation.java @@ -30,6 +30,7 @@ import org.apache.hadoop.hive.metastore.api.TxnInfo; import org.apache.hadoop.hive.ql.ddl.DDLOperation; import org.apache.hadoop.hive.ql.metadata.HiveException; +import org.apache.hadoop.hive.ql.session.SessionState; /** * Operation process of showing transactions. @@ -41,12 +42,15 @@ public ShowTransactionsOperation(DDLOperationContext context, ShowTransactionsDe @Override public int execute() throws HiveException { + SessionState sessionState = SessionState.get(); // Call the metastore to get the currently queued and running compactions. GetOpenTxnsInfoResponse rsp = context.getDb().showTransactions(); // Write the results into the file try (DataOutputStream os = DDLUtils.getOutputStream(new Path(desc.getResFile()), context)) { - writeHeader(os); + if(!sessionState.isHiveServerQuery()) { + writeHeader(os); + } for (TxnInfo txn : rsp.getOpen_txns()) { writeRow(os, txn);