Skip to content
This repository was archived by the owner on May 29, 2025. It is now read-only.

Commit 06841a8

Browse files
committed
commented out redis inc. calls
1 parent b4ae54a commit 06841a8

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

webapp/src/main/java/org/apache/atlas/notification/ObjectPropEventConsumer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -418,15 +418,15 @@ public void doWork() {
418418

419419
// [Line 8] Update redis counters
420420
if (subTaskSuccess > 0) {
421-
redisService.incrValue(ASSETS_COUNT_PROPAGATED, subTaskSuccess);
421+
// redisService.incrValue(ASSETS_COUNT_PROPAGATED, subTaskSuccess);
422422
subTaskSuccess = 0;
423423
LOG.info("ObjectPropConsumer::doWork() [Line 8] => incremented ASSETS_COUNT_PROPAGATED in {} ms",
424424
(System.currentTimeMillis() - lineStart));
425425
}
426426
lineStart = System.currentTimeMillis();
427427

428428
if (subTaskFail > 0) {
429-
redisService.incrValue(ASSETS_PROPAGATION_FAILED_COUNT, subTaskFail);
429+
// redisService.incrValue(ASSETS_PROPAGATION_FAILED_COUNT, subTaskFail);
430430
subTaskFail = 0;
431431
LOG.info("ObjectPropConsumer::doWork() [Line 9] => incremented ASSETS_PROPAGATION_FAILED_COUNT in {} ms",
432432
(System.currentTimeMillis() - lineStart));

0 commit comments

Comments
 (0)