Skip to content

Commit 30d6718

Browse files
committed
Fix Javadoc errors.
1 parent b548017 commit 30d6718

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

network/common/src/main/java/org/apache/spark/network/client/TransportClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@
4848
* to perform this setup.
4949
*
5050
* For example, a typical workflow might be:
51-
* client.sendRPC(new OpenFile("/foo")) --> returns StreamId = 100
51+
* client.sendRPC(new OpenFile("/foo")) --> returns StreamId = 100
5252
* client.fetchChunk(streamId = 100, chunkIndex = 0, callback)
5353
* client.fetchChunk(streamId = 100, chunkIndex = 1, callback)
5454
* ...

network/common/src/main/java/org/apache/spark/network/server/OneForOneStreamManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929
import org.apache.spark.network.buffer.ManagedBuffer;
3030

3131
/**
32-
* StreamManager which allows registration of an Iterator<ManagedBuffer>, which are individually
32+
* StreamManager which allows registration of an Iterator&lt;ManagedBuffer&gt;, which are individually
3333
* fetched as chunks by the client. Each registered buffer is one chunk.
3434
*/
3535
public class OneForOneStreamManager extends StreamManager {

network/common/src/main/java/org/apache/spark/network/util/NettyUtils.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ public static ByteToMessageDecoder createFrameDecoder() {
9292
return new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 8, -8, 8);
9393
}
9494

95-
/** Returns the remote address on the channel or "<remote address>" if none exists. */
95+
/** Returns the remote address on the channel or "&lt;remote address&gt;" if none exists. */
9696
public static String getRemoteAddress(Channel channel) {
9797
if (channel != null && channel.remoteAddress() != null) {
9898
return channel.remoteAddress().toString();

0 commit comments

Comments
 (0)