search

WallarooLabs / wally

Distributed Stream Processing
https://www.wallaroolabs.com
Apache License 2.0
1.48k stars 69 forks source link

Handle rollbackresume_barrier_complete event in AbortCheckpoint state #3110

Closed slfritchie closed 4 years ago

slfritchie commented 4 years ago

In rare cases, Wallaroo can generate a rollbackresume_barrier_complete event when ConnectorSink is in the AbortCheckpoint state. Let's handle this event rather than crash. Also, add more info to an existing debug log statement.

jtfmumm commented 4 years ago

@slfritchie This also has a failing test, but since it can't be caused by this change, I'm merging.