-
Notifications
You must be signed in to change notification settings - Fork 600
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
fix(streaming): inappropriate serialization for JoinRow
#2398
Conversation
Codecov Report
@@ Coverage Diff @@
## main #2398 +/- ##
=======================================
Coverage 71.36% 71.36%
=======================================
Files 680 680
Lines 86089 86088 -1
=======================================
Hits 61439 61439
+ Misses 24650 24649 -1
Flags with carried forward coverage won't be shown. Click here to find out more.
📣 Codecov can now indicate which changes are the most critical in Pull Requests. Learn more |
vec.extend_from_slice(&serializer.into_inner()); | ||
let mut degree_buf: Vec<u8> = vec![]; | ||
degree_buf.put_u64_le(self.degree); | ||
vec.extend_from_slice(°ree_buf); |
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.
vec.extend_from_slice(&self.degree.to_le_bytes())
should be enough?
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.
ditto
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.
Emmm didnt notice the auto merge
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.
Ah sorry, will fix those later.
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.
Rest LGTM
vec.extend_from_slice(&serializer.into_inner()); | ||
let mut degree_buf: Vec<u8> = vec![]; | ||
degree_buf.put_u64_le(self.degree); | ||
vec.extend_from_slice(°ree_buf); |
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.
ditto
What's changed and what's your intention?
Checklist
Refer to a related PR or issue link (optional)