Hey, How errors in the IOs can be treated (for example connection errors)?
I've tested few scenarios with the JmsIO. When I read from two different jms connections and I closed only one of them, the entire pipeline failed/froze. I would expect it to continue running with one source and try to reconnect to the second source until it's available again. Is this a bug in the IO itself? In the SDK? In the runner (I've tested with the direct runner and the spark runner)?