You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@hive.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2022/01/26 12:10:00 UTC
[jira] [Work logged] (HIVE-25899) Materialized view registry does not clean dropped views
[ https://issues.apache.org/jira/browse/HIVE-25899?focusedWorklogId=715620&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-715620 ]
ASF GitHub Bot logged work on HIVE-25899:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 26/Jan/22 12:09
Start Date: 26/Jan/22 12:09
Worklog Time Spent: 10m
Work Description: kasakrisz opened a new pull request #2975:
URL: https://github.com/apache/hive/pull/2975
### What changes were proposed in this pull request?
`MaterializedViewsCache` nested maps.
```
somedb -> someview -> Materialization
```
1. When removing entries from the inner map check whether that map is empty and remove it from the outer map.
2. Add `isEmpty()` method to `HiveMaterializedViewsRegistry`
### Why are the changes needed?
See description of jira.
### Does this PR introduce _any_ user-facing change?
No.
### How was this patch tested?
```
mvn test -Dtest=TestMaterializedViewsCache -pl ql
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: gitbox-unsubscribe@hive.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Issue Time Tracking
-------------------
Worklog Id: (was: 715620)
Remaining Estimate: 0h
Time Spent: 10m
> Materialized view registry does not clean dropped views
> -------------------------------------------------------
>
> Key: HIVE-25899
> URL: https://issues.apache.org/jira/browse/HIVE-25899
> Project: Hive
> Issue Type: Bug
> Components: Materialized views
> Reporter: Krisztian Kasa
> Assignee: Krisztian Kasa
> Priority: Major
> Time Spent: 10m
> Remaining Estimate: 0h
>
> CBO plans of materialized views which are enabled for query rewrite are cached in HS2 (MaterializedViewsCache)
> Dropping a materialized views should remove the entry from the cache however the entry keys are not removed.
> Cache state after running a whole PTest split:
> {code}
> this = {HiveMaterializedViewsRegistry@20858}
> materializedViewsCache = {MaterializedViewsCache@20913}
> materializedViews = {ConcurrentHashMap@67654} size = 3
> "default" -> {ConcurrentHashMap@28568} size = 8
> key = "default"
> value = {ConcurrentHashMap@28568} size = 8
> "cluster_mv_2" -> {HiveRelOptMaterialization@67786}
> "cluster_mv_1" -> {HiveRelOptMaterialization@67788}
> "cluster_mv_4" -> {HiveRelOptMaterialization@67790}
> "cluster_mv_3" -> {HiveRelOptMaterialization@67792}
> "cmv_mat_view_n10" -> {HiveRelOptMaterialization@67794}
> "distribute_mv_1" -> {HiveRelOptMaterialization@67796}
> "distribute_mv_3" -> {HiveRelOptMaterialization@67798}
> "distribute_mv_2" -> {HiveRelOptMaterialization@67800}
> "db2" -> {ConcurrentHashMap@67772} size = 2
> key = "db2"
> value = {ConcurrentHashMap@67772} size = 2
> "cmv_mat_view_n7" -> {HiveRelOptMaterialization@67806}
> "cmv_mat_view2_n2" -> {HiveRelOptMaterialization@67808}
> "count_distinct" -> {ConcurrentHashMap@67774} size = 0
> key = "count_distinct"
> value = {ConcurrentHashMap@67774} size = 0
> sqlToMaterializedView = {ConcurrentHashMap@20915} size = 36
> "SELECT `cmv_basetable_n100`.`a`, `cmv_basetable_2_n100`.`c`\n FROM `default`.`cmv_basetable_n100` JOIN `default`.`cmv_basetable_2_n100` ON (`cmv_basetable_n100`.`a` = `cmv_basetable_2_n100`.`a`)\n WHERE `cmv_basetable_2_n100`.`c` > 10.0\n GROUP BY `cmv_basetable_n100`.`a`, `cmv_basetable_2_n100`.`c`" -> {ArrayList@67694} size = 0
> key = "SELECT `cmv_basetable_n100`.`a`, `cmv_basetable_2_n100`.`c`\n FROM `default`.`cmv_basetable_n100` JOIN `default`.`cmv_basetable_2_n100` ON (`cmv_basetable_n100`.`a` = `cmv_basetable_2_n100`.`a`)\n WHERE `cmv_basetable_2_n100`.`c` > 10.0\n GROUP BY `cmv_basetable_n100`.`a`, `cmv_basetable_2_n100`.`c`"
> value = {ArrayList@67694} size = 0
> "select `emps_parquet_n3`.`empid`, `emps_parquet_n3`.`deptno` from `default`.`emps_parquet_n3` group by `emps_parquet_n3`.`empid`, `emps_parquet_n3`.`deptno`" -> {ArrayList@67696} size = 0
> key = "select `emps_parquet_n3`.`empid`, `emps_parquet_n3`.`deptno` from `default`.`emps_parquet_n3` group by `emps_parquet_n3`.`empid`, `emps_parquet_n3`.`deptno`"
> value = {ArrayList@67696} size = 0
> "select `cmv_basetable_n7`.`a`, `cmv_basetable_n7`.`c` from `db1`.`cmv_basetable_n7` where `cmv_basetable_n7`.`a` = 3" -> {ArrayList@67698} size = 1
> key = "select `cmv_basetable_n7`.`a`, `cmv_basetable_n7`.`c` from `db1`.`cmv_basetable_n7` where `cmv_basetable_n7`.`a` = 3"
> value = {ArrayList@67698} size = 1
> "SELECT `value`, `key`, `partkey` FROM (SELECT `src_txn`.`key` + 100 as `partkey`, `src_txn`.`value`, `src_txn`.`key` FROM `default`.`src_txn`, `default`.`src_txn_2`\nWHERE `src_txn`.`key` = `src_txn_2`.`key`\n AND `src_txn`.`key` > 200 AND `src_txn`.`key` < 250) `cluster_mv_3`" -> {ArrayList@67700} size = 1
> key = "SELECT `value`, `key`, `partkey` FROM (SELECT `src_txn`.`key` + 100 as `partkey`, `src_txn`.`value`, `src_txn`.`key` FROM `default`.`src_txn`, `default`.`src_txn_2`\nWHERE `src_txn`.`key` = `src_txn_2`.`key`\n AND `src_txn`.`key` > 200 AND `src_txn`.`key` < 250) `cluster_mv_3`"
> value = {ArrayList@67700} size = 1
> "SELECT `cmv_basetable_n6`.`a`, `cmv_basetable_2_n3`.`c`\n FROM `default`.`cmv_basetable_n6` JOIN `default`.`cmv_basetable_2_n3` ON (`cmv_basetable_n6`.`a` = `cmv_basetable_2_n3`.`a`)\n WHERE `cmv_basetable_2_n3`.`c` > 10.0" -> {ArrayList@67702} size = 0
> key = "SELECT `cmv_basetable_n6`.`a`, `cmv_basetable_2_n3`.`c`\n FROM `default`.`cmv_basetable_n6` JOIN `default`.`cmv_basetable_2_n3` ON (`cmv_basetable_n6`.`a` = `cmv_basetable_2_n3`.`a`)\n WHERE `cmv_basetable_2_n3`.`c` > 10.0"
> value = {ArrayList@67702} size = 0
> "SELECT `src_txn`.`key`, `src_txn`.`value` FROM `default`.`src_txn` where `src_txn`.`key` > 200 and `src_txn`.`key` < 250" -> {ArrayList@67704} size = 1
> key = "SELECT `src_txn`.`key`, `src_txn`.`value` FROM `default`.`src_txn` where `src_txn`.`key` > 200 and `src_txn`.`key` < 250"
> value = {ArrayList@67704} size = 1
> "select `cmv_basetable_n9`.`a`, `cmv_basetable_2_n4`.`c`\n from `default`.`cmv_basetable_n9` join `default`.`cmv_basetable_2_n4` on (`cmv_basetable_n9`.`a` = `cmv_basetable_2_n4`.`a`)\n where `cmv_basetable_2_n4`.`c` > 10.0\n group by `cmv_basetable_n9`.`a`, `cmv_basetable_2_n4`.`c`" -> {ArrayList@67706} size = 0
> key = "select `cmv_basetable_n9`.`a`, `cmv_basetable_2_n4`.`c`\n from `default`.`cmv_basetable_n9` join `default`.`cmv_basetable_2_n4` on (`cmv_basetable_n9`.`a` = `cmv_basetable_2_n4`.`a`)\n where `cmv_basetable_2_n4`.`c` > 10.0\n group by `cmv_basetable_n9`.`a`, `cmv_basetable_2_n4`.`c`"
> value = {ArrayList@67706} size = 0
> "select `emps_parquet_n3`.`empid`, `emps_parquet_n3`.`deptno`, `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`, `emps_parquet_n3`.`commission` from `default`.`emps_parquet_n3` where `emps_parquet_n3`.`empid` < 150" -> {ArrayList@67708} size = 0
> key = "select `emps_parquet_n3`.`empid`, `emps_parquet_n3`.`deptno`, `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`, `emps_parquet_n3`.`commission` from `default`.`emps_parquet_n3` where `emps_parquet_n3`.`empid` < 150"
> value = {ArrayList@67708} size = 0
> "select `t1`.`a`, sum(`t1`.`b`), count(`t1`.`b`), avg(`t1`.`b`), count(*) from `default`.`t1`\njoin `default`.`t2` on (`t1`.`a` = `t2`.`a`)\ngroup by `t1`.`a`" -> {ArrayList@67710} size = 0
> key = "select `t1`.`a`, sum(`t1`.`b`), count(`t1`.`b`), avg(`t1`.`b`), count(*) from `default`.`t1`\njoin `default`.`t2` on (`t1`.`a` = `t2`.`a`)\ngroup by `t1`.`a`"
> value = {ArrayList@67710} size = 0
> "select `cmv_basetable_n10`.`a`, `cmv_basetable_n10`.`b`, `cmv_basetable_n10`.`c` from `default`.`cmv_basetable_n10` where `cmv_basetable_n10`.`a` = 2" -> {ArrayList@67712} size = 1
> key = "select `cmv_basetable_n10`.`a`, `cmv_basetable_n10`.`b`, `cmv_basetable_n10`.`c` from `default`.`cmv_basetable_n10` where `cmv_basetable_n10`.`a` = 2"
> value = {ArrayList@67712} size = 1
> "select `emps_parquet_n3`.`deptno`, `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`, `emps_parquet_n3`.`commission`\nfrom `default`.`emps_parquet_n3`" -> {ArrayList@67714} size = 0
> key = "select `emps_parquet_n3`.`deptno`, `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`, `emps_parquet_n3`.`commission`\nfrom `default`.`emps_parquet_n3`"
> value = {ArrayList@67714} size = 0
> "select `cmv_basetable_n9`.`b` from `default`.`cmv_basetable_n9` where `cmv_basetable_n9`.`c` > 10.0 group by `cmv_basetable_n9`.`a`, `cmv_basetable_n9`.`b`, `cmv_basetable_n9`.`c`" -> {ArrayList@67716} size = 0
> key = "select `cmv_basetable_n9`.`b` from `default`.`cmv_basetable_n9` where `cmv_basetable_n9`.`c` > 10.0 group by `cmv_basetable_n9`.`a`, `cmv_basetable_n9`.`b`, `cmv_basetable_n9`.`c`"
> value = {ArrayList@67716} size = 0
> "select `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary` from `default`.`emps_parquet_n3` where `emps_parquet_n3`.`deptno` = 10 group by `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`" -> {ArrayList@67718} size = 0
> key = "select `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary` from `default`.`emps_parquet_n3` where `emps_parquet_n3`.`deptno` = 10 group by `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`"
> value = {ArrayList@67718} size = 0
> "select `cmv_basetable_n9`.`b`, `cmv_basetable_n9`.`c` from `default`.`cmv_basetable_n9` where `cmv_basetable_n9`.`c` > 10.0 group by `cmv_basetable_n9`.`a`, `cmv_basetable_n9`.`b`, `cmv_basetable_n9`.`c`" -> {ArrayList@67720} size = 0
> key = "select `cmv_basetable_n9`.`b`, `cmv_basetable_n9`.`c` from `default`.`cmv_basetable_n9` where `cmv_basetable_n9`.`c` > 10.0 group by `cmv_basetable_n9`.`a`, `cmv_basetable_n9`.`b`, `cmv_basetable_n9`.`c`"
> value = {ArrayList@67720} size = 0
> "SELECT `cmv_basetable_n3`.`a`, `cmv_basetable_2_n1`.`c`\n FROM `default`.`cmv_basetable_n3` JOIN `default`.`cmv_basetable_2_n1` ON (`cmv_basetable_n3`.`a` = `cmv_basetable_2_n1`.`a`)\n WHERE `cmv_basetable_2_n1`.`c` > 10.0\n GROUP BY `cmv_basetable_n3`.`a`, `cmv_basetable_2_n1`.`c`" -> {ArrayList@67722} size = 0
> key = "SELECT `cmv_basetable_n3`.`a`, `cmv_basetable_2_n1`.`c`\n FROM `default`.`cmv_basetable_n3` JOIN `default`.`cmv_basetable_2_n1` ON (`cmv_basetable_n3`.`a` = `cmv_basetable_2_n1`.`a`)\n WHERE `cmv_basetable_2_n1`.`c` > 10.0\n GROUP BY `cmv_basetable_n3`.`a`, `cmv_basetable_2_n1`.`c`"
> value = {ArrayList@67722} size = 0
> "SELECT `t1`.`a`, `t1`.`b`, sum(`t1`.`d`), min(`t1`.`d`), max(`t1`.`d`)\n FROM `default`.`t1`\n WHERE `t1`.`c` > 10.0\n GROUP BY `t1`.`a`, `t1`.`b`" -> {ArrayList@67724} size = 0
> key = "SELECT `t1`.`a`, `t1`.`b`, sum(`t1`.`d`), min(`t1`.`d`), max(`t1`.`d`)\n FROM `default`.`t1`\n WHERE `t1`.`c` > 10.0\n GROUP BY `t1`.`a`, `t1`.`b`"
> value = {ArrayList@67724} size = 0
> "select `t1`.`a`, count(*) from `default`.`t1`\ngroup by `t1`.`a`" -> {ArrayList@67726} size = 0
> key = "select `t1`.`a`, count(*) from `default`.`t1`\ngroup by `t1`.`a`"
> value = {ArrayList@67726} size = 0
> "select `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`, count(*) as `c`, sum(`emps_parquet_n3`.`empid`) as `s`\nfrom `default`.`emps_parquet_n3` group by `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`" -> {ArrayList@67728} size = 0
> key = "select `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`, count(*) as `c`, sum(`emps_parquet_n3`.`empid`) as `s`\nfrom `default`.`emps_parquet_n3` group by `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`"
> value = {ArrayList@67728} size = 0
> "SELECT `key`, `value`, `partkey` FROM (SELECT `src_txn`.`key`, `src_txn`.`value`, `src_txn`.`key` + 100 as `partkey` FROM `default`.`src_txn` where `src_txn`.`key` > 200 and `src_txn`.`key` < 250) `cluster_mv_2`" -> {ArrayList@67730} size = 1
> key = "SELECT `key`, `value`, `partkey` FROM (SELECT `src_txn`.`key`, `src_txn`.`value`, `src_txn`.`key` + 100 as `partkey` FROM `default`.`src_txn` where `src_txn`.`key` > 200 and `src_txn`.`key` < 250) `cluster_mv_2`"
> value = {ArrayList@67730} size = 1
> "SELECT `cmv_basetable_n5`.`a`, sum(`cmv_basetable_2_n2`.`d`)\n FROM `default`.`cmv_basetable_n5` JOIN `default`.`cmv_basetable_2_n2` ON (`cmv_basetable_n5`.`a` = `cmv_basetable_2_n2`.`a`)\n WHERE `cmv_basetable_2_n2`.`c` > 10.0\n GROUP BY `cmv_basetable_n5`.`a`" -> {ArrayList@67732} size = 0
> key = "SELECT `cmv_basetable_n5`.`a`, sum(`cmv_basetable_2_n2`.`d`)\n FROM `default`.`cmv_basetable_n5` JOIN `default`.`cmv_basetable_2_n2` ON (`cmv_basetable_n5`.`a` = `cmv_basetable_2_n2`.`a`)\n WHERE `cmv_basetable_2_n2`.`c` > 10.0\n GROUP BY `cmv_basetable_n5`.`a`"
> value = {ArrayList@67732} size = 0
> "select distinct `base`.`c1` `c1`, `base`.`c2` `c2` from `count_distinct`.`base`" -> {ArrayList@67734} size = 0
> key = "select distinct `base`.`c1` `c1`, `base`.`c2` `c2` from `count_distinct`.`base`"
> value = {ArrayList@67734} size = 0
> "select `emps_parquet_n3`.`empid`, `emps_parquet_n3`.`name` from `default`.`emps_parquet_n3` group by `emps_parquet_n3`.`empid`, `emps_parquet_n3`.`name`" -> {ArrayList@67736} size = 0
> key = "select `emps_parquet_n3`.`empid`, `emps_parquet_n3`.`name` from `default`.`emps_parquet_n3` group by `emps_parquet_n3`.`empid`, `emps_parquet_n3`.`name`"
> value = {ArrayList@67736} size = 0
> "select `emps_parquet_n3`.`empid` `deptno` from `default`.`emps_parquet_n3`\njoin `default`.`depts_parquet_n2` using (`deptno`)" -> {ArrayList@67738} size = 0
> key = "select `emps_parquet_n3`.`empid` `deptno` from `default`.`emps_parquet_n3`\njoin `default`.`depts_parquet_n2` using (`deptno`)"
> value = {ArrayList@67738} size = 0
> "SELECT `value`, `key`, `tes"t`, `te*#"s"t`, `partkey` FROM (SELECT `src_txn`.`key` + 100 as `partkey`, `src_txn`.`value`, `src_txn`.`key`, `src_txn`.`key`+1 as `tes"t`, `src_txn`.`key`+2 as `te*#"s"t` FROM `default`.`src_txn` where `src_txn`.`key` > 200 and `src_txn`.`key` < 250) `cluster_mv_4`" -> {ArrayList@67740} size = 1
> key = "SELECT `value`, `key`, `tes"t`, `te*#"s"t`, `partkey` FROM (SELECT `src_txn`.`key` + 100 as `partkey`, `src_txn`.`value`, `src_txn`.`key`, `src_txn`.`key`+1 as `tes"t`, `src_txn`.`key`+2 as `te*#"s"t` FROM `default`.`src_txn` where `src_txn`.`key` > 200 and `src_txn`.`key` < 250) `cluster_mv_4`"
> value = {ArrayList@67740} size = 1
> "SELECT `cmv_basetable_n5`.`a`, `cmv_basetable_2_n2`.`c`, sum(`cmv_basetable_2_n2`.`d`)\n FROM `default`.`cmv_basetable_n5` JOIN `default`.`cmv_basetable_2_n2` ON (`cmv_basetable_n5`.`a` = `cmv_basetable_2_n2`.`a`)\n WHERE `cmv_basetable_2_n2`.`c` > 10.0\n GROUP BY `cmv_basetable_n5`.`a`, `cmv_basetable_2_n2`.`c`" -> {ArrayList@67742} size = 0
> key = "SELECT `cmv_basetable_n5`.`a`, `cmv_basetable_2_n2`.`c`, sum(`cmv_basetable_2_n2`.`d`)\n FROM `default`.`cmv_basetable_n5` JOIN `default`.`cmv_basetable_2_n2` ON (`cmv_basetable_n5`.`a` = `cmv_basetable_2_n2`.`a`)\n WHERE `cmv_basetable_2_n2`.`c` > 10.0\n GROUP BY `cmv_basetable_n5`.`a`, `cmv_basetable_2_n2`.`c`"
> value = {ArrayList@67742} size = 0
> "SELECT `cmv_basetable`.`a`, `cmv_basetable_2`.`c`\n FROM `default`.`cmv_basetable` JOIN `default`.`cmv_basetable_2` ON (`cmv_basetable`.`a` = `cmv_basetable_2`.`a`)\n WHERE `cmv_basetable_2`.`c` > 10.0\n GROUP BY `cmv_basetable`.`a`, `cmv_basetable_2`.`c`" -> {ArrayList@67744} size = 0
> key = "SELECT `cmv_basetable`.`a`, `cmv_basetable_2`.`c`\n FROM `default`.`cmv_basetable` JOIN `default`.`cmv_basetable_2` ON (`cmv_basetable`.`a` = `cmv_basetable_2`.`a`)\n WHERE `cmv_basetable_2`.`c` > 10.0\n GROUP BY `cmv_basetable`.`a`, `cmv_basetable_2`.`c`"
> value = {ArrayList@67744} size = 0
> "select `emps_parquet_n3`.`empid`, `emps_parquet_n3`.`deptno`, `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`, `emps_parquet_n3`.`commission` from `default`.`emps_parquet_n3` where `emps_parquet_n3`.`empid` < 200" -> {ArrayList@67746} size = 0
> key = "select `emps_parquet_n3`.`empid`, `emps_parquet_n3`.`deptno`, `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`, `emps_parquet_n3`.`commission` from `default`.`emps_parquet_n3` where `emps_parquet_n3`.`empid` < 200"
> value = {ArrayList@67746} size = 0
> "select `cmv_basetable_n7`.`a`, `cmv_basetable_n7`.`b`, `cmv_basetable_n7`.`c` from `db1`.`cmv_basetable_n7` where `cmv_basetable_n7`.`a` = 2" -> {ArrayList@67748} size = 1
> key = "select `cmv_basetable_n7`.`a`, `cmv_basetable_n7`.`b`, `cmv_basetable_n7`.`c` from `db1`.`cmv_basetable_n7` where `cmv_basetable_n7`.`a` = 2"
> value = {ArrayList@67748} size = 1
> "select `cmv_basetable_n9`.`a`, `cmv_basetable_n9`.`b` from `default`.`cmv_basetable_n9` group by `cmv_basetable_n9`.`a`, `cmv_basetable_n9`.`b`" -> {ArrayList@67750} size = 0
> key = "select `cmv_basetable_n9`.`a`, `cmv_basetable_n9`.`b` from `default`.`cmv_basetable_n9` group by `cmv_basetable_n9`.`a`, `cmv_basetable_n9`.`b`"
> value = {ArrayList@67750} size = 0
> "select `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary` from `default`.`emps_parquet_n3` group by `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`" -> {ArrayList@67752} size = 0
> key = "select `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary` from `default`.`emps_parquet_n3` group by `emps_parquet_n3`.`name`, `emps_parquet_n3`.`salary`"
> value = {ArrayList@67752} size = 0
> "SELECT `value`, `key`, `partkey` FROM (SELECT `src_txn`.`value`, `src_txn`.`key`, `src_txn`.`key` + 100 as `partkey` FROM `default`.`src_txn` where `src_txn`.`key` > 200 and `src_txn`.`key` < 250) `cluster_mv_1`" -> {ArrayList@67754} size = 1
> key = "SELECT `value`, `key`, `partkey` FROM (SELECT `src_txn`.`value`, `src_txn`.`key`, `src_txn`.`key` + 100 as `partkey` FROM `default`.`src_txn` where `src_txn`.`key` > 200 and `src_txn`.`key` < 250) `cluster_mv_1`"
> value = {ArrayList@67754} size = 1
> "SELECT `src_txn`.`value`, `src_txn`.`key` FROM `default`.`src_txn`, `default`.`src_txn_2`\nWHERE `src_txn`.`key` = `src_txn_2`.`key`\n AND `src_txn`.`key` > 200 AND `src_txn`.`key` < 250" -> {ArrayList@67756} size = 1
> key = "SELECT `src_txn`.`value`, `src_txn`.`key` FROM `default`.`src_txn`, `default`.`src_txn_2`\nWHERE `src_txn`.`key` = `src_txn_2`.`key`\n AND `src_txn`.`key` > 200 AND `src_txn`.`key` < 250"
> value = {ArrayList@67756} size = 1
> "SELECT `id`, `name`, `year` FROM (select `tmv`.`id`, `tmv`.`name`, `tmv`.`year` from `db1`.`testmvtable` `tmv` where `tmv`.`year` >= 2018) `testmv`" -> {ArrayList@67758} size = 0
> key = "SELECT `id`, `name`, `year` FROM (select `tmv`.`id`, `tmv`.`name`, `tmv`.`year` from `db1`.`testmvtable` `tmv` where `tmv`.`year` >= 2018) `testmv`"
> value = {ArrayList@67758} size = 0
> "SELECT `src_txn`.`value`, `src_txn`.`key` FROM `default`.`src_txn` where `src_txn`.`key` > 200 and `src_txn`.`key` < 250" -> {ArrayList@67760} size = 2
> key = "SELECT `src_txn`.`value`, `src_txn`.`key` FROM `default`.`src_txn` where `src_txn`.`key` > 200 and `src_txn`.`key` < 250"
> value = {ArrayList@67760} size = 2
> "select `cmv_basetable_n9`.`a`, `cmv_basetable_n9`.`b`, `cmv_basetable_n9`.`c` from `default`.`cmv_basetable_n9` where `cmv_basetable_n9`.`c` > 10.0 group by `cmv_basetable_n9`.`a`, `cmv_basetable_n9`.`b`, `cmv_basetable_n9`.`c`" -> {ArrayList@67762} size = 0
> key = "select `cmv_basetable_n9`.`a`, `cmv_basetable_n9`.`b`, `cmv_basetable_n9`.`c` from `default`.`cmv_basetable_n9` where `cmv_basetable_n9`.`c` > 10.0 group by `cmv_basetable_n9`.`a`, `cmv_basetable_n9`.`b`, `cmv_basetable_n9`.`c`"
> value = {ArrayList@67762} size = 0
> "select `t1`.`a`, sum(`t1`.`b`), count(*) from `default`.`t1`\njoin `default`.`t2` on (`t1`.`a` = `t2`.`a`)\ngroup by `t1`.`a`" -> {ArrayList@67764} size = 0
> key = "select `t1`.`a`, sum(`t1`.`b`), count(*) from `default`.`t1`\njoin `default`.`t2` on (`t1`.`a` = `t2`.`a`)\ngroup by `t1`.`a`"
> value = {ArrayList@67764} size = 0
> initialized = {AtomicBoolean@67652} "true"
> {code}
> Notice the entries like
> {code}
> key = "select `t1`.`a`, sum(`t1`.`b`), count(*) from `default`.`t1`\njoin `default`.`t2` on (`t1`.`a` = `t2`.`a`)\ngroup by `t1`.`a`"
> value = {ArrayList@67764} size = 0
> {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)