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

digraph G { subgraph clusterstage_1354 { label="Stage 1354"; 14221 [labelType="html" label="SQLExecutionRDD [14221] run at <unknown>:0"]; 14229 [labelType="html" label="SQLExecutionRDD [14229] toJavaRDD at <unknown>:0"]; 14231 [labelType="html" label="PythonRDD [14231] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31824 { label="MicroBatchScan"; 14217 [labelType="html" label="DataSourceRDD [14217] run at <unknown>:0"]; 14218 [labelType="html" label="MapPartitionsRDD [14218] run at <unknown>:0"]; } subgraph cluster31823 { label="Project"; 14219 [labelType="html" label="MapPartitionsRDD [14219] run at <unknown>:0"]; } subgraph cluster31819 { label="WholeStageCodegen (1)"; 14220 [labelType="html" label="MapPartitionsRDD [14220] run at <unknown>:0"]; } subgraph cluster31833 { label="WholeStageCodegen (1)"; 14222 [labelType="html" label="MapPartitionsRDD [14222] toJavaRDD at <unknown>:0"]; } subgraph cluster31832 { label="Filter"; 14223 [labelType="html" label="MapPartitionsRDD [14223] toJavaRDD at <unknown>:0"]; } subgraph cluster31831 { label="Project"; 14224 [labelType="html" label="MapPartitionsRDD [14224] toJavaRDD at <unknown>:0"]; } subgraph cluster31828 { label="WholeStageCodegen (2)"; 14225 [labelType="html" label="MapPartitionsRDD [14225] toJavaRDD at <unknown>:0"]; } subgraph cluster31827 { label="Project"; 14226 [labelType="html" label="MapPartitionsRDD [14226] toJavaRDD at <unknown>:0"]; } subgraph cluster31826 { label="DeserializeToObject"; 14227 [labelType="html" label="MapPartitionsRDD [14227] toJavaRDD at <unknown>:0"]; } subgraph cluster31825 { label="MapPartitions"; 14228 [labelType="html" label="MapPartitionsRDD [14228] toJavaRDD at <unknown>:0"]; } subgraph cluster31835 { label="mapPartitions"; 14230 [labelType="html" label="MapPartitionsRDD [14230] toJavaRDD at <unknown>:0"]; } } 14217->14218; 14218->14219; 14219->14220; 14220->14221; 14221->14222; 14222->14223; 14223->14224; 14224->14225; 14225->14226; 14226->14227; 14227->14228; 14228->14229; 14229->14230; 14230->14231; }

Event Timeline

Enable zooming