diff --git a/metastore/scripts/upgrade/hive/hive-schema-3.1.0.hive.sql b/metastore/scripts/upgrade/hive/hive-schema-3.1.0.hive.sql index 2d67242423..983b984f4a 100644 --- a/metastore/scripts/upgrade/hive/hive-schema-3.1.0.hive.sql +++ b/metastore/scripts/upgrade/hive/hive-schema-3.1.0.hive.sql @@ -865,6 +865,38 @@ FROM \"FUNCS\"" ); +CREATE EXTERNAL TABLE IF NOT EXISTS `TXNS` ( + `TXN_ID` bigint, + `TXN_STATE` string, + `TXN_STARTED` bigint, + `TXN_LAST_HEARTBEAT` bigint, + `TXN_USER` string, + `TXN_HOST` string, + `TXN_AGENT_INFO` string, + `TXN_META_INFO` string, + `TXN_HEARTBEAT_COUNT` int, + `TXN_TYPE` int + CONSTRAINT `SYS_PK_TXNS` PRIMARY KEY (`TXN_ID`) DISABLE +) +STORED BY 'org.apache.hive.storage.jdbc.JdbcStorageHandler' +TBLPROPERTIES ( +"hive.sql.database.type" = "METASTORE", +"hive.sql.query" = +"SELECT + \"TXN_ID\", + \"TXN_STATE\", + \"TXN_STARTED\", + \"TXN_LAST_HEARTBEAT\", + \"TXN_USER\", + \"TXN_HOST\", + \"TXN_AGENT_INFO\", + \"TXN_META_INFO\", + \"TXN_HEARTBEAT_COUNT\", + \"TXN_TYPE\" +FROM + \"TXNS\"" +); + -- CREATE EXTERNAL TABLE IF NOT EXISTS `FUNC_RU` ( -- `FUNC_ID` bigint, -- `RESOURCE_TYPE` int, diff --git a/ql/src/test/queries/clientpositive/sysdb.q b/ql/src/test/queries/clientpositive/sysdb.q index 59369542d1..9ba9dffe6e 100644 --- a/ql/src/test/queries/clientpositive/sysdb.q +++ b/ql/src/test/queries/clientpositive/sysdb.q @@ -105,6 +105,8 @@ select schema_version from version order by schema_version limit 5; select func_name, func_type from funcs order by func_name, func_type limit 5; +select count(1) from TXNS group by txn_id having count(1) > 1; + select constraint_name from key_constraints order by constraint_name limit 5; select COLUMN_STATS_ACCURATE, NUM_FILES, NUM_ROWS, RAW_DATA_SIZE, TOTAL_SIZE FROM TABLE_STATS_VIEW where COLUMN_STATS_ACCURATE is not null order by COLUMN_STATS_ACCURATE limit 5; diff --git a/ql/src/test/results/clientpositive/llap/sysdb.q.out b/ql/src/test/results/clientpositive/llap/sysdb.q.out index 8b0be82417..6d7ddc8bce 100644 --- a/ql/src/test/results/clientpositive/llap/sysdb.q.out +++ b/ql/src/test/results/clientpositive/llap/sysdb.q.out @@ -1513,6 +1513,14 @@ POSTHOOK: query: select func_name, func_type from funcs order by func_name, func POSTHOOK: type: QUERY POSTHOOK: Input: sys@funcs #### A masked pattern was here #### +PREHOOK: query: select count(1) from TXNS group by txn_id having count(1) > 1 +PREHOOK: type: QUERY +PREHOOK: Input: sys@txns +#### A masked pattern was here #### +POSTHOOK: query: select count(1) from TXNS group by txn_id having count(1) > 1 +POSTHOOK: type: QUERY +POSTHOOK: Input: sys@txns +#### A masked pattern was here #### PREHOOK: query: select constraint_name from key_constraints order by constraint_name limit 5 PREHOOK: type: QUERY PREHOOK: Input: sys@key_constraints