Skip to content

Commit cfc696f

Browse files
committed
[SPARK-21253][CORE][HOTFIX] Fix Scala 2.10 build
## What changes were proposed in this pull request? A follow up PR to fix Scala 2.10 build for apache#18472 ## How was this patch tested? Jenkins Author: Shixiong Zhu <[email protected]> Closes apache#18478 from zsxwing/SPARK-21253-2.
1 parent 88a536b commit cfc696f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ public void removeRpcRequest(long requestId) {
9292

9393
public void addStreamCallback(String streamId, StreamCallback callback) {
9494
timeOfLastRequestNs.set(System.nanoTime());
95-
streamCallbacks.offer(Tuple2.apply(streamId, callback));
95+
streamCallbacks.offer(new Tuple2<>(streamId, callback));
9696
}
9797

9898
@VisibleForTesting

0 commit comments

Comments
 (0)