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

digraph G { subgraph clusterstage_1675 { label="Stage 1675"; 17603 [labelType="html" label="SQLExecutionRDD [17603] run at <unknown>:0"]; 17611 [labelType="html" label="SQLExecutionRDD [17611] toJavaRDD at <unknown>:0"]; 17613 [labelType="html" label="PythonRDD [17613] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39387 { label="MicroBatchScan"; 17599 [labelType="html" label="DataSourceRDD [17599] run at <unknown>:0"]; 17600 [labelType="html" label="MapPartitionsRDD [17600] run at <unknown>:0"]; } subgraph cluster39386 { label="Project"; 17601 [labelType="html" label="MapPartitionsRDD [17601] run at <unknown>:0"]; } subgraph cluster39382 { label="WholeStageCodegen (1)"; 17602 [labelType="html" label="MapPartitionsRDD [17602] run at <unknown>:0"]; } subgraph cluster39396 { label="WholeStageCodegen (1)"; 17604 [labelType="html" label="MapPartitionsRDD [17604] toJavaRDD at <unknown>:0"]; } subgraph cluster39395 { label="Filter"; 17605 [labelType="html" label="MapPartitionsRDD [17605] toJavaRDD at <unknown>:0"]; } subgraph cluster39394 { label="Project"; 17606 [labelType="html" label="MapPartitionsRDD [17606] toJavaRDD at <unknown>:0"]; } subgraph cluster39391 { label="WholeStageCodegen (2)"; 17607 [labelType="html" label="MapPartitionsRDD [17607] toJavaRDD at <unknown>:0"]; } subgraph cluster39390 { label="Project"; 17608 [labelType="html" label="MapPartitionsRDD [17608] toJavaRDD at <unknown>:0"]; } subgraph cluster39389 { label="DeserializeToObject"; 17609 [labelType="html" label="MapPartitionsRDD [17609] toJavaRDD at <unknown>:0"]; } subgraph cluster39388 { label="MapPartitions"; 17610 [labelType="html" label="MapPartitionsRDD [17610] toJavaRDD at <unknown>:0"]; } subgraph cluster39398 { label="mapPartitions"; 17612 [labelType="html" label="MapPartitionsRDD [17612] toJavaRDD at <unknown>:0"]; } } 17599->17600; 17600->17601; 17601->17602; 17602->17603; 17603->17604; 17604->17605; 17605->17606; 17606->17607; 17607->17608; 17608->17609; 17609->17610; 17610->17611; 17611->17612; 17612->17613; }

Event Timeline

Enable zooming