MALFORMED_STATE_IN_RATE_PER_MICRO_BATCH_SOURCE error condition
Malformed state in RatePerMicroBatch source.
INVALID_OFFSET
The offset value is invalid: startOffset should less than or equal to the endOffset, but startOffset(<startOffset>
) > endOffset(<endOffset>
).
INVALID_TIMESTAMP
The timestamp value is invalid: startTimestamp should less than or equal to the endTimestamp, but startTimestamp(<startTimestamp>
) > endTimestamp(<endTimestamp>
).
This could happen when the streaming query is restarted with a newer startingTimestamp
and reprocess the first batch (i.e. batch 0). Please consider using a new checkpoint location.