keith-turner commented on code in PR #5375:
URL: https://github.com/apache/accumulo/pull/5375#discussion_r1976502406
##########
server/base/src/main/java/org/apache/accumulo/server/rpc/CustomNonBlockingServer.java:
##########
@@ -119,6 +119,7 @@ public CustomFrameBuffer(TNonblockingTransport trans,
SelectionKey selectionKey,
super(trans, selectionKey, selectThread);
// Store the clientAddress in the buffer so it can be referenced for
logging during read/write
this.clientAddress = getClientAddress();
+ log.debug("created custom frame buffer ", new Exception());
Review Comment:
This was added as debug while trying to understand what is going on.
##########
server/tserver/src/main/java/org/apache/accumulo/tserver/TabletClientHandler.java:
##########
@@ -243,6 +245,8 @@ public void loadFiles(TInfo tinfo, TCredentials
credentials, long tid, String di
server.removeBulkImportState(files);
}
}
+ UtilWaitThread.sleep(100);
Review Comment:
Addes this sleep so that I could verify things were running concurrently in
the tserver and never saw that happen.
--
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]
