acdn-mpreston commented on issue #7926: Kafka Indexing breaks due to Mismatched DatSourceMetadata types during InternalReset call URL: https://github.com/apache/incubator-druid/issues/7926#issuecomment-513903778 @gvsmirnov yes, the issue can happen on a clean install as well, the upgrade path was just the easiest way I found to reproduce. :) My comment of running into issues "further down the pipeline" refers to a fix I tried originally in a referenced PR. Unfortunately, that attempt failed after the supervisor reset itself as it was expecting an offset stored as a SeekableStreamEndSequenceNumber (as the reset metadata should always have offsets stored using this class) but in my PR I had cast it to a SeekableStreamStartSequenceNumber. This resulted in another class mismatch, this time on the "plus" method call. This is what made me change my approach to just using SeekableStreamStartSequenceNumber class instances for storing the offset metadata as I clearly did not understand well enough all the places where the offset metadata would be retrieved and manipulated. By using only SeekableStreamEndSequenceNumber, there will never be a class mismatch.
---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
