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

digraph G { subgraph clusterstage_1348 { label="Stage 1348"; 14158 [labelType="html" label="SQLExecutionRDD [14158] run at <unknown>:0"]; 14166 [labelType="html" label="SQLExecutionRDD [14166] toJavaRDD at <unknown>:0"]; 14168 [labelType="html" label="PythonRDD [14168] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31683 { label="MicroBatchScan"; 14154 [labelType="html" label="DataSourceRDD [14154] run at <unknown>:0"]; 14155 [labelType="html" label="MapPartitionsRDD [14155] run at <unknown>:0"]; } subgraph cluster31682 { label="Project"; 14156 [labelType="html" label="MapPartitionsRDD [14156] run at <unknown>:0"]; } subgraph cluster31678 { label="WholeStageCodegen (1)"; 14157 [labelType="html" label="MapPartitionsRDD [14157] run at <unknown>:0"]; } subgraph cluster31692 { label="WholeStageCodegen (1)"; 14159 [labelType="html" label="MapPartitionsRDD [14159] toJavaRDD at <unknown>:0"]; } subgraph cluster31691 { label="Filter"; 14160 [labelType="html" label="MapPartitionsRDD [14160] toJavaRDD at <unknown>:0"]; } subgraph cluster31690 { label="Project"; 14161 [labelType="html" label="MapPartitionsRDD [14161] toJavaRDD at <unknown>:0"]; } subgraph cluster31687 { label="WholeStageCodegen (2)"; 14162 [labelType="html" label="MapPartitionsRDD [14162] toJavaRDD at <unknown>:0"]; } subgraph cluster31686 { label="Project"; 14163 [labelType="html" label="MapPartitionsRDD [14163] toJavaRDD at <unknown>:0"]; } subgraph cluster31685 { label="DeserializeToObject"; 14164 [labelType="html" label="MapPartitionsRDD [14164] toJavaRDD at <unknown>:0"]; } subgraph cluster31684 { label="MapPartitions"; 14165 [labelType="html" label="MapPartitionsRDD [14165] toJavaRDD at <unknown>:0"]; } subgraph cluster31694 { label="mapPartitions"; 14167 [labelType="html" label="MapPartitionsRDD [14167] toJavaRDD at <unknown>:0"]; } } 14154->14155; 14155->14156; 14156->14157; 14157->14158; 14158->14159; 14159->14160; 14160->14161; 14161->14162; 14162->14163; 14163->14164; 14164->14165; 14165->14166; 14166->14167; 14167->14168; }

Event Timeline

Enable zooming