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

digraph G { subgraph clusterstage_1060 { label="Stage 1060"; 11134 [labelType="html" label="SQLExecutionRDD [11134] run at <unknown>:0"]; 11142 [labelType="html" label="SQLExecutionRDD [11142] toJavaRDD at <unknown>:0"]; 11144 [labelType="html" label="PythonRDD [11144] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24915 { label="MicroBatchScan"; 11130 [labelType="html" label="DataSourceRDD [11130] run at <unknown>:0"]; 11131 [labelType="html" label="MapPartitionsRDD [11131] run at <unknown>:0"]; } subgraph cluster24914 { label="Project"; 11132 [labelType="html" label="MapPartitionsRDD [11132] run at <unknown>:0"]; } subgraph cluster24910 { label="WholeStageCodegen (1)"; 11133 [labelType="html" label="MapPartitionsRDD [11133] run at <unknown>:0"]; } subgraph cluster24924 { label="WholeStageCodegen (1)"; 11135 [labelType="html" label="MapPartitionsRDD [11135] toJavaRDD at <unknown>:0"]; } subgraph cluster24923 { label="Filter"; 11136 [labelType="html" label="MapPartitionsRDD [11136] toJavaRDD at <unknown>:0"]; } subgraph cluster24922 { label="Project"; 11137 [labelType="html" label="MapPartitionsRDD [11137] toJavaRDD at <unknown>:0"]; } subgraph cluster24919 { label="WholeStageCodegen (2)"; 11138 [labelType="html" label="MapPartitionsRDD [11138] toJavaRDD at <unknown>:0"]; } subgraph cluster24918 { label="Project"; 11139 [labelType="html" label="MapPartitionsRDD [11139] toJavaRDD at <unknown>:0"]; } subgraph cluster24917 { label="DeserializeToObject"; 11140 [labelType="html" label="MapPartitionsRDD [11140] toJavaRDD at <unknown>:0"]; } subgraph cluster24916 { label="MapPartitions"; 11141 [labelType="html" label="MapPartitionsRDD [11141] toJavaRDD at <unknown>:0"]; } subgraph cluster24926 { label="mapPartitions"; 11143 [labelType="html" label="MapPartitionsRDD [11143] toJavaRDD at <unknown>:0"]; } } 11130->11131; 11131->11132; 11132->11133; 11133->11134; 11134->11135; 11135->11136; 11136->11137; 11137->11138; 11138->11139; 11139->11140; 11140->11141; 11141->11142; 11142->11143; 11143->11144; }

Event Timeline

Enable zooming