remove experimental change that did not make a diff

keith-turner · keith-turner · commit f01694584d87 · 2025-03-01T22:42:52.000Z
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
@@ -207,7 +207,6 @@ private void sendQueued(int threshhold) {
 
               client.loadFiles(TraceUtil.traceInfo(), manager.getContext().rpcCreds(), tid,
                   bulkDir.toString(), Map.of(tExtent, files), setTime);
-              client.getOutputProtocol().getTransport().flush();
             }
           } catch (TException ex) {
             log.debug("rpc failed server: " + server + ", " + fmtTid + " " + ex.getMessage(), ex);

Original file line number	Diff line number	Diff line change
`@@ -207,7 +207,6 @@ private void sendQueued(int threshhold) {`
`207`	`207`
`208`	`208`	`client.loadFiles(TraceUtil.traceInfo(), manager.getContext().rpcCreds(), tid,`
`209`	`209`	`bulkDir.toString(), Map.of(tExtent, files), setTime);`
`210`		`- client.getOutputProtocol().getTransport().flush();`
`211`	`210`	`}`
`212`	`211`	`} catch (TException ex) {`
`213`	`212`	`log.debug("rpc failed server: " + server + ", " + fmtTid + " " + ex.getMessage(), ex);`