We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 17f020f commit 45908b7Copy full SHA for 45908b7
network/common/src/main/java/org/apache/spark/network/server/OneForOneStreamManager.java
@@ -41,7 +41,7 @@ public class OneForOneStreamManager extends StreamManager {
41
private final AtomicLong nextStreamId;
42
private final Map<Long, StreamState> streams;
43
44
- /** List of all stream ids that are associated to specified channel. **/
+ /** List of all stream ids that are associated to specified channel. */
45
private final Map<Channel, Set<Long>> streamIds;
46
47
/** State of a single stream. */
0 commit comments