processing-stream-kafka-raw-to-minio - Details for Stage 108 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 3
Input Size / Records: 0.0 B / 563
Associated Job Ids: 108

digraph G { subgraph clusterstage_108 { label="Stage 108"; 1138 [labelType="html" label="SQLExecutionRDD [1138] run at <unknown>:0"]; 1146 [labelType="html" label="SQLExecutionRDD [1146] toJavaRDD at <unknown>:0"]; 1148 [labelType="html" label="PythonRDD [1148] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2543 { label="MicroBatchScan"; 1134 [labelType="html" label="DataSourceRDD [1134] run at <unknown>:0"]; 1135 [labelType="html" label="MapPartitionsRDD [1135] run at <unknown>:0"]; } subgraph cluster2542 { label="Project"; 1136 [labelType="html" label="MapPartitionsRDD [1136] run at <unknown>:0"]; } subgraph cluster2538 { label="WholeStageCodegen (1)"; 1137 [labelType="html" label="MapPartitionsRDD [1137] run at <unknown>:0"]; } subgraph cluster2552 { label="WholeStageCodegen (1)"; 1139 [labelType="html" label="MapPartitionsRDD [1139] toJavaRDD at <unknown>:0"]; } subgraph cluster2551 { label="Filter"; 1140 [labelType="html" label="MapPartitionsRDD [1140] toJavaRDD at <unknown>:0"]; } subgraph cluster2550 { label="Project"; 1141 [labelType="html" label="MapPartitionsRDD [1141] toJavaRDD at <unknown>:0"]; } subgraph cluster2547 { label="WholeStageCodegen (2)"; 1142 [labelType="html" label="MapPartitionsRDD [1142] toJavaRDD at <unknown>:0"]; } subgraph cluster2546 { label="Project"; 1143 [labelType="html" label="MapPartitionsRDD [1143] toJavaRDD at <unknown>:0"]; } subgraph cluster2545 { label="DeserializeToObject"; 1144 [labelType="html" label="MapPartitionsRDD [1144] toJavaRDD at <unknown>:0"]; } subgraph cluster2544 { label="MapPartitions"; 1145 [labelType="html" label="MapPartitionsRDD [1145] toJavaRDD at <unknown>:0"]; } subgraph cluster2554 { label="mapPartitions"; 1147 [labelType="html" label="MapPartitionsRDD [1147] toJavaRDD at <unknown>:0"]; } } 1134->1135; 1135->1136; 1136->1137; 1137->1138; 1138->1139; 1139->1140; 1140->1141; 1141->1142; 1142->1143; 1143->1144; 1144->1145; 1145->1146; 1146->1147; 1147->1148; }

Event Timeline

Enable zooming