Greetings,

I was able to successfully install and run StreamPipes. I created a simple 
pipeline following provided tutorial in the Pipeline Editor.

Afterwards i tried to follow 
this<https://streampipes.apache.org/docs/docs/dev-guide-archetype/> tutorial 
and create a custom pipeline element:

  *   I am using IntelliJ IDE
  *   I created the project using following command: mvn archetype:generate 
-DarchetypeGroupId=org.apache.streampipes 
-DarchetypeArtifactId=streampipes-archetype-pe-processors-jvm 
-DarchetypeVersion=0.66.0 -DgroupId=org.apache.streampipes.test 
-DartifactId=TestProcessor -DclassNamePrefix=TestProcessor -DpackageName=test
  *   I edited processor's onEvent method according to instructions.

However, when i tried running the project i got following error regarding 
Consul:

"""
09:59:25,289 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could 
NOT find resource [logback-test.xml]
09:59:25,289 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Could 
NOT find resource [logback.groovy]
09:59:25,290 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Found 
resource [logback.xml] at 
[jar:file:/home/nissa/.m2/repository/org/apache/streampipes/streampipes-commons/0.66.0/streampipes-commons-0.66.0.jar!/logback.xml]
09:59:25,298 |-INFO in 
ch.qos.logback.core.joran.spi.ConfigurationWatchList@281e3708 - URL 
[jar:file:/home/nissa/.m2/repository/org/apache/streampipes/streampipes-commons/0.66.0/streampipes-commons-0.66.0.jar!/logback.xml]
 is not of type file
09:59:25,337 |-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction 
- debug attribute not set
09:59:25,337 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - About 
to instantiate appender of type [ch.qos.logback.core.ConsoleAppender]
09:59:25,342 |-INFO in ch.qos.logback.core.joran.action.AppenderAction - Naming 
appender as [STDOUT]
09:59:25,383 |-WARN in ch.qos.logback.core.ConsoleAppender[STDOUT] - This 
appender no longer admits a layout as a sub-component, set an encoder instead.
09:59:25,383 |-WARN in ch.qos.logback.core.ConsoleAppender[STDOUT] - To ensure 
compatibility, wrapping your layout in LayoutWrappingEncoder.
09:59:25,383 |-WARN in ch.qos.logback.core.ConsoleAppender[STDOUT] - See also 
http://logback.qos.ch/codes.html#layoutInsteadOfEncoder for details
09:59:25,383 |-INFO in ch.qos.logback.classic.joran.action.LoggerAction - 
Setting level of logger [org.apache.streampipes] to INFO
09:59:25,383 |-INFO in ch.qos.logback.classic.joran.action.LoggerAction - 
Setting level of logger [org.lightcouch] to ERROR
09:59:25,383 |-INFO in ch.qos.logback.classic.joran.action.RootLoggerAction - 
Setting level of ROOT logger to INFO
09:59:25,383 |-INFO in ch.qos.logback.core.joran.action.AppenderRefAction - 
Attaching appender named [STDOUT] to Logger[ROOT]
09:59:25,384 |-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction 
- End of configuration.
09:59:25,384 |-INFO in ch.qos.logback.classic.joran.JoranConfigurator@35a50a4c 
- Registering current configuration as safe fallback point

Exception in thread "main" java.lang.ExceptionInInitializerError
at 
org.apache.streampipes.test.main.Init.main(<DeclarersSingleton.getInstance().setPort(Config.INSTANCE.getPort());>)
Caused by: com.orbitz.consul.ConsulException: Error connecting to Consul
at com.orbitz.consul.AgentClient.ping(AgentClient.java:69)
at com.orbitz.consul.Consul$Builder.build(Consul.java:731)
at 
org.apache.streampipes.config.consul.ConsulSpConfig.<init>(ConsulSpConfig.java:62)
at org.apache.streampipes.config.SpConfig.getSpConfig(SpConfig.java:38)
at org.apache.streampipes.test.config.Config.<init>(<config = 
SpConfig.getSpConfig("pe/org.apache.streampipes.test");>)
at org.apache.streampipes.test.config.Config.<clinit>(<INSTANCE;>)
... 1 more
Caused by: java.net.ConnectException: Failed to connect to 
localhost/127.0.0.1:8500
at 
okhttp3.internal.connection.RealConnection.connectSocket(RealConnection.java:249)
at okhttp3.internal.connection.RealConnection.connect(RealConnection.java:167)
at 
okhttp3.internal.connection.StreamAllocation.findConnection(StreamAllocation.java:257)
at 
okhttp3.internal.connection.StreamAllocation.findHealthyConnection(StreamAllocation.java:135)
at 
okhttp3.internal.connection.StreamAllocation.newStream(StreamAllocation.java:114)
at 
okhttp3.internal.connection.ConnectInterceptor.intercept(ConnectInterceptor.java:42)
at 
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
at 
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
at okhttp3.internal.cache.CacheInterceptor.intercept(CacheInterceptor.java:93)
at 
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
at 
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
at okhttp3.internal.http.BridgeInterceptor.intercept(BridgeInterceptor.java:93)
at 
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
at 
okhttp3.internal.http.RetryAndFollowUpInterceptor.intercept(RetryAndFollowUpInterceptor.java:126)
at 
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
at 
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
at 
com.orbitz.consul.cache.TimeoutInterceptor.intercept(TimeoutInterceptor.java:53)
at 
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:147)
at 
okhttp3.internal.http.RealInterceptorChain.proceed(RealInterceptorChain.java:121)
at okhttp3.RealCall.getResponseWithInterceptorChain(RealCall.java:250)
at okhttp3.RealCall.execute(RealCall.java:93)
at retrofit2.OkHttpCall.execute(OkHttpCall.java:186)
at com.orbitz.consul.AgentClient.ping(AgentClient.java:62)
... 6 more
Caused by: java.net.ConnectException: Connection refused
at java.base/sun.nio.ch.Net.pollConnect(Native Method)
at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:589)
at java.base/sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:542)
at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:597)
at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:333)
at java.base/java.net.Socket.connect(Socket.java:648)
at okhttp3.internal.platform.Platform.connectSocket(Platform.java:129)
at 
okhttp3.internal.connection.RealConnection.connectSocket(RealConnection.java:247)
... 28 more

Process finished with exit code 1
"""

​I checked, port 8500 was not registered to any program (including Consul) and 
is not blocked by Firewall.
Unfortunately, I am not familiar with Consul and my attempts at solving this 
problem were not successful.
I am running Linux Mint 19.3 Tricia base: Ubuntu 18.04 bionic.

I would be very grateful for your help in solving this issue.

Kindest regards,
Branislav Jovicic

Reply via email to