Index: standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java (revision 5ce0b4008ed1d6b7bdce0d037cc6cf7010bd948b) +++ standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/txn/TxnHandler.java (date 1571379468000) @@ -572,7 +572,7 @@ int numTxns = rqst.getNum_txns(); ResultSet rs = null; List insertPreparedStmts = null; - TxnType txnType = TxnType.DEFAULT; + TxnType txnType = rqst.getTxn_type(); try { if (rqst.isSetReplPolicy()) { List targetTxnIdList = getTargetTxnIdList(rqst.getReplPolicy(), rqst.getReplSrcTxnIds(), dbConn); Index: standalone-metastore/metastore-server/src/test/java/org/apache/hadoop/hive/metastore/TestHiveMetaStoreTxns.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- standalone-metastore/metastore-server/src/test/java/org/apache/hadoop/hive/metastore/TestHiveMetaStoreTxns.java (revision 5ce0b4008ed1d6b7bdce0d037cc6cf7010bd948b) +++ standalone-metastore/metastore-server/src/test/java/org/apache/hadoop/hive/metastore/TestHiveMetaStoreTxns.java (date 1571660116000) @@ -308,6 +308,15 @@ Assert.assertTrue(validTxns.isTxnValid(txnId)); } + @Test + public void testTxnTypePersisted() throws Exception { + long txnId = client.openTxn("me", TxnType.READ_ONLY); + Statement stm = conn.createStatement(); + ResultSet rs = stm.executeQuery("SELECT txn_type FROM TXNS WHERE txn_id = " + txnId); + Assert.assertTrue(rs.next()); + Assert.assertEquals(TxnType.findByValue(rs.getInt("txn_type")), TxnType.READ_ONLY); + } + @Before public void setUp() throws Exception { conf.setBoolean(ConfVars.HIVE_IN_TEST.getVarname(), true);