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

digraph G { subgraph clusterstage_2013 { label="Stage 2013"; 21152 [labelType="html" label="SQLExecutionRDD [21152] run at <unknown>:0"]; 21160 [labelType="html" label="SQLExecutionRDD [21160] toJavaRDD at <unknown>:0"]; 21162 [labelType="html" label="PythonRDD [21162] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47330 { label="MicroBatchScan"; 21148 [labelType="html" label="DataSourceRDD [21148] run at <unknown>:0"]; 21149 [labelType="html" label="MapPartitionsRDD [21149] run at <unknown>:0"]; } subgraph cluster47329 { label="Project"; 21150 [labelType="html" label="MapPartitionsRDD [21150] run at <unknown>:0"]; } subgraph cluster47325 { label="WholeStageCodegen (1)"; 21151 [labelType="html" label="MapPartitionsRDD [21151] run at <unknown>:0"]; } subgraph cluster47339 { label="WholeStageCodegen (1)"; 21153 [labelType="html" label="MapPartitionsRDD [21153] toJavaRDD at <unknown>:0"]; } subgraph cluster47338 { label="Filter"; 21154 [labelType="html" label="MapPartitionsRDD [21154] toJavaRDD at <unknown>:0"]; } subgraph cluster47337 { label="Project"; 21155 [labelType="html" label="MapPartitionsRDD [21155] toJavaRDD at <unknown>:0"]; } subgraph cluster47334 { label="WholeStageCodegen (2)"; 21156 [labelType="html" label="MapPartitionsRDD [21156] toJavaRDD at <unknown>:0"]; } subgraph cluster47333 { label="Project"; 21157 [labelType="html" label="MapPartitionsRDD [21157] toJavaRDD at <unknown>:0"]; } subgraph cluster47332 { label="DeserializeToObject"; 21158 [labelType="html" label="MapPartitionsRDD [21158] toJavaRDD at <unknown>:0"]; } subgraph cluster47331 { label="MapPartitions"; 21159 [labelType="html" label="MapPartitionsRDD [21159] toJavaRDD at <unknown>:0"]; } subgraph cluster47341 { label="mapPartitions"; 21161 [labelType="html" label="MapPartitionsRDD [21161] toJavaRDD at <unknown>:0"]; } } 21148->21149; 21149->21150; 21150->21151; 21151->21152; 21152->21153; 21153->21154; 21154->21155; 21155->21156; 21156->21157; 21157->21158; 21158->21159; 21159->21160; 21160->21161; 21161->21162; }

Event Timeline

Enable zooming