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

digraph G { subgraph clusterstage_1444 { label="Stage 1444"; 15173 [labelType="html" label="SQLExecutionRDD [15173] run at <unknown>:0"]; 15181 [labelType="html" label="SQLExecutionRDD [15181] toJavaRDD at <unknown>:0"]; 15183 [labelType="html" label="PythonRDD [15183] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33943 { label="MicroBatchScan"; 15169 [labelType="html" label="DataSourceRDD [15169] run at <unknown>:0"]; 15170 [labelType="html" label="MapPartitionsRDD [15170] run at <unknown>:0"]; } subgraph cluster33942 { label="Project"; 15171 [labelType="html" label="MapPartitionsRDD [15171] run at <unknown>:0"]; } subgraph cluster33938 { label="WholeStageCodegen (1)"; 15172 [labelType="html" label="MapPartitionsRDD [15172] run at <unknown>:0"]; } subgraph cluster33952 { label="WholeStageCodegen (1)"; 15174 [labelType="html" label="MapPartitionsRDD [15174] toJavaRDD at <unknown>:0"]; } subgraph cluster33951 { label="Filter"; 15175 [labelType="html" label="MapPartitionsRDD [15175] toJavaRDD at <unknown>:0"]; } subgraph cluster33950 { label="Project"; 15176 [labelType="html" label="MapPartitionsRDD [15176] toJavaRDD at <unknown>:0"]; } subgraph cluster33947 { label="WholeStageCodegen (2)"; 15177 [labelType="html" label="MapPartitionsRDD [15177] toJavaRDD at <unknown>:0"]; } subgraph cluster33946 { label="Project"; 15178 [labelType="html" label="MapPartitionsRDD [15178] toJavaRDD at <unknown>:0"]; } subgraph cluster33945 { label="DeserializeToObject"; 15179 [labelType="html" label="MapPartitionsRDD [15179] toJavaRDD at <unknown>:0"]; } subgraph cluster33944 { label="MapPartitions"; 15180 [labelType="html" label="MapPartitionsRDD [15180] toJavaRDD at <unknown>:0"]; } subgraph cluster33954 { label="mapPartitions"; 15182 [labelType="html" label="MapPartitionsRDD [15182] toJavaRDD at <unknown>:0"]; } } 15169->15170; 15170->15171; 15171->15172; 15172->15173; 15173->15174; 15174->15175; 15175->15176; 15176->15177; 15177->15178; 15178->15179; 15179->15180; 15180->15181; 15181->15182; 15182->15183; }

Event Timeline

Enable zooming