Changing default function subscription to be function name, not FQFN

(cherry picked from commit 4bb9056)
datastax · May 7, 2021 · 186e63b · 186e63b
1 parent e03a65f
commit 186e63b
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/...-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceUtils.java b/...-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceUtils.java
@@ -117,7 +117,9 @@ public Function.FunctionDetails.ComponentType calculateSubjectType(Function.Func
     }
 
     public static String getDefaultSubscriptionName(String tenant, String namespace, String name) {
-        return FunctionCommon.getFullyQualifiedName(tenant, namespace, name);
+        // Hacking this to just return the function name. Using a FQFN breaks the REST endpoints
+        // that deal with subscriptions
+        return name;
     }
 
     public static String getDefaultSubscriptionName(Function.FunctionDetails functionDetails) {

diff --git a/pulsar-functions/instance/src/main/python/python_instance.py b/pulsar-functions/instance/src/main/python/python_instance.py
@@ -136,9 +136,8 @@ def run(self):
     if self.instance_config.function_details.source.subscriptionType == Function_pb2.SubscriptionType.Value("FAILOVER"):
       mode = pulsar._pulsar.ConsumerType.Failover
 
-    subscription_name = str(self.instance_config.function_details.tenant) + "/" + \
-                        str(self.instance_config.function_details.namespace) + "/" + \
-                        str(self.instance_config.function_details.name)
+    # Default subscription to function name
+    subscription_name = str(self.instance_config.function_details.name)
 
     properties = util.get_properties(util.getFullyQualifiedFunctionName(
                         self.instance_config.function_details.tenant,