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

digraph G { subgraph clusterstage_1409 { label="Stage 1409"; 14810 [labelType="html" label="SQLExecutionRDD [14810] run at <unknown>:0"]; 14818 [labelType="html" label="SQLExecutionRDD [14818] toJavaRDD at <unknown>:0"]; 14820 [labelType="html" label="PythonRDD [14820] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33136 { label="MicroBatchScan"; 14806 [labelType="html" label="DataSourceRDD [14806] run at <unknown>:0"]; 14807 [labelType="html" label="MapPartitionsRDD [14807] run at <unknown>:0"]; } subgraph cluster33135 { label="Project"; 14808 [labelType="html" label="MapPartitionsRDD [14808] run at <unknown>:0"]; } subgraph cluster33131 { label="WholeStageCodegen (1)"; 14809 [labelType="html" label="MapPartitionsRDD [14809] run at <unknown>:0"]; } subgraph cluster33145 { label="WholeStageCodegen (1)"; 14811 [labelType="html" label="MapPartitionsRDD [14811] toJavaRDD at <unknown>:0"]; } subgraph cluster33144 { label="Filter"; 14812 [labelType="html" label="MapPartitionsRDD [14812] toJavaRDD at <unknown>:0"]; } subgraph cluster33143 { label="Project"; 14813 [labelType="html" label="MapPartitionsRDD [14813] toJavaRDD at <unknown>:0"]; } subgraph cluster33140 { label="WholeStageCodegen (2)"; 14814 [labelType="html" label="MapPartitionsRDD [14814] toJavaRDD at <unknown>:0"]; } subgraph cluster33139 { label="Project"; 14815 [labelType="html" label="MapPartitionsRDD [14815] toJavaRDD at <unknown>:0"]; } subgraph cluster33138 { label="DeserializeToObject"; 14816 [labelType="html" label="MapPartitionsRDD [14816] toJavaRDD at <unknown>:0"]; } subgraph cluster33137 { label="MapPartitions"; 14817 [labelType="html" label="MapPartitionsRDD [14817] toJavaRDD at <unknown>:0"]; } subgraph cluster33147 { label="mapPartitions"; 14819 [labelType="html" label="MapPartitionsRDD [14819] toJavaRDD at <unknown>:0"]; } } 14806->14807; 14807->14808; 14808->14809; 14809->14810; 14810->14811; 14811->14812; 14812->14813; 14813->14814; 14814->14815; 14815->14816; 14816->14817; 14817->14818; 14818->14819; 14819->14820; }

Event Timeline

Enable zooming