From 0aacfc4500a1dc820861ab26356f114260fd68ff Mon Sep 17 00:00:00 2001
From: Christophe Bornet <cbornet@hotmail.com>
Date: Wed, 12 Oct 2022 16:51:44 +0200
Subject: [PATCH] [fix][connectors] Fix builtin sink transformation on k8s

---
 .../apache/pulsar/functions/worker/rest/api/SinksImpl.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SinksImpl.java b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SinksImpl.java
index dede6307e76f0..80454ee890160 100644
--- a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SinksImpl.java
+++ b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SinksImpl.java
@@ -433,8 +433,8 @@ private void setTransformFunctionPackageLocation(Function.FunctionMetaData.Build
                                                  Function.FunctionDetails functionDetails, String transformFunction) {
         File functionPackageFile = null;
         try {
-            String builtin = null;
-            if (!transformFunction.startsWith(Utils.BUILTIN)) {
+            String builtin = functionDetails.getBuiltin();
+            if (isBlank(builtin)) {
                 functionPackageFile = getPackageFile(transformFunction);
             }
             Function.PackageLocationMetaData.Builder functionPackageLocation =