You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by sa...@apache.org on 2019/05/15 12:02:37 UTC
[pulsar] branch master updated: fix bug with source local run
(#4278)
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 ac8e4e3 fix bug with source local run (#4278)
ac8e4e3 is described below
commit ac8e4e38e8d5b811ed871711117393553c9687f4
Author: Boyang Jerry Peng <je...@gmail.com>
AuthorDate: Wed May 15 05:02:31 2019 -0700
fix bug with source local run (#4278)
---
.../src/main/java/org/apache/pulsar/functions/runtime/LocalRunner.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/LocalRunner.java b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/LocalRunner.java
index 581bbbf..1c180ab 100644
--- a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/LocalRunner.java
+++ b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/LocalRunner.java
@@ -133,7 +133,7 @@ public class LocalRunner {
if (!file.exists()) {
throw new RuntimeException("Source archive does not exist");
}
- functionDetails = SourceConfigUtils.convert(sourceConfig, SourceConfigUtils.validate(sourceConfig, null, null));
+ functionDetails = SourceConfigUtils.convert(sourceConfig, SourceConfigUtils.validate(sourceConfig, null, file));
}
} else {
SinkConfig sinkConfig = new Gson().fromJson(sinkConfigString, SinkConfig.class);