Update server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/LoadFiles.java

keith-turner · ddanielr · web-flow · commit 2f65c478a86d · 2025-03-12T16:25:47.000-04:00
Co-authored-by: Daniel Roberts &lt;ddanielr@gmail.com&gt;
diff --git a/server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/LoadFiles.java b/server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/LoadFiles.java
@@ -242,7 +242,7 @@ private void sendQueued(int threshhold) {
                 client.send_loadFilesV2(TraceUtil.traceInfo(), manager.getContext().rpcCreds(), tid,
                     bulkDir.toString(), chunk, setTime);
               } catch (TException ex) {
-                log.debug("rpc failed server: {}, {}", server, fmtTid, ex);
+                log.debug("rpc send failed server: {}, {}", server, fmtTid, ex);
               }
             }
           });

Original file line number	Diff line number	Diff line change
`@@ -242,7 +242,7 @@ private void sendQueued(int threshhold) {`
`242`	`242`	`client.send_loadFilesV2(TraceUtil.traceInfo(), manager.getContext().rpcCreds(), tid,`
`243`	`243`	`bulkDir.toString(), chunk, setTime);`
`244`	`244`	`} catch (TException ex) {`
`245`		`- log.debug("rpc failed server: {}, {}", server, fmtTid, ex);`
	`245`	`+ log.debug("rpc send failed server: {}, {}", server, fmtTid, ex);`
`246`	`246`	`}`
`247`	`247`	`}`
`248`	`248`	`});`