Skip to content

Commit 4727fd3

Browse files
Update server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2/LoadFiles.java
Co-authored-by: Daniel Roberts <ddanielr@gmail.com>
1 parent 2f65c47 commit 4727fd3

File tree

1 file changed

+2
-3
lines changed
  • server/manager/src/main/java/org/apache/accumulo/manager/tableOps/bulkVer2

1 file changed

+2
-3
lines changed

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

+2-3
Original file line numberDiff line numberDiff line change
@@ -258,9 +258,8 @@ private void sendQueued(int threshhold) {
258258
client.service.recv_loadFilesV2();
259259
} catch (TException ex) {
260260
String additionalInfo = "";
261-
if (ex instanceof TApplicationException) {
262-
if (((TApplicationException) ex).getType()
263-
== TApplicationException.UNKNOWN_METHOD) {
261+
if (ex instanceof TApplicationException && ((TApplicationException) ex).getType()
262+
== TApplicationException.UNKNOWN_METHOD) {
264263
// A new RPC method was added in 2.1.4, a tserver running 2.1.3 or earlier will
265264
// not have this RPC. This should not kill the fate operation, it can wait until
266265
// all tablet servers are upgraded.

0 commit comments

Comments
 (0)