Babulal created CARBONDATA-2530:
----------------------------------- Summary: [MV] Wrong data displayed when parent table data are loaded Key: CARBONDATA-2530 URL: https://issues.apache.org/jira/browse/CARBONDATA-2530 Project: CarbonData Issue Type: Bug Reporter: Babulal Spark Release:- Spark2.2.1 Create table and load data to it create MV rebuild datamap run query (used during mv creation) which hits MV and get data Now load data to main table again run query (used during mv creation) which hits MV and get data Result:- data shown is from MV which is wrong if increament load happens then data should get from Main table(parent table) Commands 0: jdbc:hive2://10.18.222.231:23040> create table tt13 ( name string, age int) stored by 'carbondata'; 0: jdbc:hive2://10.18.222.231:23040> insert into tt13 select 'babu',12; +---------+--+ | Result | +---------+--+ +---------+–+ 0: jdbc:hive2://10.18.222.231:23040> create datamap datamap43 using 'mv' as select name from tt13 ; +---------+--+ | Result | +---------+--+ +---------+--+ No rows selected (0.51 seconds) 0: jdbc:hive2://10.18.222.231:23040> rebuild datamap datamap43; +---------+--+ | Result | +---------+--+ +---------+--+ No rows selected (8.747 seconds) 0: jdbc:hive2://10.18.222.231:23040> explain select name from tt13; +------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+--+ | plan | +------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+--+ | == CarbonData Profiler == Table Scan on datamap43_table - total blocklets: 1 - filter: none - pruned by Main DataMap - skipped blocklets: 0 | | == Physical Plan == *BatchedScan CarbonDatasourceHadoopRelation [ Database name :default, Table name :datamap43_table, Schema :Some(StructType(StructField(tt13_name,StringType,true))) ] default.datamap43_table[tt13_name#1311] | +------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+--+ 2 rows selected (0.525 seconds) 0: jdbc:hive2://10.18.222.231:23040> select name from tt13; +------------+--+ | tt13_name | +------------+--+ | babu | +------------+--+ 1 row selected (0.483 seconds) 0: jdbc:hive2://10.18.222.231:23040> insert into tt13 select 'lal',13; +---------+--+ | Result | +---------+--+ +---------+--+ No rows selected (11.819 seconds) 0: jdbc:hive2://10.18.222.231:23040> select name from tt13; +------------+--+ | tt13_name | +------------+--+ | babu | +------------+--+ 1 row selected (0.349 seconds) 0: jdbc:hive2://10.18.222.231:23040> explain select name from tt13; +------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+--+ | plan | +------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+--+ | == CarbonData Profiler == Table Scan on datamap43_table - total blocklets: 1 - filter: none - pruned by Main DataMap - skipped blocklets: 0 | | == Physical Plan == *BatchedScan CarbonDatasourceHadoopRelation [ Database name :default, Table name :datamap43_table, Schema :Some(StructType(StructField(tt13_name,StringType,true))) ] default.datamap43_table[tt13_name#1311] | +------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+--+ 2 rows selected (0.391 seconds) Expected output should display 2 records . (check insert into command) -- This message was sent by Atlassian JIRA (v7.6.3#76005) |
Free forum by Nabble | Edit this page |