Skip to content

Commit 874dad7

Browse files
committed
Updated to return Message.EMPTY
1 parent 90c5052 commit 874dad7

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/invoker/DeletedBlockLogStateManagerInvoker.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ public Message invokeLocal(String methodName, Object[] p) throws Exception {
116116
final ArrayList arg0 = p.length > 0 ? (ArrayList) p[0] : null;
117117
final DeletedBlocksTransactionSummary arg1 = p.length > 1 ? (DeletedBlocksTransactionSummary) p[1] : null;
118118
getImpl().addTransactionsToDB(arg0, arg1);
119-
return null;
119+
return Message.EMPTY;
120120

121121
case "getReadOnlyIterator":
122122
returnType = Table.KeyValueIterator.class;
@@ -125,19 +125,19 @@ public Message invokeLocal(String methodName, Object[] p) throws Exception {
125125

126126
case "onFlush":
127127
getImpl().onFlush();
128-
return null;
128+
return Message.EMPTY;
129129

130130
case "reinitialize":
131131
final Table arg2 = p.length > 0 ? (Table) p[0] : null;
132132
final Table arg3 = p.length > 1 ? (Table) p[1] : null;
133133
getImpl().reinitialize(arg2, arg3);
134-
return null;
134+
return Message.EMPTY;
135135

136136
case "removeTransactionsFromDB":
137137
final ArrayList arg4 = p.length > 0 ? (ArrayList) p[0] : null;
138138
final DeletedBlocksTransactionSummary arg5 = p.length > 1 ? (DeletedBlocksTransactionSummary) p[1] : null;
139139
getImpl().removeTransactionsFromDB(arg4, arg5);
140-
return null;
140+
return Message.EMPTY;
141141

142142
default:
143143
throw new IllegalArgumentException("Method not found: " + methodName + " in DeletedBlockLogStateManager");

0 commit comments

Comments
 (0)