From 55685032fcafd43af8b22049e5969a0c172a3ccb Mon Sep 17 00:00:00 2001 From: Woonduk Kang Date: Wed, 10 Feb 2021 11:37:04 +0900 Subject: [PATCH] [#7559] Fix cycle reference --- .../dao/hbase/statistics/BulkConfiguration.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/collector/src/main/java/com/navercorp/pinpoint/collector/dao/hbase/statistics/BulkConfiguration.java b/collector/src/main/java/com/navercorp/pinpoint/collector/dao/hbase/statistics/BulkConfiguration.java index 15ea11b5c5bc..871490781b7a 100644 --- a/collector/src/main/java/com/navercorp/pinpoint/collector/dao/hbase/statistics/BulkConfiguration.java +++ b/collector/src/main/java/com/navercorp/pinpoint/collector/dao/hbase/statistics/BulkConfiguration.java @@ -55,7 +55,7 @@ public BulkConfiguration(BulkIncrementerFactory bulkIncrementerFactory, @Bean("callerBulkIncrementer") public BulkIncrementer getCallerBulkIncrementer() { - String reporterName = "callerBulkReporter"; + String reporterName = "callerBulkIncrementerReporter"; HbaseColumnFamily hbaseColumnFamily = HbaseColumnFamily.MAP_STATISTICS_CALLER_VER2_COUNTER; int limitSize = callerLimitSize; @@ -64,7 +64,7 @@ public BulkIncrementer getCallerBulkIncrementer() { @Bean("calleeBulkIncrementer") public BulkIncrementer getCalleeBulkIncrementer() { - String reporterName = "calleeBulkReporter"; + String reporterName = "calleeBulkIncrementerReporter"; HbaseColumnFamily hbaseColumnFamily = HbaseColumnFamily.MAP_STATISTICS_CALLEE_VER2_COUNTER; int limitSize = calleeLimitSize; @@ -73,7 +73,7 @@ public BulkIncrementer getCalleeBulkIncrementer() { @Bean("selfBulkIncrementer") public BulkIncrementer getSelfBulkIncrementer() { - String reporterName = "selfBulkReporter"; + String reporterName = "selfBulkIncrementerReporter"; HbaseColumnFamily hbaseColumnFamily = HbaseColumnFamily.MAP_STATISTICS_SELF_VER2_COUNTER; int limitSize = selfLimitSize; @@ -90,7 +90,7 @@ private BulkIncrementer newBulkIncrementer(String reporterName, HbaseColumnFamil @Bean("callerBulkUpdater") public BulkUpdater getCallerBulkUpdater() { - String reporterName = "callerBulkUpdater"; + String reporterName = "callerBulkUpdaterReporter"; return getBulkUpdater(reporterName); } @@ -102,13 +102,13 @@ private BulkUpdater getBulkUpdater(String reporterName) { @Bean("calleeBulkUpdater") public BulkUpdater getCalleeBulkUpdater() { - String reporterName = "calleeBulkUpdater"; + String reporterName = "calleeBulkUpdaterReporter"; return getBulkUpdater(reporterName); } @Bean("selfBulkUpdater") public BulkUpdater getSelfBulkUpdater() { - String reporterName = "selfBulkUpdater"; + String reporterName = "selfBulkUpdaterReporter"; return getBulkUpdater(reporterName); }