This is an automated email from the ASF dual-hosted git repository. mmerli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push: new f535627 Throw exception of source/sink (#1756) f535627 is described below commit f53562755b033062e5774592b5276da66ec2a752 Author: Sanjeev Kulkarni <sanjee...@gmail.com> AuthorDate: Wed May 9 15:08:42 2018 -0700 Throw exception of source/sink (#1756) * Throw exception of source/sink * Don't double log --- .../pulsar/functions/instance/JavaInstanceRunnable.java | 16 +++------------- 1 file changed, 3 insertions(+), 13 deletions(-) diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java index 36d6521..3ef7bac 100644 --- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java +++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java @@ -479,12 +479,7 @@ public class JavaInstanceRunnable implements AutoCloseable, Runnable { } this.source = (Source) object; - try { - this.source.open(new Gson().fromJson(sourceSpec.getConfigs(), Map.class)); - } catch (Exception e) { - log.info("Error occurred executing open for source: {}", - sourceSpec.getClassName(), e); - } + this.source.open(new Gson().fromJson(sourceSpec.getConfigs(), Map.class)); } public void setupOutput() throws Exception { @@ -518,11 +513,6 @@ public class JavaInstanceRunnable implements AutoCloseable, Runnable { } else { throw new RuntimeException("Sink does not implement correct interface"); } - try { - this.sink.open(new Gson().fromJson(sinkSpec.getConfigs(), Map.class)); - } catch (Exception e) { - log.info("Error occurred executing open for sink: {}", - sinkSpec.getClassName(), e); - } + this.sink.open(new Gson().fromJson(sinkSpec.getConfigs(), Map.class)); } -} \ No newline at end of file +} -- To stop receiving notification emails like this one, please contact mme...@apache.org.