diff options
Diffstat (limited to 'vdslib/src')
| -rw-r--r-- | vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java b/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java index 404ec357e93..47a09ab0873 100644 --- a/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java +++ b/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java @@ -127,7 +127,11 @@ public class Distribution { } public void close() { - if (configSub!=null) configSub.close(); + if (configSub!=null) { + configSub.close(); + configSub = null; + } + configSubscriber = null; } private int getGroupSeed(BucketId bucket, ClusterState state, Group group) { |