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)?

Reply via email to