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

digraph G { subgraph clusterstage_870 { label="Stage 870"; 9139 [labelType="html" label="SQLExecutionRDD [9139] run at <unknown>:0"]; 9147 [labelType="html" label="SQLExecutionRDD [9147] toJavaRDD at <unknown>:0"]; 9149 [labelType="html" label="PythonRDD [9149] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster20450 { label="MicroBatchScan"; 9135 [labelType="html" label="DataSourceRDD [9135] run at <unknown>:0"]; 9136 [labelType="html" label="MapPartitionsRDD [9136] run at <unknown>:0"]; } subgraph cluster20449 { label="Project"; 9137 [labelType="html" label="MapPartitionsRDD [9137] run at <unknown>:0"]; } subgraph cluster20445 { label="WholeStageCodegen (1)"; 9138 [labelType="html" label="MapPartitionsRDD [9138] run at <unknown>:0"]; } subgraph cluster20459 { label="WholeStageCodegen (1)"; 9140 [labelType="html" label="MapPartitionsRDD [9140] toJavaRDD at <unknown>:0"]; } subgraph cluster20458 { label="Filter"; 9141 [labelType="html" label="MapPartitionsRDD [9141] toJavaRDD at <unknown>:0"]; } subgraph cluster20457 { label="Project"; 9142 [labelType="html" label="MapPartitionsRDD [9142] toJavaRDD at <unknown>:0"]; } subgraph cluster20454 { label="WholeStageCodegen (2)"; 9143 [labelType="html" label="MapPartitionsRDD [9143] toJavaRDD at <unknown>:0"]; } subgraph cluster20453 { label="Project"; 9144 [labelType="html" label="MapPartitionsRDD [9144] toJavaRDD at <unknown>:0"]; } subgraph cluster20452 { label="DeserializeToObject"; 9145 [labelType="html" label="MapPartitionsRDD [9145] toJavaRDD at <unknown>:0"]; } subgraph cluster20451 { label="MapPartitions"; 9146 [labelType="html" label="MapPartitionsRDD [9146] toJavaRDD at <unknown>:0"]; } subgraph cluster20461 { label="mapPartitions"; 9148 [labelType="html" label="MapPartitionsRDD [9148] toJavaRDD at <unknown>:0"]; } } 9135->9136; 9136->9137; 9137->9138; 9138->9139; 9139->9140; 9140->9141; 9141->9142; 9142->9143; 9143->9144; 9144->9145; 9145->9146; 9146->9147; 9147->9148; 9148->9149; }

Event Timeline

Enable zooming