-
Notifications
You must be signed in to change notification settings - Fork 513
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
Allow String key type to transform SMB sources with CharSequence key #5297
Conversation
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## main #5297 +/- ##
==========================================
- Coverage 62.67% 62.66% -0.01%
==========================================
Files 301 301
Lines 10844 10844
Branches 749 749
==========================================
- Hits 6796 6795 -1
- Misses 4048 4049 +1 ☔ View full report in Codecov by Sentry. |
@@ -403,11 +403,9 @@ private <MetadataT extends BucketMetadata> boolean isIntraPartitionCompatibleWit | |||
final Class<? extends BucketMetadata> otherClass = other.getClass(); | |||
final Set<Class<? extends BucketMetadata>> compatibleTypes = compatibleMetadataTypes(); | |||
|
|||
if (compatibleTypes.isEmpty() && other.getClass() != this.getClass()) { | |||
return false; | |||
} else if (this.getKeyClass() != other.getKeyClass() |
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.
this check was not correct; it should have been comparing the metadata class itself.
Added an assertion in AvroBucketMetadataTest for this
extension of #5291 for transforms.
+ adds support for sources with multiple partitions, where some partitions have CharSequence key and some have String key
( 🤦♀️ )