Hi,
We have given below query in tHiveRow -
"set hive.support.concurrency=true;
set hive.enforce.bucketing=true ;
set hive.exec.dynamic.partition.mode=nonstrict;
set ive.txn.manager=org.apache.hadoop.hive.ql.lockmgr.DbTxnManager;
set hive.compactor.initiator.on=true;
set hive.compactor.worker.threads=10;
update hiveupdate set salary = 75000 where employeeid=10";
Job is not throwing any error but record is not actually updated in DB - where as same is working finer from Hive CLI. Please help.
Regards,
Kiran G.
Hi, What's the hive version you are using? Have you tried to check "Die on error" option in component tHiveRow to see if there is any error message printed on console? Best regards Sabrina
Hi, What does the error message look like? Could you please post the whole error message into forum which will be helpful for us to locate this issue? Best regards Sabrina
Hi,
No error message from tHiveRow and job for Update query is successfully completed - but when we go and the Database the record is not actually updated.
Below code is used in tHiveRow:
"set hive.support.concurrency=true;
set hive.enforce.bucketing=true ;
set hive.exec.dynamic.partition.mode=nonstrict;
set ive.txn.manager=org.apache.hadoop.hive.ql.lockmgr.DbTxnManager;
set hive.compactor.initiator.on=true;
set hive.compactor.worker.threads=10;
update hiveupdate set salary = 75000 where employeeid=10";
Even we removed ; for set statements and ran - but still no Luck.
Above same code - when copy pasted (with out set parameters too) at Hive CLI - it is working fine.
We have set up all above Set parameters in hive-site.xml and that's how Hive CLI working fine.
Not sure - why talend is unable to do this update transaction. Please help.
Regards,
Kiran G.