rmdmattingly commented on code in PR #5481:
URL: https://github.com/apache/hbase/pull/5481#discussion_r1383448371
##########
hbase-server/src/main/java/org/apache/hadoop/hbase/namequeues/RpcLogDetails.java:
##########
@@ -60,6 +64,18 @@ public RpcLogDetails(RpcCall rpcCall, Message param, String
clientAddress, long
// would result in corrupted attributes
this.connectionAttributes = rpcCall.getConnectionAttributes();
this.requestAttributes = rpcCall.getRequestAttributes();
+
+ // We also need to deep copy the message because the CodedInputStream may
be
+ // overwritten before this slow log is consumed. Such overwriting could
+ // cause the slow log payload to be corrupt
+ try {
+ this.param =
param.newBuilderForType().mergeFrom(param.toByteArray()).build();
+ } catch (InvalidProtocolBufferException e) {
+ LOG.error("Failed to parse protobuf for message {}", param, e);
+ if (this.param == null) {
Review Comment:
yeah, I can't imagine when it wouldn't be true so maybe we should just
remove this
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
