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

digraph G { subgraph clusterstage_1688 { label="Stage 1688"; 17735 [labelType="html" label="SQLExecutionRDD [17735] run at <unknown>:0"]; 17743 [labelType="html" label="SQLExecutionRDD [17743] toJavaRDD at <unknown>:0"]; 17745 [labelType="html" label="PythonRDD [17745] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39677 { label="MicroBatchScan"; 17731 [labelType="html" label="DataSourceRDD [17731] run at <unknown>:0"]; 17732 [labelType="html" label="MapPartitionsRDD [17732] run at <unknown>:0"]; } subgraph cluster39676 { label="Project"; 17733 [labelType="html" label="MapPartitionsRDD [17733] run at <unknown>:0"]; } subgraph cluster39672 { label="WholeStageCodegen (1)"; 17734 [labelType="html" label="MapPartitionsRDD [17734] run at <unknown>:0"]; } subgraph cluster39686 { label="WholeStageCodegen (1)"; 17736 [labelType="html" label="MapPartitionsRDD [17736] toJavaRDD at <unknown>:0"]; } subgraph cluster39685 { label="Filter"; 17737 [labelType="html" label="MapPartitionsRDD [17737] toJavaRDD at <unknown>:0"]; } subgraph cluster39684 { label="Project"; 17738 [labelType="html" label="MapPartitionsRDD [17738] toJavaRDD at <unknown>:0"]; } subgraph cluster39681 { label="WholeStageCodegen (2)"; 17739 [labelType="html" label="MapPartitionsRDD [17739] toJavaRDD at <unknown>:0"]; } subgraph cluster39680 { label="Project"; 17740 [labelType="html" label="MapPartitionsRDD [17740] toJavaRDD at <unknown>:0"]; } subgraph cluster39679 { label="DeserializeToObject"; 17741 [labelType="html" label="MapPartitionsRDD [17741] toJavaRDD at <unknown>:0"]; } subgraph cluster39678 { label="MapPartitions"; 17742 [labelType="html" label="MapPartitionsRDD [17742] toJavaRDD at <unknown>:0"]; } subgraph cluster39688 { label="mapPartitions"; 17744 [labelType="html" label="MapPartitionsRDD [17744] toJavaRDD at <unknown>:0"]; } } 17731->17732; 17732->17733; 17733->17734; 17734->17735; 17735->17736; 17736->17737; 17737->17738; 17738->17739; 17739->17740; 17740->17741; 17741->17742; 17742->17743; 17743->17744; 17744->17745; }

Event Timeline

Enable zooming