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

digraph G { subgraph clusterstage_1304 { label="Stage 1304"; 13696 [labelType="html" label="SQLExecutionRDD [13696] run at <unknown>:0"]; 13704 [labelType="html" label="SQLExecutionRDD [13704] toJavaRDD at <unknown>:0"]; 13706 [labelType="html" label="PythonRDD [13706] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster30649 { label="MicroBatchScan"; 13692 [labelType="html" label="DataSourceRDD [13692] run at <unknown>:0"]; 13693 [labelType="html" label="MapPartitionsRDD [13693] run at <unknown>:0"]; } subgraph cluster30648 { label="Project"; 13694 [labelType="html" label="MapPartitionsRDD [13694] run at <unknown>:0"]; } subgraph cluster30644 { label="WholeStageCodegen (1)"; 13695 [labelType="html" label="MapPartitionsRDD [13695] run at <unknown>:0"]; } subgraph cluster30658 { label="WholeStageCodegen (1)"; 13697 [labelType="html" label="MapPartitionsRDD [13697] toJavaRDD at <unknown>:0"]; } subgraph cluster30657 { label="Filter"; 13698 [labelType="html" label="MapPartitionsRDD [13698] toJavaRDD at <unknown>:0"]; } subgraph cluster30656 { label="Project"; 13699 [labelType="html" label="MapPartitionsRDD [13699] toJavaRDD at <unknown>:0"]; } subgraph cluster30653 { label="WholeStageCodegen (2)"; 13700 [labelType="html" label="MapPartitionsRDD [13700] toJavaRDD at <unknown>:0"]; } subgraph cluster30652 { label="Project"; 13701 [labelType="html" label="MapPartitionsRDD [13701] toJavaRDD at <unknown>:0"]; } subgraph cluster30651 { label="DeserializeToObject"; 13702 [labelType="html" label="MapPartitionsRDD [13702] toJavaRDD at <unknown>:0"]; } subgraph cluster30650 { label="MapPartitions"; 13703 [labelType="html" label="MapPartitionsRDD [13703] toJavaRDD at <unknown>:0"]; } subgraph cluster30660 { label="mapPartitions"; 13705 [labelType="html" label="MapPartitionsRDD [13705] toJavaRDD at <unknown>:0"]; } } 13692->13693; 13693->13694; 13694->13695; 13695->13696; 13696->13697; 13697->13698; 13698->13699; 13699->13700; 13700->13701; 13701->13702; 13702->13703; 13703->13704; 13704->13705; 13705->13706; }

Event Timeline

Enable zooming