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

digraph G { subgraph clusterstage_966 { label="Stage 966"; 10150 [labelType="html" label="SQLExecutionRDD [10150] run at <unknown>:0"]; 10162 [labelType="html" label="SQLExecutionRDD [10162] toJavaRDD at <unknown>:0"]; 10164 [labelType="html" label="PythonRDD [10164] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22710 { label="MicroBatchScan"; 10145 [labelType="html" label="DataSourceRDD [10145] run at <unknown>:0"]; 10147 [labelType="html" label="MapPartitionsRDD [10147] run at <unknown>:0"]; } subgraph cluster22709 { label="Project"; 10148 [labelType="html" label="MapPartitionsRDD [10148] run at <unknown>:0"]; } subgraph cluster22703 { label="WholeStageCodegen (1)"; 10149 [labelType="html" label="MapPartitionsRDD [10149] run at <unknown>:0"]; } subgraph cluster22719 { label="WholeStageCodegen (1)"; 10155 [labelType="html" label="MapPartitionsRDD [10155] toJavaRDD at <unknown>:0"]; } subgraph cluster22718 { label="Filter"; 10156 [labelType="html" label="MapPartitionsRDD [10156] toJavaRDD at <unknown>:0"]; } subgraph cluster22717 { label="Project"; 10157 [labelType="html" label="MapPartitionsRDD [10157] toJavaRDD at <unknown>:0"]; } subgraph cluster22714 { label="WholeStageCodegen (2)"; 10158 [labelType="html" label="MapPartitionsRDD [10158] toJavaRDD at <unknown>:0"]; } subgraph cluster22713 { label="Project"; 10159 [labelType="html" label="MapPartitionsRDD [10159] toJavaRDD at <unknown>:0"]; } subgraph cluster22712 { label="DeserializeToObject"; 10160 [labelType="html" label="MapPartitionsRDD [10160] toJavaRDD at <unknown>:0"]; } subgraph cluster22711 { label="MapPartitions"; 10161 [labelType="html" label="MapPartitionsRDD [10161] toJavaRDD at <unknown>:0"]; } subgraph cluster22721 { label="mapPartitions"; 10163 [labelType="html" label="MapPartitionsRDD [10163] toJavaRDD at <unknown>:0"]; } } 10145->10147; 10147->10148; 10148->10149; 10149->10150; 10150->10155; 10155->10156; 10156->10157; 10157->10158; 10158->10159; 10159->10160; 10160->10161; 10161->10162; 10162->10163; 10163->10164; }

Event Timeline

Enable zooming