set hive.stats.column.autogather=false;
set hive.support.concurrency=true;
set hive.txn.manager=org.apache.hadoop.hive.ql.lockmgr.DbTxnManager;
set hive.exec.mode.local.auto=false;

set mapred.reduce.tasks = 2;

-- This test sets number of mapred tasks to 2 for a table with 4 buckets,
-- and uses a post-hook to confirm that 1 tasks were created

drop table if exists bucket_nr_acid2;
create table bucket_nr_acid2 (a int, b int) clustered by (a) into 4 buckets stored as orc TBLPROPERTIES ('transactional'='true');

-- txn X write to b0 + b1
insert into bucket_nr_acid2 values(0,1),(1,1);
-- txn X + 1 write to b2 + b3
insert into bucket_nr_acid2 values(2,2),(3,2);
-- txn X + 2 write to b0 + b1
insert into bucket_nr_acid2 values(0,3),(1,3);
-- txn X + 3 write to b2 + b3
insert into bucket_nr_acid2 values(2,4),(3,4);

-- so with 2 FileSinks and 4 buckets, FS1 should see (0,1),(2,2),(0,3)(2,4) since data is sorted by
-- ROW__ID where tnxid is the first component FS2 should see (1,1),(3,2),(1,3),(3,4)


update bucket_nr_acid2 set b = -1;
select * from bucket_nr_acid2 order by a, b;

drop table bucket_nr_acid2;