processing-stream-kafka-raw-to-minio - Details for Stage 1922 (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 / 428
Associated Job Ids: 1922

digraph G { subgraph clusterstage_1922 { label="Stage 1922"; 20185 [labelType="html" label="SQLExecutionRDD [20185] run at <unknown>:0"]; 20193 [labelType="html" label="SQLExecutionRDD [20193] toJavaRDD at <unknown>:0"]; 20195 [labelType="html" label="PythonRDD [20195] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster45172 { label="MicroBatchScan"; 20181 [labelType="html" label="DataSourceRDD [20181] run at <unknown>:0"]; 20182 [labelType="html" label="MapPartitionsRDD [20182] run at <unknown>:0"]; } subgraph cluster45171 { label="Project"; 20183 [labelType="html" label="MapPartitionsRDD [20183] run at <unknown>:0"]; } subgraph cluster45167 { label="WholeStageCodegen (1)"; 20184 [labelType="html" label="MapPartitionsRDD [20184] run at <unknown>:0"]; } subgraph cluster45181 { label="WholeStageCodegen (1)"; 20186 [labelType="html" label="MapPartitionsRDD [20186] toJavaRDD at <unknown>:0"]; } subgraph cluster45180 { label="Filter"; 20187 [labelType="html" label="MapPartitionsRDD [20187] toJavaRDD at <unknown>:0"]; } subgraph cluster45179 { label="Project"; 20188 [labelType="html" label="MapPartitionsRDD [20188] toJavaRDD at <unknown>:0"]; } subgraph cluster45176 { label="WholeStageCodegen (2)"; 20189 [labelType="html" label="MapPartitionsRDD [20189] toJavaRDD at <unknown>:0"]; } subgraph cluster45175 { label="Project"; 20190 [labelType="html" label="MapPartitionsRDD [20190] toJavaRDD at <unknown>:0"]; } subgraph cluster45174 { label="DeserializeToObject"; 20191 [labelType="html" label="MapPartitionsRDD [20191] toJavaRDD at <unknown>:0"]; } subgraph cluster45173 { label="MapPartitions"; 20192 [labelType="html" label="MapPartitionsRDD [20192] toJavaRDD at <unknown>:0"]; } subgraph cluster45183 { label="mapPartitions"; 20194 [labelType="html" label="MapPartitionsRDD [20194] toJavaRDD at <unknown>:0"]; } } 20181->20182; 20182->20183; 20183->20184; 20184->20185; 20185->20186; 20186->20187; 20187->20188; 20188->20189; 20189->20190; 20190->20191; 20191->20192; 20192->20193; 20193->20194; 20194->20195; }

Event Timeline

Enable zooming