| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/metrics/ |
| H A D | MetricsSystemSuite.scala | 74 val executorId = "driver" constant
91 val executorId = "driver" constant
124 val executorId = "1" constant
141 val executorId = "1" constant
174 val executorId = "dummyExecutorId" constant
196 val executorId = "1" constant
215 val executorId = "1" constant
255 val executorId = "dummyExecutorId" constant
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/storage/ |
| H A D | StorageStatusListener.scala | 76 val executorId = blockManagerId.executorId constant
89 val executorId = blockManagerRemoved.blockManagerId.executorId constant
100 val executorId = blockUpdated.blockUpdatedInfo.blockManagerId.executorId constant
|
| H A D | BlockManagerId.scala | 46 def executorId: String = executorId_ method
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/deploy/worker/ui/ |
| H A D | LogPage.scala | 40 val executorId = Option(request.getParameter("executorId")) constant
62 val executorId = Option(request.getParameter("executorId")) constant
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/ |
| H A D | ExecutorAllocationManager.scala | 649 val executorId = taskStart.taskInfo.executorId constant
673 val executorId = taskEnd.taskInfo.executorId constant
701 val executorId = executorAdded.executorId constant
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/scheduler/ |
| H A D | TaskDescription.scala | 31 val executorId: String, constant
|
| H A D | TaskInfo.scala | 40 val executorId: String, constant
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/ |
| H A D | StateStore.scala | 257 val executorId = SparkEnv.get.blockManager.blockManagerId.executorId constant
265 val executorId = SparkEnv.get.blockManager.blockManagerId.executorId constant
|
| H A D | StateStoreCoordinator.scala | 134 val executorId = instances.get(id).map(_.toString) constant
|
| /dports/devel/spark/spark-2.1.1/core/src/test/resources/HistoryServerExpectations/ |
| H A D | stage_task_list_w__offset___length_expectation.json | 6 "executorId" : "driver", string
48 "executorId" : "driver", string
90 "executorId" : "driver", string
132 "executorId" : "driver", string
174 "executorId" : "driver", string
216 "executorId" : "driver", string
258 "executorId" : "driver", string
300 "executorId" : "driver", string
342 "executorId" : "driver", string
384 "executorId" : "driver", string
[all …]
|
| H A D | stage_task_list_expectation.json | 6 "executorId" : "driver", string
48 "executorId" : "driver", string
90 "executorId" : "driver", string
132 "executorId" : "driver", string
174 "executorId" : "driver", string
216 "executorId" : "driver", string
258 "executorId" : "driver", string
300 "executorId" : "driver", string
342 "executorId" : "driver", string
384 "executorId" : "driver", string
[all …]
|
| H A D | stage_task_list_w__sortBy_expectation.json | 6 "executorId" : "driver", string
48 "executorId" : "driver", string
90 "executorId" : "driver", string
132 "executorId" : "driver", string
174 "executorId" : "driver", string
216 "executorId" : "driver", string
258 "executorId" : "driver", string
300 "executorId" : "driver", string
342 "executorId" : "driver", string
384 "executorId" : "driver", string
[all …]
|
| H A D | stage_task_list_w__sortBy_short_names___runtime_expectation.json | 6 "executorId" : "driver", string
48 "executorId" : "driver", string
90 "executorId" : "driver", string
132 "executorId" : "driver", string
174 "executorId" : "driver", string
216 "executorId" : "driver", string
258 "executorId" : "driver", string
300 "executorId" : "driver", string
342 "executorId" : "driver", string
384 "executorId" : "driver", string
[all …]
|
| H A D | stage_task_list_w__sortBy_short_names__runtime_expectation.json | 6 "executorId" : "driver", string
48 "executorId" : "driver", string
90 "executorId" : "driver", string
132 "executorId" : "driver", string
174 "executorId" : "driver", string
216 "executorId" : "driver", string
258 "executorId" : "driver", string
300 "executorId" : "driver", string
342 "executorId" : "driver", string
384 "executorId" : "driver", string
[all …]
|
| H A D | one_stage_json_expectation.json | 33 "executorId" : "<driver>", string
76 "executorId" : "<driver>", string
119 "executorId" : "<driver>", string
162 "executorId" : "<driver>", string
205 "executorId" : "<driver>", string
248 "executorId" : "<driver>", string
291 "executorId" : "<driver>", string
334 "executorId" : "<driver>", string
|
| H A D | stage_task_list_from_multi_attempt_app_json_1__expectation.json | 6 "executorId" : "<driver>", string
53 "executorId" : "<driver>", string
100 "executorId" : "<driver>", string
147 "executorId" : "<driver>", string
194 "executorId" : "<driver>", string
241 "executorId" : "<driver>", string
288 "executorId" : "<driver>", string
335 "executorId" : "<driver>", string
|
| H A D | stage_task_list_from_multi_attempt_app_json_2__expectation.json | 6 "executorId" : "<driver>", string
53 "executorId" : "<driver>", string
100 "executorId" : "<driver>", string
147 "executorId" : "<driver>", string
194 "executorId" : "<driver>", string
241 "executorId" : "<driver>", string
288 "executorId" : "<driver>", string
335 "executorId" : "<driver>", string
|
| H A D | one_stage_attempt_json_expectation.json | 33 "executorId" : "<driver>", string
76 "executorId" : "<driver>", string
119 "executorId" : "<driver>", string
162 "executorId" : "<driver>", string
205 "executorId" : "<driver>", string
248 "executorId" : "<driver>", string
291 "executorId" : "<driver>", string
334 "executorId" : "<driver>", string
|
| H A D | stage_with_accumulable_json_expectation.json | 37 "executorId" : "<driver>", string
85 "executorId" : "<driver>", string
133 "executorId" : "<driver>", string
181 "executorId" : "<driver>", string
229 "executorId" : "<driver>", string
277 "executorId" : "<driver>", string
325 "executorId" : "<driver>", string
373 "executorId" : "<driver>", string
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/ui/exec/ |
| H A D | ExecutorThreadDumpPage.scala | 31 val executorId = Option(request.getParameter("executorId")).map { executorId => constant
|
| /dports/devel/spark/spark-2.1.1/mesos/src/main/scala/org/apache/spark/executor/ |
| H A D | MesosExecutorBackend.scala | 64 val executorId = executorInfo.getExecutorId.getValue constant
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/ui/jobs/ |
| H A D | ExecutorTable.scala | 109 val executorId = blockManagerId.executorId constant
|
| H A D | JobProgressListener.scala | 542 val executorId = blockManagerId.executorId constant
549 val executorId = blockManagerRemoved.blockManagerId.executorId constant
|
| /dports/devel/spark/spark-2.1.1/common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/ |
| H A D | ExternalShuffleIntegrationSuite.java | 242 private void registerExecutor(String executorId, ExecutorShuffleInfo executorInfo) in registerExecutor()
247 executorId, executorInfo); in registerExecutor() local
|
| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/scheduler/ |
| H A D | BlacklistIntegrationSuite.scala | 139 val executorId = (hostIdx * nExecutorsPerHost + subIdx).toString constant
|