processing-stream-kafka-raw-to-minio - Details for Stage 1 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 8 s
Locality Level Summary: Process local: 3
Input Size / Records: 0.0 B / 722
Associated Job Ids: 1

digraph G { subgraph clusterstage_1 { label="Stage 1"; 8 [labelType="html" label="SQLExecutionRDD [8] start at NativeMethodAccessorImpl.java:0"]; 18 [labelType="html" label="SQLExecutionRDD [18] start at NativeMethodAccessorImpl.java:0"]; 20 [labelType="html" label="PythonRDD [20] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12 { label="MicroBatchScan"; 1 [labelType="html" label="DataSourceRDD [1] start at NativeMethodAccessorImpl.java:0"]; 3 [labelType="html" label="MapPartitionsRDD [3] start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster10 { label="Project"; 4 [labelType="html" label="MapPartitionsRDD [4] start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster0 { label="WholeStageCodegen (1)"; 6 [labelType="html" label="MapPartitionsRDD [6] start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster22 { label="WholeStageCodegen (1)"; 11 [labelType="html" label="MapPartitionsRDD [11] start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster21 { label="Filter"; 12 [labelType="html" label="MapPartitionsRDD [12] start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster20 { label="Project"; 13 [labelType="html" label="MapPartitionsRDD [13] start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster17 { label="WholeStageCodegen (2)"; 14 [labelType="html" label="MapPartitionsRDD [14] start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster16 { label="Project"; 15 [labelType="html" label="MapPartitionsRDD [15] start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster15 { label="DeserializeToObject"; 16 [labelType="html" label="MapPartitionsRDD [16] start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster14 { label="MapPartitions"; 17 [labelType="html" label="MapPartitionsRDD [17] start at NativeMethodAccessorImpl.java:0"]; } subgraph cluster24 { label="mapPartitions"; 19 [labelType="html" label="MapPartitionsRDD [19] start at NativeMethodAccessorImpl.java:0"]; } } 1->3; 3->4; 4->6; 6->8; 8->11; 11->12; 12->13; 13->14; 14->15; 15->16; 16->17; 17->18; 18->19; 19->20; }

Event Timeline

Enable zooming