-
Notifications
You must be signed in to change notification settings - Fork 29
Volume Tracing Stream: Skip invalid buckets #3541
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
I believe that this happens for tracings edited during the fossildb overload. It does not happen for my new tracings and also not for my old tracings. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM 👍
def bucketStreamWithVersion(dataLayer: VolumeTracingLayer, resolution: Int, version: Option[Long]): Iterator[(BucketPosition, Array[Byte], Long)] = { | ||
val key = buildKeyPrefix(dataLayer.name, resolution) | ||
new VersionedBucketIterator(key, volumeDataStore, version) | ||
new VersionedBucketIterator(key, volumeDataStore, version).flatMap(item => item) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
.flatten
should do the same thing
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
But I am apparently to late to the party :(
The only explanation I can see for the None.get as posted here is invalid bucket keys being returned by the getMultipleKeys. This is troubling and we should look into the fossildb contents. However, since wK can show volume data for these tracings, the download (+copy to my account) may be fixed when we just skip all the invalid keys.
URL of deployed dev instance (used for testing):
Steps to test:
Issues:
[ ] Updated changelog[ ] Updated migration guide if applicable[ ] Updated documentation if applicabledatastoretracingstore update after deployment