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

digraph G { subgraph clusterstage_874 { label="Stage 874"; 9181 [labelType="html" label="SQLExecutionRDD [9181] run at <unknown>:0"]; 9189 [labelType="html" label="SQLExecutionRDD [9189] toJavaRDD at <unknown>:0"]; 9191 [labelType="html" label="PythonRDD [9191] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster20544 { label="MicroBatchScan"; 9177 [labelType="html" label="DataSourceRDD [9177] run at <unknown>:0"]; 9178 [labelType="html" label="MapPartitionsRDD [9178] run at <unknown>:0"]; } subgraph cluster20543 { label="Project"; 9179 [labelType="html" label="MapPartitionsRDD [9179] run at <unknown>:0"]; } subgraph cluster20539 { label="WholeStageCodegen (1)"; 9180 [labelType="html" label="MapPartitionsRDD [9180] run at <unknown>:0"]; } subgraph cluster20553 { label="WholeStageCodegen (1)"; 9182 [labelType="html" label="MapPartitionsRDD [9182] toJavaRDD at <unknown>:0"]; } subgraph cluster20552 { label="Filter"; 9183 [labelType="html" label="MapPartitionsRDD [9183] toJavaRDD at <unknown>:0"]; } subgraph cluster20551 { label="Project"; 9184 [labelType="html" label="MapPartitionsRDD [9184] toJavaRDD at <unknown>:0"]; } subgraph cluster20548 { label="WholeStageCodegen (2)"; 9185 [labelType="html" label="MapPartitionsRDD [9185] toJavaRDD at <unknown>:0"]; } subgraph cluster20547 { label="Project"; 9186 [labelType="html" label="MapPartitionsRDD [9186] toJavaRDD at <unknown>:0"]; } subgraph cluster20546 { label="DeserializeToObject"; 9187 [labelType="html" label="MapPartitionsRDD [9187] toJavaRDD at <unknown>:0"]; } subgraph cluster20545 { label="MapPartitions"; 9188 [labelType="html" label="MapPartitionsRDD [9188] toJavaRDD at <unknown>:0"]; } subgraph cluster20555 { label="mapPartitions"; 9190 [labelType="html" label="MapPartitionsRDD [9190] toJavaRDD at <unknown>:0"]; } } 9177->9178; 9178->9179; 9179->9180; 9180->9181; 9181->9182; 9182->9183; 9183->9184; 9184->9185; 9185->9186; 9186->9187; 9187->9188; 9188->9189; 9189->9190; 9190->9191; }

Event Timeline

Enable zooming