riesgos / async

0 stars 0 forks source link

An idea to not completely share the jar file between containers. #50

Closed nbrinckm closed 1 year ago

nbrinckm commented 1 year ago

I'm not sure yet if that solves the problem with the changed documents, but this change here should make sure that we don't share the actual jar files between the containers as everyone gets its very own jar file.

(From my understanding also every container just listen to one kind of message on the pulsar - here is no further parallelization that could trigger those unwanted changes. But I'm not 100% sure if I understand completely what happens there).

nbrinckm commented 1 year ago

Seems that the stuff doesn't work as I want:

2023-02-14 13:44:44,468 [assetmaster-asyncwrapper_new-order_subscription] INFO  AbstractWrapper: WPS call failed                                                                                    [52/425]
org.n52.geoprocessing.wps.client.WPSClientException: Got HTTP error code, response: Exceptions: [       Code: NoApplicableCode  Text: java.util.ConcurrentModificationException: Document changed during sav
e                                                                                                                                                                                                           
        at org.apache.xmlbeans.impl.store.Saver.process(Saver.java:302)                                                                                                                                     
        at org.apache.xmlbeans.impl.store.Saver$TextSaver.write(Saver.java:1817)                                                                                                                            
        at org.apache.xmlbeans.impl.store.Saver$InputStreamSaver.ensure(Saver.java:2521)                                                                                                                    
        at org.apache.xmlbeans.impl.store.Saver$InputStreamSaver.access$100(Saver.java:2419)                                                                                                                
        at org.apache.xmlbeans.impl.store.Saver$InputStreamSaver$OutputStreamImpl.read(Saver.java:2570)                                                                                                     
        at org.apache.xmlbeans.impl.store.Saver$InputStreamSaver.read(Saver.java:2504)                                                                                                                      
        at java.io.InputStream.read(InputStream.java:101)                                                                                                                                                   
        at org.apache.commons.io.IOUtils.copyLarge(IOUtils.java:1262)                                                                                                                                       
        at org.apache.commons.io.IOUtils.copy(IOUtils.java:1236)                                                                                                                                            
        at org.n52.wps.server.handler.RequestHandler.handle(RequestHandler.java:431)                                                                                                                        
        at org.n52.wps.server.WebProcessingService.doGet(WebProcessingService.java:223)                                                                                                                     
        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.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:221)
        at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:137)
        at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:110)
        at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandleMethod(RequestMappingHandlerAdapter.java:776)
        at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:705)
        at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85)
        at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:959)
        at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:893)
...

Still get the error that I tried to resolve.

nbrinckm commented 1 year ago

I close this PR for now, as it clearly doesn't solve the problem.