KAFKA-4752: Fixed bandwidth calculation #2551
Conversation
|
@dguy could you have a look? Thanks. |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
@dguy ok |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
@guozhangwang this is ready to go. Thanks. |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
| @@ -563,6 +568,7 @@ public void init(ProcessorContext context) { | |||
| @Override | |||
| public void process(Integer key, byte[] value) { | |||
| processedRecords++; | |||
| processedBytes += value.length + KEY_SIZE; | |||
There was a problem hiding this comment.
Could we just use Integer.SIZE and get rid of KEY_SIZE?
|
One minor comment, otherwise LGTM. |
|
Thanks @guozhangwang |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): |
Author: Eno Thereska <eno@confluent.io> Reviewers: Damian Guy, Guozhang Wang Closes apache#2551 from enothereska/KAFKA-4752-join-bw
No description provided.