fix minor issue when cleaning up subscriptions for functions (apache#…

…4461)
ouyanghuangzheng · Jun 4, 2019 · ec8961f · ec8961f
1 parent 4db4d53
commit ec8961f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...r-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionActioner.java b/...r-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionActioner.java
@@ -346,7 +346,7 @@ public void accept(Map.Entry<String, Function.ConsumerSpec> stringConsumerSpecEn
                                                             List<Map<String, String>> existingConsumers = Collections.emptyList();
                                                             try {
                                                                 TopicStats stats = pulsarAdmin.topics().getStats(topic);
-                                                                SubscriptionStats sub = stats.subscriptions.get(InstanceUtils.getDefaultSubscriptionName(details));
+                                                                SubscriptionStats sub = stats.subscriptions.get(subscriptionName);
                                                                 if (sub != null) {
                                                                     existingConsumers = sub.consumers.stream()
                                                                             .map(consumerStats -> consumerStats.metadata)