You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2019/03/02 06:52:27 UTC
[incubator-skywalking] branch master updated: Update
RegisterPersistentWorker.java (#2307)
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git
The following commit(s) were added to refs/heads/master by this push:
new 5629bc3 Update RegisterPersistentWorker.java (#2307)
5629bc3 is described below
commit 5629bc33f39043172cb8ae396e7c33b5631b2630
Author: Gao Hongtao <ha...@gmail.com>
AuthorDate: Sat Mar 2 14:52:22 2019 +0800
Update RegisterPersistentWorker.java (#2307)
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)) {