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

digraph G { subgraph clusterstage_1648 { label="Stage 1648"; 17315 [labelType="html" label="SQLExecutionRDD [17315] run at <unknown>:0"]; 17323 [labelType="html" label="SQLExecutionRDD [17323] toJavaRDD at <unknown>:0"]; 17325 [labelType="html" label="PythonRDD [17325] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster38737 { label="MicroBatchScan"; 17311 [labelType="html" label="DataSourceRDD [17311] run at <unknown>:0"]; 17312 [labelType="html" label="MapPartitionsRDD [17312] run at <unknown>:0"]; } subgraph cluster38736 { label="Project"; 17313 [labelType="html" label="MapPartitionsRDD [17313] run at <unknown>:0"]; } subgraph cluster38732 { label="WholeStageCodegen (1)"; 17314 [labelType="html" label="MapPartitionsRDD [17314] run at <unknown>:0"]; } subgraph cluster38746 { label="WholeStageCodegen (1)"; 17316 [labelType="html" label="MapPartitionsRDD [17316] toJavaRDD at <unknown>:0"]; } subgraph cluster38745 { label="Filter"; 17317 [labelType="html" label="MapPartitionsRDD [17317] toJavaRDD at <unknown>:0"]; } subgraph cluster38744 { label="Project"; 17318 [labelType="html" label="MapPartitionsRDD [17318] toJavaRDD at <unknown>:0"]; } subgraph cluster38741 { label="WholeStageCodegen (2)"; 17319 [labelType="html" label="MapPartitionsRDD [17319] toJavaRDD at <unknown>:0"]; } subgraph cluster38740 { label="Project"; 17320 [labelType="html" label="MapPartitionsRDD [17320] toJavaRDD at <unknown>:0"]; } subgraph cluster38739 { label="DeserializeToObject"; 17321 [labelType="html" label="MapPartitionsRDD [17321] toJavaRDD at <unknown>:0"]; } subgraph cluster38738 { label="MapPartitions"; 17322 [labelType="html" label="MapPartitionsRDD [17322] toJavaRDD at <unknown>:0"]; } subgraph cluster38748 { label="mapPartitions"; 17324 [labelType="html" label="MapPartitionsRDD [17324] toJavaRDD at <unknown>:0"]; } } 17311->17312; 17312->17313; 17313->17314; 17314->17315; 17315->17316; 17316->17317; 17317->17318; 17318->17319; 17319->17320; 17320->17321; 17321->17322; 17322->17323; 17323->17324; 17324->17325; }

Event Timeline

Enable zooming