From 5629bc33f39043172cb8ae396e7c33b5631b2630 Mon Sep 17 00:00:00 2001 From: Gao Hongtao Date: Sat, 2 Mar 2019 14:52:22 +0800 Subject: [PATCH] Update RegisterPersistentWorker.java (#2307) Fixed wrong parameter --- .../server/core/register/worker/RegisterPersistentWorker.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/worker/RegisterPersistentWorker.java b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/worker/RegisterPersistentWorker.java index 3cbfc93ff..e42c880d8 100644 --- a/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/worker/RegisterPersistentWorker.java +++ b/oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/register/worker/RegisterPersistentWorker.java @@ -91,7 +91,7 @@ public class RegisterPersistentWorker extends AbstractWorker { } } else { int sequence; - if ((sequence = registerLockDAO.getId(scopeId, registerSource)) != Const.NONE) { + if ((sequence = registerLockDAO.getId(scopeId, source)) != Const.NONE) { try { dbSource = registerDAO.get(modelName, source.id()); if (Objects.nonNull(dbSource)) {