From b36ce2a2469ff923a3367a530d4a14899ecf9238 Mon Sep 17 00:00:00 2001
From: DjvuLee <lihu@bytedance.com>
Date: Tue, 13 Jun 2017 15:56:03 +0100
Subject: [PATCH] [SPARK-21064][CORE][TEST] Fix the default value bug in
NettyBlockTransferServiceSuite
## What changes were proposed in this pull request?
The default value for `spark.port.maxRetries` is 100,
but we use 10 in the suite file.
So we change it to 100 to avoid test failure.
## How was this patch tested?
No test
Author: DjvuLee <lihu@bytedance.com>
Closes #18280 from djvulee/NettyTestBug.
---
.../spark/network/netty/NettyBlockTransferServiceSuite.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/core/src/test/scala/org/apache/spark/network/netty/NettyBlockTransferServiceSuite.scala b/core/src/test/scala/org/apache/spark/network/netty/NettyBlockTransferServiceSuite.scala
index 271ab8b148..9825930038 100644
--- a/core/src/test/scala/org/apache/spark/network/netty/NettyBlockTransferServiceSuite.scala
+++ b/core/src/test/scala/org/apache/spark/network/netty/NettyBlockTransferServiceSuite.scala
@@ -80,7 +80,8 @@ class NettyBlockTransferServiceSuite
private def verifyServicePort(expectedPort: Int, actualPort: Int): Unit = {
actualPort should be >= expectedPort
// avoid testing equality in case of simultaneous tests
- actualPort should be <= (expectedPort + 10)
+ // the default value for `spark.port.maxRetries` is 100 under test
+ actualPort should be <= (expectedPort + 100)
}
private def createService(port: Int): NettyBlockTransferService = {
--
GitLab