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

digraph G { subgraph clusterstage_2021 { label="Stage 2021"; 21236 [labelType="html" label="SQLExecutionRDD [21236] run at <unknown>:0"]; 21244 [labelType="html" label="SQLExecutionRDD [21244] toJavaRDD at <unknown>:0"]; 21246 [labelType="html" label="PythonRDD [21246] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47518 { label="MicroBatchScan"; 21232 [labelType="html" label="DataSourceRDD [21232] run at <unknown>:0"]; 21233 [labelType="html" label="MapPartitionsRDD [21233] run at <unknown>:0"]; } subgraph cluster47517 { label="Project"; 21234 [labelType="html" label="MapPartitionsRDD [21234] run at <unknown>:0"]; } subgraph cluster47513 { label="WholeStageCodegen (1)"; 21235 [labelType="html" label="MapPartitionsRDD [21235] run at <unknown>:0"]; } subgraph cluster47527 { label="WholeStageCodegen (1)"; 21237 [labelType="html" label="MapPartitionsRDD [21237] toJavaRDD at <unknown>:0"]; } subgraph cluster47526 { label="Filter"; 21238 [labelType="html" label="MapPartitionsRDD [21238] toJavaRDD at <unknown>:0"]; } subgraph cluster47525 { label="Project"; 21239 [labelType="html" label="MapPartitionsRDD [21239] toJavaRDD at <unknown>:0"]; } subgraph cluster47522 { label="WholeStageCodegen (2)"; 21240 [labelType="html" label="MapPartitionsRDD [21240] toJavaRDD at <unknown>:0"]; } subgraph cluster47521 { label="Project"; 21241 [labelType="html" label="MapPartitionsRDD [21241] toJavaRDD at <unknown>:0"]; } subgraph cluster47520 { label="DeserializeToObject"; 21242 [labelType="html" label="MapPartitionsRDD [21242] toJavaRDD at <unknown>:0"]; } subgraph cluster47519 { label="MapPartitions"; 21243 [labelType="html" label="MapPartitionsRDD [21243] toJavaRDD at <unknown>:0"]; } subgraph cluster47529 { label="mapPartitions"; 21245 [labelType="html" label="MapPartitionsRDD [21245] toJavaRDD at <unknown>:0"]; } } 21232->21233; 21233->21234; 21234->21235; 21235->21236; 21236->21237; 21237->21238; 21238->21239; 21239->21240; 21240->21241; 21241->21242; 21242->21243; 21243->21244; 21244->21245; 21245->21246; }

Event Timeline

Enable zooming