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

digraph G { subgraph clusterstage_300 { label="Stage 300"; 3154 [labelType="html" label="SQLExecutionRDD [3154] run at <unknown>:0"]; 3162 [labelType="html" label="SQLExecutionRDD [3162] toJavaRDD at <unknown>:0"]; 3164 [labelType="html" label="PythonRDD [3164] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster7055 { label="MicroBatchScan"; 3150 [labelType="html" label="DataSourceRDD [3150] run at <unknown>:0"]; 3151 [labelType="html" label="MapPartitionsRDD [3151] run at <unknown>:0"]; } subgraph cluster7054 { label="Project"; 3152 [labelType="html" label="MapPartitionsRDD [3152] run at <unknown>:0"]; } subgraph cluster7050 { label="WholeStageCodegen (1)"; 3153 [labelType="html" label="MapPartitionsRDD [3153] run at <unknown>:0"]; } subgraph cluster7064 { label="WholeStageCodegen (1)"; 3155 [labelType="html" label="MapPartitionsRDD [3155] toJavaRDD at <unknown>:0"]; } subgraph cluster7063 { label="Filter"; 3156 [labelType="html" label="MapPartitionsRDD [3156] toJavaRDD at <unknown>:0"]; } subgraph cluster7062 { label="Project"; 3157 [labelType="html" label="MapPartitionsRDD [3157] toJavaRDD at <unknown>:0"]; } subgraph cluster7059 { label="WholeStageCodegen (2)"; 3158 [labelType="html" label="MapPartitionsRDD [3158] toJavaRDD at <unknown>:0"]; } subgraph cluster7058 { label="Project"; 3159 [labelType="html" label="MapPartitionsRDD [3159] toJavaRDD at <unknown>:0"]; } subgraph cluster7057 { label="DeserializeToObject"; 3160 [labelType="html" label="MapPartitionsRDD [3160] toJavaRDD at <unknown>:0"]; } subgraph cluster7056 { label="MapPartitions"; 3161 [labelType="html" label="MapPartitionsRDD [3161] toJavaRDD at <unknown>:0"]; } subgraph cluster7066 { label="mapPartitions"; 3163 [labelType="html" label="MapPartitionsRDD [3163] toJavaRDD at <unknown>:0"]; } } 3150->3151; 3151->3152; 3152->3153; 3153->3154; 3154->3155; 3155->3156; 3156->3157; 3157->3158; 3158->3159; 3159->3160; 3160->3161; 3161->3162; 3162->3163; 3163->3164; }

Event Timeline

Enable zooming