Skip to content

Commit 84cdc68

Browse files
committed
add TODOs
1 parent 6bdc5fe commit 84cdc68

2 files changed

Lines changed: 2 additions & 0 deletions

File tree

core/src/main/scala/org/apache/spark/barrier/BarrierTaskContext.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@ class BarrierTaskContext(
3737
@transient private val metricsSystem: MetricsSystem,
3838
// The default value is only used in tests.
3939
override val taskMetrics: TaskMetrics = TaskMetrics.empty)
40+
// TODO make this extends TaskContext
4041
extends TaskContextImpl(stageId, stageAttemptNumber, partitionId, taskAttemptId, attemptNumber,
4142
taskMemoryManager, localProperties, metricsSystem, taskMetrics)
4243
with Logging {

core/src/main/scala/org/apache/spark/deploy/Client.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -226,6 +226,7 @@ private[spark] class ClientApp extends SparkApplication {
226226
override def start(args: Array[String], conf: SparkConf): Unit = {
227227
val driverArgs = new ClientArguments(args)
228228

229+
// TODO remove this hack
229230
if (!conf.contains("spark.rpc.askTimeout")) {
230231
conf.set("spark.rpc.askTimeout", "900s")
231232
}

0 commit comments

Comments
 (0)