hmangla98 commented on a change in pull request #2167:
URL: https://github.com/apache/hive/pull/2167#discussion_r615549345
##########
File path: ql/src/java/org/apache/hadoop/hive/ql/stats/StatsUpdaterThread.java
##########
@@ -226,8 +227,8 @@ private void stopWorkers() {
// on the target again
// 2. updating stats requires a writeId to be created. Hence writeIds on
source and target
// can get out of sync when stats are updated. That can cause
consistency issues.
- String replTrgtParam =
table.getParameters().get(ReplConst.REPL_TARGET_TABLE_PROPERTY);
- if (replTrgtParam != null && !replTrgtParam.isEmpty()) {
+ HiveMetaStoreClient msc = new HiveMetaStoreClient(conf);
+ if (ReplUtils.isTargetOfReplication(msc.getDatabase(table.getCatName(),
table.getDbName()))) {
Review comment:
In case of table level replication also, repl.target.for would be set
for that db. Hence, these tasks would be disabled for these tables.
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
