Skip to content

Commit a616266

Browse files
committed
remove debugging added when tracking down issues
1 parent 932efdc commit a616266

File tree

2 files changed

+0
-4
lines changed

2 files changed

+0
-4
lines changed

server/base/src/main/java/org/apache/accumulo/server/rpc/CustomNonBlockingServer.java

-1
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,6 @@ public CustomFrameBuffer(TNonblockingTransport trans, SelectionKey selectionKey,
119119
super(trans, selectionKey, selectThread);
120120
// Store the clientAddress in the buffer so it can be referenced for logging during read/write
121121
this.clientAddress = getClientAddress();
122-
log.debug("created custom frame buffer ", new Exception());
123122
}
124123

125124
@Override

server/tserver/src/main/java/org/apache/accumulo/tserver/TabletClientHandler.java

-3
Original file line numberDiff line numberDiff line change
@@ -219,7 +219,6 @@ public void loadFiles(TInfo tinfo, TCredentials credentials, long tid, String di
219219

220220
watcher.runQuietly(Constants.BULK_ARBITRATOR_TYPE, tid, () -> {
221221
tabletImports.forEach((tke, fileMap) -> {
222-
log.debug("Starting bulk import for {} ", KeyExtent.fromThrift(tke));
223222
Map<TabletFile,MapFileInfo> newFileMap = new HashMap<>();
224223

225224
for (Entry<String,MapFileInfo> mapping : fileMap.entrySet()) {
@@ -244,8 +243,6 @@ public void loadFiles(TInfo tinfo, TCredentials credentials, long tid, String di
244243
server.removeBulkImportState(files);
245244
}
246245
}
247-
// UtilWaitThread.sleep(100);
248-
log.debug("Finished bulk import for {} ", KeyExtent.fromThrift(tke), new Exception());
249246
});
250247
});
251248

0 commit comments

Comments
 (0)