This is an automated email from the ASF dual-hosted git repository.

lixiaojie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git


The following commit(s) were added to refs/heads/master by this push:
     new e89b3f2  fix issue #3533 (#3548)
e89b3f2 is described below

commit e89b3f2728248242e38e70627d761be776ef03ec
Author: THY <[email protected]>
AuthorDate: Sun Feb 24 14:20:57 2019 +0800

    fix issue #3533 (#3548)
---
 .../apache/dubbo/configcenter/support/zookeeper/CacheListener.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/dubbo-configcenter/dubbo-configcenter-zookeeper/src/main/java/org/apache/dubbo/configcenter/support/zookeeper/CacheListener.java
 
b/dubbo-configcenter/dubbo-configcenter-zookeeper/src/main/java/org/apache/dubbo/configcenter/support/zookeeper/CacheListener.java
index a1e1f08..1851a22 100644
--- 
a/dubbo-configcenter/dubbo-configcenter-zookeeper/src/main/java/org/apache/dubbo/configcenter/support/zookeeper/CacheListener.java
+++ 
b/dubbo-configcenter/dubbo-configcenter-zookeeper/src/main/java/org/apache/dubbo/configcenter/support/zookeeper/CacheListener.java
@@ -38,6 +38,8 @@ import java.util.concurrent.CountDownLatch;
  *
  */
 public class CacheListener implements TreeCacheListener {
+    private static final byte[] EMPTY_BYTES = new byte[0];
+
     private Map<String, Set<ConfigurationListener>> keyListeners = new 
ConcurrentHashMap<>();
     private CountDownLatch initializedLatch;
     private String rootPath;
@@ -83,6 +85,9 @@ public class CacheListener implements TreeCacheListener {
                     return;
             }
 
+            if (value == null) {
+                value = EMPTY_BYTES;
+            }
             ConfigChangeEvent configChangeEvent = new ConfigChangeEvent(key, 
new String(value, StandardCharsets.UTF_8), changeType);
             Set<ConfigurationListener> listeners = keyListeners.get(key);
             if (CollectionUtils.isNotEmpty(listeners)) {

Reply via email to