[incubator-pulsar] branch master updated: Throw exception of source/sink (#1756)

[mmerli]

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.