GitHub user KarenjanM edited a discussion: Problems with extending StreamPipes with a new Data Processor
Hello, I am getting familiar with StreamPipes and I wanted also to try extending it with a new Data Processor as it stays in documentation. I did everything according to documentation: - Created a project with the corresponding Maven archetype, added all needed environment variables as EnvFile in IntelliJ and launched it. It all seems to work, because I can go to localhost:8005 and find there links for the example processor and sink, also with appropriate IP-address. However when I try to start a pipeline with this ExampleProcessor I get **400 Bad Request** error. **Logs from backend:** streampipes-backend-1 | 2023-07-12T07:34:48.357Z ERROR 1 --- [nio-8030-exec-6] o.a.s.m.e.http.InvokeHttpRequest : Could not perform invocation request at http://172.27.30.183:8005/sepa/deep5.pe.example.processor for pipeline element ExampleProcessor: status code: 400, reason phrase: Bad Request streampipes-backend-1 | 2023-07-12T07:34:48.358Z INFO 1 --- [nio-8030-exec-6] o.a.s.m.e.http.InvokeHttpRequest : Invoking element: http://172.31.0.7:8090/sec/org.apache.streampipes.sinks.internal.jvm.datalake streampipes-backend-1 | 2023-07-12T07:34:48.369Z INFO 1 --- [nio-8030-exec-6] a.s.m.e.h.InvokePipelineElementSubmitter : Could not start pipeline, initializing rollback... streampipes-backend-1 | 2023-07-12T07:35:00.962Z INFO 1 --- [pool-3-thread-1] o.a.s.m.m.p.ExtensionsServiceLogExecutor : Could not fetch log info from endpoint http://172.27.30.183:8005 Also I get some not critical errors in **ExampleProcessor** itself: Jul 12, 2023 9:56:56 AM org.glassfish.jersey.server.wadl.WadlFeature configure WARNING: JAXBContext implementation could not be found. WADL feature is disabled. 09:57:00.485 SP [OkHttp http://localhost:8500/...] ERROR com.orbitz.consul.cache.ConsulCache - Error getting response from consul for health.service "core", will retry in 10000 MILLISECONDS com.orbitz.consul.ConsulException: Consul cluster has no elected leader at com.orbitz.consul.cache.ConsulCache$1.onComplete(ConsulCache.java:180) at com.orbitz.consul.util.Http$1.onResponse(Http.java:80) at retrofit2.OkHttpCall$1.onResponse(OkHttpCall.java:161) at okhttp3.internal.connection.RealCall$AsyncCall.run(RealCall.kt:519) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) at java.base/java.lang.Thread.run(Thread.java:833) 09:57:01.573 SP [OkHttp http://localhost:8500/...] ERROR com.orbitz.consul.cache.ConsulCache - Error getting response from consul for health.service "ext", will retry in 10000 MILLISECONDS com.orbitz.consul.ConsulException: Consul cluster has no elected leader at com.orbitz.consul.cache.ConsulCache$1.onComplete(ConsulCache.java:180) at com.orbitz.consul.util.Http$1.onResponse(Http.java:80) at retrofit2.OkHttpCall$1.onResponse(OkHttpCall.java:161) I would be very thankful, if somebody helps me with the problem GitHub link: https://github.com/apache/streampipes/discussions/1768 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected]
