This is an automated email from the ASF dual-hosted git repository. sanjeevrk pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push: new 138c863 Use the right field to get the filename (#2851) 138c863 is described below commit 138c863af0a43bd3423a7f3fb3846d2cb8dfe472 Author: Sanjeev Kulkarni <sanjee...@gmail.com> AuthorDate: Fri Oct 26 02:57:03 2018 -0700 Use the right field to get the filename (#2851) --- .../org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.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/FunctionsImpl.java b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.java index 087238c..89e3b48 100644 --- a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.java +++ b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.java @@ -243,8 +243,8 @@ public class FunctionsImpl { Utils.uploadFileToBookkeeper(packageLocationMetaDataBuilder.getPackagePath(), file, worker().getDlogNamespace()); } else { packageLocationMetaDataBuilder.setPackagePath(createPackagePath(tenant, namespace, componentName, - fileDetail.getName())); - packageLocationMetaDataBuilder.setOriginalFileName(fileDetail.getName()); + fileDetail.getFileName())); + packageLocationMetaDataBuilder.setOriginalFileName(fileDetail.getFileName()); log.info("Uploading {} package to {}", componentType, packageLocationMetaDataBuilder.getPackagePath()); Utils.uploadFileToBookkeeper(packageLocationMetaDataBuilder.getPackagePath(), uploadedInputStreamAsFile, worker().getDlogNamespace()); }