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

digraph G { subgraph clusterstage_2009 { label="Stage 2009"; 21110 [labelType="html" label="SQLExecutionRDD [21110] run at <unknown>:0"]; 21118 [labelType="html" label="SQLExecutionRDD [21118] toJavaRDD at <unknown>:0"]; 21120 [labelType="html" label="PythonRDD [21120] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47236 { label="MicroBatchScan"; 21106 [labelType="html" label="DataSourceRDD [21106] run at <unknown>:0"]; 21107 [labelType="html" label="MapPartitionsRDD [21107] run at <unknown>:0"]; } subgraph cluster47235 { label="Project"; 21108 [labelType="html" label="MapPartitionsRDD [21108] run at <unknown>:0"]; } subgraph cluster47231 { label="WholeStageCodegen (1)"; 21109 [labelType="html" label="MapPartitionsRDD [21109] run at <unknown>:0"]; } subgraph cluster47245 { label="WholeStageCodegen (1)"; 21111 [labelType="html" label="MapPartitionsRDD [21111] toJavaRDD at <unknown>:0"]; } subgraph cluster47244 { label="Filter"; 21112 [labelType="html" label="MapPartitionsRDD [21112] toJavaRDD at <unknown>:0"]; } subgraph cluster47243 { label="Project"; 21113 [labelType="html" label="MapPartitionsRDD [21113] toJavaRDD at <unknown>:0"]; } subgraph cluster47240 { label="WholeStageCodegen (2)"; 21114 [labelType="html" label="MapPartitionsRDD [21114] toJavaRDD at <unknown>:0"]; } subgraph cluster47239 { label="Project"; 21115 [labelType="html" label="MapPartitionsRDD [21115] toJavaRDD at <unknown>:0"]; } subgraph cluster47238 { label="DeserializeToObject"; 21116 [labelType="html" label="MapPartitionsRDD [21116] toJavaRDD at <unknown>:0"]; } subgraph cluster47237 { label="MapPartitions"; 21117 [labelType="html" label="MapPartitionsRDD [21117] toJavaRDD at <unknown>:0"]; } subgraph cluster47247 { label="mapPartitions"; 21119 [labelType="html" label="MapPartitionsRDD [21119] toJavaRDD at <unknown>:0"]; } } 21106->21107; 21107->21108; 21108->21109; 21109->21110; 21110->21111; 21111->21112; 21112->21113; 21113->21114; 21114->21115; 21115->21116; 21116->21117; 21117->21118; 21118->21119; 21119->21120; }

Event Timeline

Enable zooming