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:31 UTC
[incubator-skywalking] branch gao-patch-register created (now
78f5486)
This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a change to branch gao-patch-register
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git.
at 78f5486 Update RegisterPersistentWorker.java
This branch includes the following new commits:
new 78f5486 Update RegisterPersistentWorker.java
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[incubator-skywalking] 01/01: Update RegisterPersistentWorker.java
Posted by ha...@apache.org.
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)) {