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

digraph G { subgraph clusterstage_992 { label="Stage 992"; 10420 [labelType="html" label="SQLExecutionRDD [10420] run at <unknown>:0"]; 10428 [labelType="html" label="SQLExecutionRDD [10428] toJavaRDD at <unknown>:0"]; 10430 [labelType="html" label="PythonRDD [10430] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23317 { label="MicroBatchScan"; 10416 [labelType="html" label="DataSourceRDD [10416] run at <unknown>:0"]; 10417 [labelType="html" label="MapPartitionsRDD [10417] run at <unknown>:0"]; } subgraph cluster23316 { label="Project"; 10418 [labelType="html" label="MapPartitionsRDD [10418] run at <unknown>:0"]; } subgraph cluster23312 { label="WholeStageCodegen (1)"; 10419 [labelType="html" label="MapPartitionsRDD [10419] run at <unknown>:0"]; } subgraph cluster23326 { label="WholeStageCodegen (1)"; 10421 [labelType="html" label="MapPartitionsRDD [10421] toJavaRDD at <unknown>:0"]; } subgraph cluster23325 { label="Filter"; 10422 [labelType="html" label="MapPartitionsRDD [10422] toJavaRDD at <unknown>:0"]; } subgraph cluster23324 { label="Project"; 10423 [labelType="html" label="MapPartitionsRDD [10423] toJavaRDD at <unknown>:0"]; } subgraph cluster23321 { label="WholeStageCodegen (2)"; 10424 [labelType="html" label="MapPartitionsRDD [10424] toJavaRDD at <unknown>:0"]; } subgraph cluster23320 { label="Project"; 10425 [labelType="html" label="MapPartitionsRDD [10425] toJavaRDD at <unknown>:0"]; } subgraph cluster23319 { label="DeserializeToObject"; 10426 [labelType="html" label="MapPartitionsRDD [10426] toJavaRDD at <unknown>:0"]; } subgraph cluster23318 { label="MapPartitions"; 10427 [labelType="html" label="MapPartitionsRDD [10427] toJavaRDD at <unknown>:0"]; } subgraph cluster23328 { label="mapPartitions"; 10429 [labelType="html" label="MapPartitionsRDD [10429] toJavaRDD at <unknown>:0"]; } } 10416->10417; 10417->10418; 10418->10419; 10419->10420; 10420->10421; 10421->10422; 10422->10423; 10423->10424; 10424->10425; 10425->10426; 10426->10427; 10427->10428; 10428->10429; 10429->10430; }

Event Timeline

Enable zooming