-
Notifications
You must be signed in to change notification settings - Fork 9.1k
HADOOP-16290. Enable RpcMetrics units to be configurable #3198
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
Jenkins runs are failing recently, looks like an infra issue based on logs: https://ci-hadoop.apache.org/job/hadoop-multibranch/job/PR-3198/1/console |
This comment has been minimized.
This comment has been minimized.
a75c486
to
acd2d3c
Compare
This comment has been minimized.
This comment has been minimized.
RpcMetrics m = new RpcMetrics(server, conf); | ||
return DefaultMetricsSystem.instance().register(m.name, null, m); | ||
} | ||
|
||
private static void setMetricTimeUnit(Configuration conf) { |
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 can be error-prone because a process can have multiple Server binding at different ports at the same time.
So metricsTimeUnit is initialized multiple times for each Server creation. Hopefully they end up using the same metric unit. Otherwise this could hypothetically create confusion later on.
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.
Agree, let me make it this way. If server is instance of RPC.Server
(which is LimitedPrivate for Commons, HDFS, Yarn, MapReduce), we can make this change so that for anyone extending this Server from downstream application does not interfere with core-site config used in core Hadoop.
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.
Done
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 is recently addressed better by keeping metricsTimeUnit
as non-static final.
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestRPC.java
Outdated
Show resolved
Hide resolved
acd2d3c
to
528a51a
Compare
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/metrics/RpcMetrics.java
Outdated
Show resolved
Hide resolved
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
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.
Thank you @virajjasani for addressing the comments. Now I have a few additional minor comments, and I'm +1 if these are addressed.
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestRPC.java
Outdated
Show resolved
Hide resolved
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/DecayRpcScheduler.java
Outdated
Show resolved
Hide resolved
4c925e3
to
8723b39
Compare
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
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, thank you.
🎊 +1 overall
This message was automatically generated. |
QA results look good now. (earlier one had some temporary issue with hadoop-yarn-ui module, hence build was failing) |
@jojochuang Would you review this? |
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
🎊 +1 overall
This message was automatically generated. |
Signed-off-by: Akira Ajisaka <aajisaka@apache.org> (cherry picked from commit e1d00ad)
Thank you @virajjasani and @jojochuang! |
Signed-off-by: Akira Ajisaka <aajisaka@apache.org>
No description provided.