[SPARK-21253][CORE][HOTFIX] Fix Scala 2.10 build

zsxwing · zsxwing · commit d16e2620d1fc · 2017-06-29T20:56:44.000-07:00
## 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 <shixiong@databricks.com> Closes apache#18478 from zsxwing/SPARK-21253-2. (cherry picked from commit cfc696f) Signed-off-by: Shixiong Zhu <shixiong@databricks.com>
diff --git a/common/network-common/src/main/java/org/apache/spark/network/client/TransportResponseHandler.java b/common/network-common/src/main/java/org/apache/spark/network/client/TransportResponseHandler.java
@@ -92,7 +92,7 @@ public void removeRpcRequest(long requestId) {
 
   public void addStreamCallback(String streamId, StreamCallback callback) {
     timeOfLastRequestNs.set(System.nanoTime());
-    streamCallbacks.offer(Tuple2.apply(streamId, callback));
+    streamCallbacks.offer(new Tuple2<>(streamId, callback));
   }
 
   @VisibleForTesting

Original file line number	Diff line number	Diff line change
`@@ -92,7 +92,7 @@ public void removeRpcRequest(long requestId) {`
`92`	`92`
`93`	`93`	`public void addStreamCallback(String streamId, StreamCallback callback) {`
`94`	`94`	`timeOfLastRequestNs.set(System.nanoTime());`
`95`		`- streamCallbacks.offer(Tuple2.apply(streamId, callback));`
	`95`	`+ streamCallbacks.offer(new Tuple2<>(streamId, callback));`
`96`	`96`	`}`
`97`	`97`
`98`	`98`	`@VisibleForTesting`