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

digraph G { subgraph clusterstage_1500 { label="Stage 1500"; 15754 [labelType="html" label="SQLExecutionRDD [15754] run at <unknown>:0"]; 15762 [labelType="html" label="SQLExecutionRDD [15762] toJavaRDD at <unknown>:0"]; 15764 [labelType="html" label="PythonRDD [15764] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35255 { label="MicroBatchScan"; 15750 [labelType="html" label="DataSourceRDD [15750] run at <unknown>:0"]; 15751 [labelType="html" label="MapPartitionsRDD [15751] run at <unknown>:0"]; } subgraph cluster35254 { label="Project"; 15752 [labelType="html" label="MapPartitionsRDD [15752] run at <unknown>:0"]; } subgraph cluster35250 { label="WholeStageCodegen (1)"; 15753 [labelType="html" label="MapPartitionsRDD [15753] run at <unknown>:0"]; } subgraph cluster35264 { label="WholeStageCodegen (1)"; 15755 [labelType="html" label="MapPartitionsRDD [15755] toJavaRDD at <unknown>:0"]; } subgraph cluster35263 { label="Filter"; 15756 [labelType="html" label="MapPartitionsRDD [15756] toJavaRDD at <unknown>:0"]; } subgraph cluster35262 { label="Project"; 15757 [labelType="html" label="MapPartitionsRDD [15757] toJavaRDD at <unknown>:0"]; } subgraph cluster35259 { label="WholeStageCodegen (2)"; 15758 [labelType="html" label="MapPartitionsRDD [15758] toJavaRDD at <unknown>:0"]; } subgraph cluster35258 { label="Project"; 15759 [labelType="html" label="MapPartitionsRDD [15759] toJavaRDD at <unknown>:0"]; } subgraph cluster35257 { label="DeserializeToObject"; 15760 [labelType="html" label="MapPartitionsRDD [15760] toJavaRDD at <unknown>:0"]; } subgraph cluster35256 { label="MapPartitions"; 15761 [labelType="html" label="MapPartitionsRDD [15761] toJavaRDD at <unknown>:0"]; } subgraph cluster35266 { label="mapPartitions"; 15763 [labelType="html" label="MapPartitionsRDD [15763] toJavaRDD at <unknown>:0"]; } } 15750->15751; 15751->15752; 15752->15753; 15753->15754; 15754->15755; 15755->15756; 15756->15757; 15757->15758; 15758->15759; 15759->15760; 15760->15761; 15761->15762; 15762->15763; 15763->15764; }

Event Timeline

Enable zooming