PlusAMP App Middleware - Details for Job 330629

Status: SUCCEEDED
Submitted: 2025/08/01 18:52:46
Duration: 3 s
Completed Stages: 2
Skipped Stages: 1

Enable zooming

digraph G { subgraph clusterstage_511803 { label="Stage 511803 (skipped)"; subgraph cluster6277967 { label="Scan csv "; 3610297 [labelType="html" label="FileScanRDD [3610297] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3610298 [labelType="html" label="MapPartitionsRDD [3610298] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6277964 { label="WholeStageCodegen (1)"; 3610299 [labelType="html" label="MapPartitionsRDD [3610299] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6277963 { label="InMemoryTableScan"; 3610300 [labelType="html" label="MapPartitionsRDD [3610300] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3610301 [labelType="html" label="*(1) Project [CASE WHEN (date#94005174 = null) THEN null ELSE cast(date#94005174 as date) END AS date#94005335, CASE WHEN ((allret#94005175 = NA) OR (allret#94005175 = null)) THEN null ELSE cast(allret#94005175 as float) END AS allret#94005336, CASE WHEN ((allcum#94005176 = NA) OR (allcum#94005176 = null)) THEN null ELSE cast(allcum#94005176 as float) END AS allcum#94005360, CASE WHEN ((drawdown_gross#94005177 = NA) OR (drawdown_gross#94005177 = null)) THEN null ELSE cast(drawdown_gross#94005177 as float) END AS drawdown_gross#94005361, CASE WHEN ((drawdown_length_gross#94005178 = NA) OR (drawdown_length_gross#94005178 = null)) THEN null ELSE cast(drawdown_length_gross#94005178 as int) END AS drawdown_length_gross#94005385, CASE WHEN ((allretnet#94005179 = NA) OR (allretnet#94005179 = null)) THEN null ELSE cast(allretnet#94005179 as float) END AS allretnet#94005389, CASE WHEN ((allcumnet#94005180 = NA) OR (allcumnet#94005180 = null)) THEN null ELSE cast(allcumnet#94005180 as float) END AS allcumnet#9400539... [3610301] [Cached] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6278040 { label="InMemoryTableScan"; 3610344 [labelType="html" label="MapPartitionsRDD [3610344] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3610345 [labelType="html" label="MapPartitionsRDD [3610345] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3610346 [labelType="html" label="MapPartitionsRDD [3610346] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6278039 { label="Exchange"; 3610350 [labelType="html" label="MapPartitionsRDD [3610350] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3610297->3610298; 3610298->3610299; 3610299->3610300; 3610300->3610301; 3610301->3610344; 3610344->3610345; 3610345->3610346; 3610346->3610350; }

3610301

digraph G { subgraph clusterstage_511804 { label="Stage 511804"; subgraph cluster6278039 { label="Exchange"; 3610351 [labelType="html" label="ShuffledRowRDD [3610351] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6278036 { label="WholeStageCodegen (1)"; 3610352 [labelType="html" label="MapPartitionsRDD [3610352] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6278035 { label="InMemoryTableScan"; 3610353 [labelType="html" label="MapPartitionsRDD [3610353] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3610354 [labelType="html" label="*(1) Sort [date#94006072 ASC NULLS FIRST], true, 0\n+- Exchange rangepartitioning(date#94006072 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7505747]\n +- InMemoryTableScan [date#94006072, drawdown_gross#94006078, drawdown_net#94006085]\n +- InMemoryRelation [date#94006072, allret#94006074, allcum#94006076, drawdown_gross#94006078, drawdown_length_gross#94006080, allretnet#94006081, allcumnet#94006083, drawdown_net#94006085, drawdown_length_net#94006087, numcos#94006089, largecum#94006091, largecumnet#94006093, largeret#94006095, largeretnet#94006096, midcum#94006098, midcumnet#94006101, midret#94006104, midretnet#94006107, smallcum#94006109, smallcumnet#94006111, smallret#94006114, smallretnet#94006116], StorageLevel(disk, memory, deserialized, 1 replicas)\n +- *(1) Project [CASE WHEN (date#94005174 = null) THEN null ELSE cast(date#94005174 as date) END AS date#94005335, CASE WHEN ((allret#94005175 = NA) OR (allret#94005175 = null)) THEN null ELSE cast(allret#94005175 as float) END... [3610354] [Cached] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6287263 { label="InMemoryTableScan"; 3615633 [labelType="html" label="MapPartitionsRDD [3615633] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3615634 [labelType="html" label="MapPartitionsRDD [3615634] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3615635 [labelType="html" label="MapPartitionsRDD [3615635] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6287262 { label="CollectLimit"; 3615636 [labelType="html" label="MapPartitionsRDD [3615636] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3615637 [labelType="html" label="MapPartitionsRDD [3615637] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3610351->3610352; 3610352->3610353; 3610353->3610354; 3610354->3615633; 3615633->3615634; 3615634->3615635; 3615635->3615636; 3615636->3615637; }

3610350,3610351

3610354

digraph G { subgraph clusterstage_511805 { label="Stage 511805"; subgraph cluster6287262 { label="CollectLimit"; 3615638 [labelType="html" label="ShuffledRowRDD [3615638] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; 3615639 [labelType="html" label="MapPartitionsRDD [3615639] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6287264 { label="mapPartitionsInternal"; 3615640 [labelType="html" label="MapPartitionsRDD [3615640] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } subgraph cluster6287265 { label="map"; 3615649 [labelType="html" label="MapPartitionsRDD [3615649] [Unordered] toLocalIterator at SparkDataStreamBuilder.scala:39"]; } } 3615638->3615639; 3615639->3615640; 3615640->3615649; }

3615637,3615638

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
511805	default	toStream at SparkDataStreamBuilder.scala:39 +details scala.collection.AbstractIterator.toStream(Iterator.scala:1431) plusamp.middleware.model.core.data.SparkDataStreamBuilder.$anonfun$stream$1(SparkDataStreamBuilder.scala:39) plusamp.scala.util.Profile$.time(Profile.scala:22) plusamp.middleware.model.core.data.SparkDataStreamBuilder.<init>(SparkDataStreamBuilder.scala:39) plusamp.middleware.graphql.datafile.SparkAccessor.$anonfun$retrieveData$3(SparkAccessor.scala:77) scala.util.Success.$anonfun$map$1(Try.scala:255) scala.util.Success.map(Try.scala:213) scala.concurrent.Future.$anonfun$map$1(Future.scala:292) scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33) scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33) scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base/java.lang.Thread.run(Thread.java:829)	2025/08/01 18:52:49	68 ms	1/1			42.6 KiB
511804	default	toLocalIterator at SparkDataStreamBuilder.scala:39 +details RDD: (1) Sort [date#94006072 ASC NULLS FIRST], true, 0 +- Exchange rangepartitioning(date#94006072 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7505747] +- InMemoryTableScan [date#94006072, drawdown_gross#94006078, drawdown_net#94006085] +- InMemoryRelation [date#94006072, allret#94006074, allcum#94006076, drawdown_gross#94006078, drawdown_length_gross#94006080, allretnet#94006081, allcumnet#94006083, drawdown_net#94006085, drawdown_length_net#94006087, numcos#94006089, largecum#94006091, largecumnet#94006093, largeret#94006095, largeretnet#94006096, midcum#94006098, midcumnet#94006101, midret#94006104, midretnet#94006107, smallcum#94006109, smallcumnet#94006111, smallret#94006114, smallretnet#94006116], StorageLevel(disk, memory, deserialized, 1 replicas) +- (1) Project [CASE WHEN (date#94005174 = null) THEN null ELSE cast(date#94005174 as date) END AS date#94005335, CASE WHEN ((allret#94005175 = NA) OR (allret#94005175 = null)) THEN null ELSE cast(allret#94005175 as float) END... org.apache.spark.sql.Dataset.toLocalIterator(Dataset.scala:3000) plusamp.middleware.model.core.data.SparkDataStreamBuilder.$anonfun$stream$1(SparkDataStreamBuilder.scala:39) plusamp.scala.util.Profile$.time(Profile.scala:22) plusamp.middleware.model.core.data.SparkDataStreamBuilder.<init>(SparkDataStreamBuilder.scala:39) plusamp.middleware.graphql.datafile.SparkAccessor.$anonfun$retrieveData$3(SparkAccessor.scala:77) scala.util.Success.$anonfun$map$1(Try.scala:255) scala.util.Success.map(Try.scala:213) scala.concurrent.Future.$anonfun$map$1(Future.scala:292) scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33) scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33) scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base/java.lang.Thread.run(Thread.java:829)	2025/08/01 18:52:46	0.5 s	200/200	96.9 KiB			42.6 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

511805

default

toStream at SparkDataStreamBuilder.scala:39 +details

scala.collection.AbstractIterator.toStream(Iterator.scala:1431)
plusamp.middleware.model.core.data.SparkDataStreamBuilder.$anonfun$stream$1(SparkDataStreamBuilder.scala:39)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.model.core.data.SparkDataStreamBuilder.<init>(SparkDataStreamBuilder.scala:39)
plusamp.middleware.graphql.datafile.SparkAccessor.$anonfun$retrieveData$3(SparkAccessor.scala:77)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
java.base/java.lang.Thread.run(Thread.java:829)

2025/08/01 18:52:49

68 ms

1/1

42.6 KiB

511804

default

toLocalIterator at SparkDataStreamBuilder.scala:39 +details

RDD: *(1) Sort [date#94006072 ASC NULLS FIRST], true, 0 +- Exchange rangepartitioning(date#94006072 ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [id=#7505747] +- InMemoryTableScan [date#94006072, drawdown_gross#94006078, drawdown_net#94006085] +- InMemoryRelation [date#94006072, allret#94006074, allcum#94006076, drawdown_gross#94006078, drawdown_length_gross#94006080, allretnet#94006081, allcumnet#94006083, drawdown_net#94006085, drawdown_length_net#94006087, numcos#94006089, largecum#94006091, largecumnet#94006093, largeret#94006095, largeretnet#94006096, midcum#94006098, midcumnet#94006101, midret#94006104, midretnet#94006107, smallcum#94006109, smallcumnet#94006111, smallret#94006114, smallretnet#94006116], StorageLevel(disk, memory, deserialized, 1 replicas) +- *(1) Project [CASE WHEN (date#94005174 = null) THEN null ELSE cast(date#94005174 as date) END AS date#94005335, CASE WHEN ((allret#94005175 = NA) OR (allret#94005175 = null)) THEN null ELSE cast(allret#94005175 as float) END...

org.apache.spark.sql.Dataset.toLocalIterator(Dataset.scala:3000)
plusamp.middleware.model.core.data.SparkDataStreamBuilder.$anonfun$stream$1(SparkDataStreamBuilder.scala:39)
plusamp.scala.util.Profile$.time(Profile.scala:22)
plusamp.middleware.model.core.data.SparkDataStreamBuilder.<init>(SparkDataStreamBuilder.scala:39)
plusamp.middleware.graphql.datafile.SparkAccessor.$anonfun$retrieveData$3(SparkAccessor.scala:77)
scala.util.Success.$anonfun$map$1(Try.scala:255)
scala.util.Success.map(Try.scala:213)
scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
java.base/java.lang.Thread.run(Thread.java:829)

2025/08/01 18:52:46

0.5 s

200/200

96.9 KiB

42.6 KiB

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
511803	default	toLocalIterator at SparkDataStreamBuilder.scala:39 +details RDD: *(1) Project [CASE WHEN (date#94005174 = null) THEN null ELSE cast(date#94005174 as date) END AS date#94005335, CASE WHEN ((allret#94005175 = NA) OR (allret#94005175 = null)) THEN null ELSE cast(allret#94005175 as float) END AS allret#94005336, CASE WHEN ((allcum#94005176 = NA) OR (allcum#94005176 = null)) THEN null ELSE cast(allcum#94005176 as float) END AS allcum#94005360, CASE WHEN ((drawdown_gross#94005177 = NA) OR (drawdown_gross#94005177 = null)) THEN null ELSE cast(drawdown_gross#94005177 as float) END AS drawdown_gross#94005361, CASE WHEN ((drawdown_length_gross#94005178 = NA) OR (drawdown_length_gross#94005178 = null)) THEN null ELSE cast(drawdown_length_gross#94005178 as int) END AS drawdown_length_gross#94005385, CASE WHEN ((allretnet#94005179 = NA) OR (allretnet#94005179 = null)) THEN null ELSE cast(allretnet#94005179 as float) END AS allretnet#94005389, CASE WHEN ((allcumnet#94005180 = NA) OR (allcumnet#94005180 = null)) THEN null ELSE cast(allcumnet#94005180 as float) END AS allcumnet#9400539... org.apache.spark.sql.Dataset.toLocalIterator(Dataset.scala:3000) plusamp.middleware.model.core.data.SparkDataStreamBuilder.$anonfun$stream$1(SparkDataStreamBuilder.scala:39) plusamp.scala.util.Profile$.time(Profile.scala:22) plusamp.middleware.model.core.data.SparkDataStreamBuilder.<init>(SparkDataStreamBuilder.scala:39) plusamp.middleware.graphql.datafile.SparkAccessor.$anonfun$retrieveData$3(SparkAccessor.scala:77) scala.util.Success.$anonfun$map$1(Try.scala:255) scala.util.Success.map(Try.scala:213) scala.concurrent.Future.$anonfun$map$1(Future.scala:292) scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33) scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33) scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) java.base/java.lang.Thread.run(Thread.java:829)	Unknown	Unknown	0/1

Page: