bbejeck opened a new pull request, #22727:
URL: https://github.com/apache/kafka/pull/22727
Two defects surfaced when parameterizing the PositionRestartIntegrationTest
for transactional state stores
1. ClassCastException on IQv2 RangeQuery/TimestampedRangeQuery
An IQv2 `RangeQuery` or `TimestampedRangeQuery` against a transactional
store threw:
java.lang.ClassCastException: class StagedMergeIterator cannot be cast
to class RocksDbIterator
at KeyValueToTimestampedKeyValueByteStoreAdapter.query(...)
`KeyValueToTimestampedKeyValueByteStoreAdapter.query` cast the range
result to `RocksDbIterator`; a transactional store returns a
StagedMergeIterator
2. Committed Position not restored after restart
After a clean close and reopen, a position-bound IQv2 query against a
transactional store timed out with `NOT_UP_TO_BOUND` because the persisted
Position came back empty/stale:
current position Position{position={}} is not yet up to the bound ...
The committed Position was staged into the transaction buffer's write
batch by the `writePosition()` checkpoint callback but never flushed, and
the batch is discarded on close.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
