You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by ha...@apache.org on 2019/03/02 04:29:32 UTC
[incubator-skywalking] 01/01: Update RegisterPersistentWorker.java
This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a commit to branch gao-patch-register
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git
commit 78f54864ec0cf46dfbe0a64df403fec7565bc832
Author: Gao Hongtao <ha...@gmail.com>
AuthorDate: Sat Mar 2 12:29:25 2019 +0800
Update RegisterPersistentWorker.java
Fixed wrong parameter
---
.../oap/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 3cbfc93..e42c880 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<RegisterSource> {
}
} 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)) {