spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zsxw...@apache.org
Subject spark git commit: [SPARK-21253][CORE][HOTFIX] Fix Scala 2.10 build
Date Fri, 30 Jun 2017 03:56:39 GMT
Repository: spark
Updated Branches:
  refs/heads/master 88a536bab -> cfc696f4a


[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 #18472

## How was this patch tested?

Jenkins

Author: Shixiong Zhu <shixiong@databricks.com>

Closes #18478 from zsxwing/SPARK-21253-2.


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/cfc696f4
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/cfc696f4
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/cfc696f4

Branch: refs/heads/master
Commit: cfc696f4a4289acf132cb26baf7c02c5b6305277
Parents: 88a536b
Author: Shixiong Zhu <shixiong@databricks.com>
Authored: Thu Jun 29 20:56:37 2017 -0700
Committer: Shixiong Zhu <shixiong@databricks.com>
Committed: Thu Jun 29 20:56:37 2017 -0700

----------------------------------------------------------------------
 .../org/apache/spark/network/client/TransportResponseHandler.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/cfc696f4/common/network-common/src/main/java/org/apache/spark/network/client/TransportResponseHandler.java
----------------------------------------------------------------------
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
index be9f182..340b8b9 100644
--- 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 class TransportResponseHandler extends MessageHandler<ResponseMessage>
{
 
   public void addStreamCallback(String streamId, StreamCallback callback) {
     timeOfLastRequestNs.set(System.nanoTime());
-    streamCallbacks.offer(Tuple2.apply(streamId, callback));
+    streamCallbacks.offer(new Tuple2<>(streamId, callback));
   }
 
   @VisibleForTesting


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org


Mime
View raw message