Skip to content

Commit 6b589f0

Browse files
cvictorycarryxyh
authored andcommitted
Modify MetadataReportRetry ThreadName (#3550)
* fix: rename the thread name from DubboRegistryFailedRetryTimer to DubboMetadataReportRetryTimer in MetadataReportRetry
1 parent f71a95b commit 6b589f0

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

dubbo-metadata-report/dubbo-metadata-report-api/src/main/java/org/apache/dubbo/metadata/support/AbstractMetadataReport.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public abstract class AbstractMetadataReport implements MetadataReport {
6262
// Log output
6363
protected final Logger logger = LoggerFactory.getLogger(getClass());
6464

65-
// Local disk cache, where the special key value.registries records the list of registry centers, and the others are the list of notified service providers
65+
// Local disk cache, where the special key value.registries records the list of metadata centers, and the others are the list of notified service providers
6666
final Properties properties = new Properties();
6767
private final ExecutorService reportCacheExecutor = Executors.newFixedThreadPool(1, new NamedThreadFactory("DubboSaveMetadataReport", true));
6868
final Map<MetadataIdentifier, Object> allMetadataReports = new ConcurrentHashMap<>(4);
@@ -336,7 +336,7 @@ long calculateStartTime() {
336336
class MetadataReportRetry {
337337
protected final Logger logger = LoggerFactory.getLogger(getClass());
338338

339-
final ScheduledExecutorService retryExecutor = Executors.newScheduledThreadPool(0, new NamedThreadFactory("DubboRegistryFailedRetryTimer", true));
339+
final ScheduledExecutorService retryExecutor = Executors.newScheduledThreadPool(0, new NamedThreadFactory("DubboMetadataReportRetryTimer", true));
340340
volatile ScheduledFuture retryScheduledFuture;
341341
AtomicInteger retryCounter = new AtomicInteger(0);
342342
// retry task schedule period
@@ -358,7 +358,7 @@ void startRetryTask() {
358358
retryScheduledFuture = retryExecutor.scheduleWithFixedDelay(new Runnable() {
359359
@Override
360360
public void run() {
361-
// Check and connect to the registry
361+
// Check and connect to the metadata
362362
try {
363363
int times = retryCounter.incrementAndGet();
364364
logger.info("start to retry task for metadata report. retry times:" + times);

0 commit comments

Comments
 (0)