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
GOBBLIN-970: Pass metric context from the KafkaSource to the KafkaWor… #2815
Conversation
…kUnitPacker for emission of metrics from the packer.
@autumnust @ZihanLi58 Please review. |
Codecov Report
@@ Coverage Diff @@
## master #2815 +/- ##
============================================
- Coverage 45.56% 45.56% -0.01%
+ Complexity 8954 8951 -3
============================================
Files 1900 1900
Lines 71213 71217 +4
Branches 7856 7856
============================================
- Hits 32451 32449 -2
- Misses 35780 35782 +2
- Partials 2982 2986 +4
Continue to review full report at Codecov.
|
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, just a minor comment.
@@ -367,19 +368,19 @@ private static void logMultiWorkUnitInfo(Iterable<MultiWorkUnit> mwus) { | |||
return partitions; | |||
} | |||
|
|||
public static KafkaWorkUnitPacker getInstance(AbstractSource<?, ?> source, SourceState state) { |
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.
Should we keep the original function to make the change backward compatible?
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
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.
+1
Closes apache#2815 from sv2000/metricContextPacker
Closes apache#2815 from sv2000/metricContextPacker
…kUnitPacker for emission of metrics from the packer.
Dear Gobblin maintainers,
Please accept this PR. I understand that it will not be reviewed until I have checked off all the steps below!
JIRA
Description
Pass metric context from the KafkaSource to the KafkaWorkUnitPacker for emission of bin packing related metrics.
Tests
Modified KafkaWorkUnitPackerTest.
Commits