Skip to content

Commit

Permalink
more style
Browse files Browse the repository at this point in the history
  • Loading branch information
squito committed Mar 16, 2015
1 parent 3377e61 commit 00e9cc5
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ object AllRDDResource {
None
}
val partitions = if (includeDetails) {
Some(blocks.map { case(id, block, locations) =>
Some(blocks.map { case (id, block, locations) =>
new RDDPartitionInfo(
blockName = id.name,
storageLevel = block.storageLevel.description,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -66,12 +66,12 @@ object AllStagesResource {
): StageData = {

val taskData = if(includeDetails) {
Some(stageUiData.taskData.map { case(k,v) => k -> convertTaskData(v) } )
Some(stageUiData.taskData.map { case (k, v) => k -> convertTaskData(v) } )
} else {
None
}
val executorSummary = if(includeDetails) {
Some(stageUiData.executorSummary.map { case(k,summary) =>
Some(stageUiData.executorSummary.map { case (k, summary) =>
k -> new ExecutorStageSummary(
taskTime = summary.taskTime,
failedTasks = summary.failedTasks,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ class OneStageResource(uiRoot: UIRoot) {
matched.map { status -> _ }
}.headOption
oneStage match {
case Some((status,stageInfo)) =>
case Some((status, stageInfo)) =>
val stageUiData = listener.synchronized {
listener.stageIdToData.get((stageInfo.stageId, stageInfo.attemptId)).
getOrElse(throw new SparkException("failed to get full stage data for stage: " +
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -82,8 +82,8 @@ class HistoryServerSuite extends FunSuite with BeforeAndAfter with Matchers with

//run a bunch of characterization tests -- just verify the behavior is the same as what is saved in the test
// resource folder
cases.foreach{case(name, path) =>
test(name){
cases.foreach { case (name, path) =>
test(name) {
val (code, jsonOpt, errOpt) = getContentAndCode(path)
code should be (HttpServletResponse.SC_OK)
jsonOpt should be ('defined)
Expand Down

0 comments on commit 00e9cc5

Please sign in to comment.