You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2022/11/03 12:56:05 UTC

[incubator-eventmesh] branch master updated: fix CI error: pulsar connector

This is an automated email from the ASF dual-hosted git repository.

mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git


The following commit(s) were added to refs/heads/master by this push:
     new 8f7185e5 fix CI error: pulsar connector
     new ad94e45a Merge pull request #2103 from horoc/fix-ci-error-pulsar
8f7185e5 is described below

commit 8f7185e559f2ff73a650b746c9e752c365a02cee
Author: horoc <ho...@gmail.com>
AuthorDate: Thu Nov 3 19:59:28 2022 +0800

    fix CI error: pulsar connector
---
 .../eventmesh/connector/pulsar/config/ConfigurationWrapper.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/ConfigurationWrapper.java b/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/ConfigurationWrapper.java
index af7d0cc7..ca2ccd0a 100644
--- a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/ConfigurationWrapper.java
+++ b/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/ConfigurationWrapper.java
@@ -52,12 +52,12 @@ public class ConfigurationWrapper {
      */
     private void loadProperties() {
         try (InputStream resourceAsStream = ConfigurationWrapper.class.getResourceAsStream(
-                "/" + EventMeshConstants.EVENTMESH_CONF_FILE)) {
+            "/" + EventMeshConstants.EVENTMESH_CONF_FILE)) {
             if (resourceAsStream != null) {
                 properties.load(resourceAsStream);
             }
         } catch (IOException e) {
-            log.error("Load {}.properties file from classpath error",EventMeshConstants.EVENTMESH_CONF_FILE,e);
+            log.error("Load {}.properties file from classpath error", EventMeshConstants.EVENTMESH_CONF_FILE, e);
             throw new RuntimeException(String.format("Load %s.properties file from classpath error", EventMeshConstants.EVENTMESH_CONF_FILE));
         }
 
@@ -67,7 +67,7 @@ public class ConfigurationWrapper {
                 properties.load(new BufferedReader(new FileReader(configPath)));
             }
         } catch (IOException e) {
-            log.error("Cannot load {} file from conf.", EventMeshConstants.EVENTMESH_CONF_FILE,e);
+            log.error("Cannot load {} file from conf.", EventMeshConstants.EVENTMESH_CONF_FILE, e);
             throw new IllegalArgumentException(String.format("Cannot load %s file from conf", EventMeshConstants.EVENTMESH_CONF_FILE));
         }
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org