Uploaded image for project: 'Hive'
  1. Hive
  2. HIVE-25899

Materialized view registry does not clean dropped views

    XMLWordPrintableJSON

Details

    Description

      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:

      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"
      

      Notice the entries like

          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
      

      Attachments

        Issue Links

          Activity

            People

              kkasa Krisztian Kasa
              kkasa Krisztian Kasa
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 40m
                  40m