Skip to content

Commit 8a18da5

Browse files
committed
fix
1 parent cf991a9 commit 8a18da5

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

common/network-common/src/main/java/org/apache/spark/network/client/StreamCallbackWithID.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,5 +18,5 @@
1818
package org.apache.spark.network.client;
1919

2020
public interface StreamCallbackWithID extends StreamCallback {
21-
public String getID();
21+
String getID();
2222
}

common/network-common/src/main/java/org/apache/spark/network/server/TransportRequestHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -230,8 +230,8 @@ public void onComplete(String streamId) throws IOException {
230230
streamHandler.onComplete(streamId);
231231
callback.onSuccess(ByteBuffer.allocate(0));
232232
} catch (Exception ex) {
233-
IOException ioExc = new IOException("Failure post-processing complete stream; failing " +
234-
"this rpc and leaving channel active");
233+
IOException ioExc = new IOException("Failure post-processing complete stream;" +
234+
" failing this rpc and leaving channel active");
235235
callback.onFailure(ioExc);
236236
streamHandler.onFailure(streamId, ioExc);
237237
}

0 commit comments

Comments
 (0)