@@ -535,24 +535,6 @@ private[spark] class AppStatusStore(
535535 store.close()
536536 }
537537
538- def constructTaskData (taskDataWrapper : TaskDataWrapper ) : v1.TaskData = {
539- val taskDataOld : v1.TaskData = taskDataWrapper.toApi
540- val executorLogs : Option [Map [String , String ]] = try {
541- Some (executorSummary(taskDataOld.executorId).executorLogs)
542- } catch {
543- case e : NoSuchElementException => e.getMessage
544- None
545- }
546- new v1.TaskData (taskDataOld.taskId, taskDataOld.index,
547- taskDataOld.attempt, taskDataOld.launchTime, taskDataOld.resultFetchStart,
548- taskDataOld.duration, taskDataOld.executorId, taskDataOld.host, taskDataOld.status,
549- taskDataOld.taskLocality, taskDataOld.speculative, taskDataOld.accumulatorUpdates,
550- taskDataOld.errorMessage, taskDataOld.taskMetrics,
551- executorLogs.getOrElse(Map [String , String ]()),
552- AppStatusUtils .schedulerDelay(taskDataOld),
553- AppStatusUtils .gettingResultTime(taskDataOld))
554- }
555-
556538 def constructTaskDataList (taskDataWrapperIter : Iterable [TaskDataWrapper ]): Seq [v1.TaskData ] = {
557539 val executorIdToLogs = new HashMap [String , Map [String , String ]]()
558540 taskDataWrapperIter.map { taskDataWrapper =>
0 commit comments