You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by zs...@apache.org on 2017/06/30 03:56:39 UTC
spark git commit: [SPARK-21253][CORE][HOTFIX] Fix Scala 2.10 build
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 <sh...@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 <sh...@databricks.com>
Authored: Thu Jun 29 20:56:37 2017 -0700
Committer: Shixiong Zhu <sh...@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