I get two different errors, randomly, as far as I can tell: https://pastebin.com/pEvLk81F https://pastebin.com/aKjsTGub Short offending code: https://pastebin.com/kND1Z0Rr
I read records from Kafka, deserialize the Avro as GenericRecords, assign my timestamp, convert to Row, then do a simple SQL query. I see a couple of early triggers, then this error. Getting from Kafka to SQL requires a lot of boilerplate with how I'm doing it. Maybe there's a smarter way. Other than that, I have no idea what could be causing this. Any help appreciated!
