Github user efimpoberezkin commented on the issue:
https://github.com/apache/spark/pull/21392
@jose-torres Hi Jose, could you take a look at this pr please? I had doubts
how to properly implement error reporting logic we were discussing and this is
what I came up with.
Also please advise how to test these changes. I was writing this several
weeks ago so if my memory doesn't fail me I thought about the approach similar
to tests in ContinuousSuite with custom StreamActions, but wasn't completely
sure.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
