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

digraph G { subgraph clusterstage_1028 { label="Stage 1028"; 10799 [labelType="html" label="SQLExecutionRDD [10799] run at <unknown>:0"]; 10813 [labelType="html" label="SQLExecutionRDD [10813] toJavaRDD at <unknown>:0"]; 10815 [labelType="html" label="PythonRDD [10815] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24159 { label="MicroBatchScan"; 10795 [labelType="html" label="DataSourceRDD [10795] run at <unknown>:0"]; 10796 [labelType="html" label="MapPartitionsRDD [10796] run at <unknown>:0"]; } subgraph cluster24158 { label="Project"; 10797 [labelType="html" label="MapPartitionsRDD [10797] run at <unknown>:0"]; } subgraph cluster24154 { label="WholeStageCodegen (1)"; 10798 [labelType="html" label="MapPartitionsRDD [10798] run at <unknown>:0"]; } subgraph cluster24176 { label="WholeStageCodegen (1)"; 10806 [labelType="html" label="MapPartitionsRDD [10806] toJavaRDD at <unknown>:0"]; } subgraph cluster24175 { label="Filter"; 10807 [labelType="html" label="MapPartitionsRDD [10807] toJavaRDD at <unknown>:0"]; } subgraph cluster24174 { label="Project"; 10808 [labelType="html" label="MapPartitionsRDD [10808] toJavaRDD at <unknown>:0"]; } subgraph cluster24171 { label="WholeStageCodegen (2)"; 10809 [labelType="html" label="MapPartitionsRDD [10809] toJavaRDD at <unknown>:0"]; } subgraph cluster24170 { label="Project"; 10810 [labelType="html" label="MapPartitionsRDD [10810] toJavaRDD at <unknown>:0"]; } subgraph cluster24169 { label="DeserializeToObject"; 10811 [labelType="html" label="MapPartitionsRDD [10811] toJavaRDD at <unknown>:0"]; } subgraph cluster24168 { label="MapPartitions"; 10812 [labelType="html" label="MapPartitionsRDD [10812] toJavaRDD at <unknown>:0"]; } subgraph cluster24178 { label="mapPartitions"; 10814 [labelType="html" label="MapPartitionsRDD [10814] toJavaRDD at <unknown>:0"]; } } 10795->10796; 10796->10797; 10797->10798; 10798->10799; 10799->10806; 10806->10807; 10807->10808; 10808->10809; 10809->10810; 10810->10811; 10811->10812; 10812->10813; 10813->10814; 10814->10815; }

Event Timeline

Enable zooming