You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@streampipes.apache.org by "Philipp Zehnder (Jira)" <ji...@apache.org> on 2021/11/13 06:23:00 UTC
[jira] [Commented] (STREAMPIPES-461) 500 error if mqtt adapter is created
[ https://issues.apache.org/jira/browse/STREAMPIPES-461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17443025#comment-17443025 ]
Philipp Zehnder commented on STREAMPIPES-461:
---------------------------------------------
Hi,
thanks for reporting the problem.
It seems that the worker executing the adapters is not able to communicate with the backend. This is also the reason why the adapter shows up in the adapters overview, but not in the pipeline editor.
When you start an adapter the backend initiates the adapter creation in the worker, which then registers the newly created adapter in the backend. Can you please check if the worker is able to connect to the backend? Therefore you can log into the worker container and try to ping the backend.
Philipp
> 500 error if mqtt adapter is created
> ------------------------------------
>
> Key: STREAMPIPES-461
> URL: https://issues.apache.org/jira/browse/STREAMPIPES-461
> Project: StreamPipes
> Issue Type: Bug
> Reporter: Simon Bosse
> Priority: Major
>
> Hi,
> we are running streampipes Version 0.68 inside kubernetes. At the moment we have the problem that if a mqtt adapter is created after clicking on "Start adapter" the message "Please wait while your adapter is generated" keeps spinning. If I look at the requests in the browser I can see that there is a 500 error.
> If I open then streampipes in a new window under connect/adapters I can see the adapter but it is not shown in the pipeline editor.
> In the logs of the backend pod I see this 500 error. What can be the cause of this?
> 10:12:29.643 SP [http-nio-8030-exec-2] INFO o.a.s.c.c.m.m.AdapterMasterManagement - Start adapter
> 10:12:29.647 SP [http-nio-8030-exec-2] INFO o.a.s.c.c.m.m.AdapterMasterManagement - Install source (source URL: http://backend:8030/streampipes-backend/api/v2/connect/name@email.de/master/sources/69f9ff51-f7f0-40b1-8948-20c76a269fa4 in backend over URL: http://backend:8030/streampipes-backend/api/v2/noauth/users/sysops@edi.gmbh/element
> 10:12:29.676 SP [http-nio-8030-exec-2] ERROR o.a.c.c.C.[.[.[.[.a.s.b.StreamPipesResourceConfig] - Servlet.service() for servlet [org.apache.streampipes.backend.StreamPipesResourceConfig] in context with path [/streampipes-backend] threw exception [javax.persistence.PersistenceException: javax.persistence.PersistenceException: javax.persistence.PersistenceException: java.lang.NullPointerException] with root cause
> java.lang.NullPointerException: null
> at io.fogsy.empire.core.empire.impl.EntityManagerImpl$MergeCascade.cascade(EntityManagerImpl.java:530)
> at io.fogsy.empire.core.empire.impl.EntityManagerImpl$CascadeAction.test(EntityManagerImpl.java:580)
> at io.fogsy.empire.core.empire.impl.EntityManagerImpl.cascadeOperation(EntityManagerImpl.java:516)
> at io.fogsy.empire.core.empire.impl.EntityManagerImpl.persist(EntityManagerImpl.java:360)
> at io.fogsy.empire.core.empire.impl.EntityManagerImpl$MergeCascade.cascade(EntityManagerImpl.java:535)
> at io.fogsy.empire.core.empire.impl.EntityManagerImpl$CascadeAction.test(EntityManagerImpl.java:580)
> at io.fogsy.empire.core.empire.impl.EntityManagerImpl.cascadeOperation(EntityManagerImpl.java:516)
> at io.fogsy.empire.core.empire.impl.EntityManagerImpl.persist(EntityManagerImpl.java:360)
> at io.fogsy.empire.core.empire.impl.EntityManagerImpl$MergeCascade.cascade(EntityManagerImpl.java:535)
> at io.fogsy.empire.core.empire.impl.EntityManagerImpl$CascadeAction.test(EntityManagerImpl.java:584)
> at io.fogsy.empire.core.empire.impl.EntityManagerImpl.cascadeOperation(EntityManagerImpl.java:516)
> at io.fogsy.empire.core.empire.impl.EntityManagerImpl.persist(EntityManagerImpl.java:360)
> at org.apache.streampipes.storage.rdf4j.impl.PipelineElementStorageRequests.storeDataStream(PipelineElementStorageRequests.java:57)
> at org.apache.streampipes.storage.rdf4j.impl.PipelineElementInMemoryStorage.storeDataStream(PipelineElementInMemoryStorage.java:104)
> at org.apache.streampipes.manager.verification.DataStreamVerifier.store(DataStreamVerifier.java:51)
> at org.apache.streampipes.manager.verification.ElementVerifier.verifyAndAdd(ElementVerifier.java:100)
> at org.apache.streampipes.connect.container.master.management.AdapterMasterManagement.installDataSource(AdapterMasterManagement.java:125)
> at org.apache.streampipes.connect.container.master.management.AdapterMasterManagement.addAdapter(AdapterMasterManagement.java:118)
> at org.apache.streampipes.connect.container.master.rest.AdapterResource.addAdapter(AdapterResource.java:56)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory.lambda$static$0(ResourceMethodInvocationHandlerFactory.java:52)
> at org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory$$Lambda$700/0x000000002406e8f0.invoke(Unknown Source)
> at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:124)
> at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:167)
> at org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$ResponseOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:176)
> at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:79)
> at org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:475)
> at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:397)
> at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:81)
> at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:255)
> at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)
> at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)
> at org.glassfish.jersey.internal.Errors.process(Errors.java:292)
> at org.glassfish.jersey.internal.Errors.process(Errors.java:274)
> at org.glassfish.jersey.internal.Errors.process(Errors.java:244)
> at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265)
> at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:234)
> at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:680)
> at org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:394)
> at org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:346)
> at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:366)
> at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:319)
> at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:205)
> at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)
> at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
> at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53)
> at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
> at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
> at org.apache.shiro.web.servlet.ProxiedFilterChain.doFilter(ProxiedFilterChain.java:61)
> at org.apache.shiro.web.servlet.AdviceFilter.executeChain(AdviceFilter.java:108)
> at org.apache.shiro.web.servlet.AdviceFilter.doFilterInternal(AdviceFilter.java:137)
> at org.apache.shiro.web.servlet.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:125)
> at org.apache.shiro.web.servlet.ProxiedFilterChain.doFilter(ProxiedFilterChain.java:66)
> at org.apache.shiro.web.servlet.AdviceFilter.executeChain(AdviceFilter.java:108)
> at org.apache.shiro.web.servlet.AdviceFilter.doFilterInternal(AdviceFilter.java:137)
> at org.apache.shiro.web.servlet.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:125)
> at org.apache.shiro.web.servlet.ProxiedFilterChain.doFilter(ProxiedFilterChain.java:66)
> at org.apache.shiro.web.servlet.AdviceFilter.executeChain(AdviceFilter.java:108)
> at org.apache.shiro.web.servlet.AdviceFilter.doFilterInternal(AdviceFilter.java:137)
> at org.apache.shiro.web.servlet.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:125)
> at org.apache.shiro.web.servlet.ProxiedFilterChain.doFilter(ProxiedFilterChain.java:66)
> at org.apache.shiro.web.servlet.AbstractShiroFilter.executeChain(AbstractShiroFilter.java:450)
> at org.apache.shiro.web.servlet.AbstractShiroFilter$1.call(AbstractShiroFilter.java:365)
> at org.apache.shiro.subject.support.SubjectCallable.doCall(SubjectCallable.java:90)
> at org.apache.shiro.subject.support.SubjectCallable.call(SubjectCallable.java:83)
> at org.apache.shiro.subject.support.DelegatingSubject.execute(DelegatingSubject.java:387)
> at org.apache.shiro.web.servlet.AbstractShiroFilter.doFilterInternal(AbstractShiroFilter.java:362)
> at org.apache.shiro.web.servlet.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:125)
> at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
> at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
> at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100)
> at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)
> at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
> at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
> at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93)
> at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)
> at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
> at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
> at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201)
> at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)
> at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
> at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
> at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:202)
> at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:97)
> at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:542)
> at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:143)
> at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)
> at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:78)
> at org.apache.catalina.valves.RemoteIpValve.invoke(RemoteIpValve.java:764)
> at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343)
> at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:374)
> at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:65)
> at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:888)
> at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1597)
> at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
> at java.lang.Thread.run(Thread.java:823)
--
This message was sent by Atlassian Jira
(v8.20.1#820001)