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)) {