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

digraph G { subgraph clusterstage_1599 { label="Stage 1599"; 16805 [labelType="html" label="SQLExecutionRDD [16805] run at <unknown>:0"]; 16813 [labelType="html" label="SQLExecutionRDD [16813] toJavaRDD at <unknown>:0"]; 16815 [labelType="html" label="PythonRDD [16815] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37601 { label="MicroBatchScan"; 16801 [labelType="html" label="DataSourceRDD [16801] run at <unknown>:0"]; 16802 [labelType="html" label="MapPartitionsRDD [16802] run at <unknown>:0"]; } subgraph cluster37600 { label="Project"; 16803 [labelType="html" label="MapPartitionsRDD [16803] run at <unknown>:0"]; } subgraph cluster37596 { label="WholeStageCodegen (1)"; 16804 [labelType="html" label="MapPartitionsRDD [16804] run at <unknown>:0"]; } subgraph cluster37610 { label="WholeStageCodegen (1)"; 16806 [labelType="html" label="MapPartitionsRDD [16806] toJavaRDD at <unknown>:0"]; } subgraph cluster37609 { label="Filter"; 16807 [labelType="html" label="MapPartitionsRDD [16807] toJavaRDD at <unknown>:0"]; } subgraph cluster37608 { label="Project"; 16808 [labelType="html" label="MapPartitionsRDD [16808] toJavaRDD at <unknown>:0"]; } subgraph cluster37605 { label="WholeStageCodegen (2)"; 16809 [labelType="html" label="MapPartitionsRDD [16809] toJavaRDD at <unknown>:0"]; } subgraph cluster37604 { label="Project"; 16810 [labelType="html" label="MapPartitionsRDD [16810] toJavaRDD at <unknown>:0"]; } subgraph cluster37603 { label="DeserializeToObject"; 16811 [labelType="html" label="MapPartitionsRDD [16811] toJavaRDD at <unknown>:0"]; } subgraph cluster37602 { label="MapPartitions"; 16812 [labelType="html" label="MapPartitionsRDD [16812] toJavaRDD at <unknown>:0"]; } subgraph cluster37612 { label="mapPartitions"; 16814 [labelType="html" label="MapPartitionsRDD [16814] toJavaRDD at <unknown>:0"]; } } 16801->16802; 16802->16803; 16803->16804; 16804->16805; 16805->16806; 16806->16807; 16807->16808; 16808->16809; 16809->16810; 16810->16811; 16811->16812; 16812->16813; 16813->16814; 16814->16815; }

Event Timeline

Enable zooming