Skip to content

Commit ed485f7

Browse files
committed
use the same test codes since 2.4 has the heartbeat interval fix
1 parent 8a6de17 commit ed485f7

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

core/src/test/scala/org/apache/spark/ui/UISeleniumSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ import org.apache.spark._
3939
import org.apache.spark.LocalSparkContext._
4040
import org.apache.spark.api.java.StorageLevels
4141
import org.apache.spark.deploy.history.HistoryServerSuite
42-
import org.apache.spark.internal.config.MEMORY_OFFHEAP_SIZE
42+
import org.apache.spark.internal.config.{EXECUTOR_HEARTBEAT_INTERVAL, MEMORY_OFFHEAP_SIZE}
4343
import org.apache.spark.shuffle.FetchFailedException
4444
import org.apache.spark.status.api.v1.{JacksonMessageWriter, RDDDataDistribution, StageStatus}
4545
import org.apache.spark.status.config._
@@ -733,7 +733,7 @@ class UISeleniumSuite extends SparkFunSuite with WebBrowser with Matchers with B
733733
master = "local[2]",
734734
// Set a small heart beat interval to make the test fast
735735
additionalConfs = Map(
736-
"spark.executor.heartbeatInterval" -> "1s",
736+
EXECUTOR_HEARTBEAT_INTERVAL.key -> "10ms",
737737
LIVE_ENTITY_UPDATE_MIN_FLUSH_PERIOD.key -> "10ms"))) { sc =>
738738
sc.setLocalProperty(SparkContext.SPARK_JOB_INTERRUPT_ON_CANCEL, "true")
739739
val f = sc.parallelize(1 to 1000, 1000).foreachAsync { _ =>

0 commit comments

Comments
 (0)