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

digraph G { subgraph clusterstage_2011 { label="Stage 2011"; 21131 [labelType="html" label="SQLExecutionRDD [21131] run at <unknown>:0"]; 21139 [labelType="html" label="SQLExecutionRDD [21139] toJavaRDD at <unknown>:0"]; 21141 [labelType="html" label="PythonRDD [21141] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47283 { label="MicroBatchScan"; 21127 [labelType="html" label="DataSourceRDD [21127] run at <unknown>:0"]; 21128 [labelType="html" label="MapPartitionsRDD [21128] run at <unknown>:0"]; } subgraph cluster47282 { label="Project"; 21129 [labelType="html" label="MapPartitionsRDD [21129] run at <unknown>:0"]; } subgraph cluster47278 { label="WholeStageCodegen (1)"; 21130 [labelType="html" label="MapPartitionsRDD [21130] run at <unknown>:0"]; } subgraph cluster47292 { label="WholeStageCodegen (1)"; 21132 [labelType="html" label="MapPartitionsRDD [21132] toJavaRDD at <unknown>:0"]; } subgraph cluster47291 { label="Filter"; 21133 [labelType="html" label="MapPartitionsRDD [21133] toJavaRDD at <unknown>:0"]; } subgraph cluster47290 { label="Project"; 21134 [labelType="html" label="MapPartitionsRDD [21134] toJavaRDD at <unknown>:0"]; } subgraph cluster47287 { label="WholeStageCodegen (2)"; 21135 [labelType="html" label="MapPartitionsRDD [21135] toJavaRDD at <unknown>:0"]; } subgraph cluster47286 { label="Project"; 21136 [labelType="html" label="MapPartitionsRDD [21136] toJavaRDD at <unknown>:0"]; } subgraph cluster47285 { label="DeserializeToObject"; 21137 [labelType="html" label="MapPartitionsRDD [21137] toJavaRDD at <unknown>:0"]; } subgraph cluster47284 { label="MapPartitions"; 21138 [labelType="html" label="MapPartitionsRDD [21138] toJavaRDD at <unknown>:0"]; } subgraph cluster47294 { label="mapPartitions"; 21140 [labelType="html" label="MapPartitionsRDD [21140] toJavaRDD at <unknown>:0"]; } } 21127->21128; 21128->21129; 21129->21130; 21130->21131; 21131->21132; 21132->21133; 21133->21134; 21134->21135; 21135->21136; 21136->21137; 21137->21138; 21138->21139; 21139->21140; 21140->21141; }

Event Timeline

Enable zooming