Hi Branislav, I assume you used the installer with the lite or full version? In this case, the only ports that are exposed by the docker-based installer are the ports that are the ports that are needed by the UI. We closed all other external ports to avoid port conflicts. For development purposes, we recommend using the CLI tool (which can be found in the cli folder of the installation zip file). In this version, all ports necessary for development are open by default.
Alternatively, you can also uncomment closed ports in the generated docker-compose.yml file (e.g., have a look at the consul service), but we recommend using the CLI for development. Hope this helps, if you have any other questions, feel free to ask! Dominik On 2020/07/29 11:17:35, Branislav Jovicic <[email protected]> wrote: > 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 >
