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

digraph G { subgraph clusterstage_1918 { label="Stage 1918"; 20143 [labelType="html" label="SQLExecutionRDD [20143] run at <unknown>:0"]; 20151 [labelType="html" label="SQLExecutionRDD [20151] toJavaRDD at <unknown>:0"]; 20153 [labelType="html" label="PythonRDD [20153] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster45078 { label="MicroBatchScan"; 20139 [labelType="html" label="DataSourceRDD [20139] run at <unknown>:0"]; 20140 [labelType="html" label="MapPartitionsRDD [20140] run at <unknown>:0"]; } subgraph cluster45077 { label="Project"; 20141 [labelType="html" label="MapPartitionsRDD [20141] run at <unknown>:0"]; } subgraph cluster45073 { label="WholeStageCodegen (1)"; 20142 [labelType="html" label="MapPartitionsRDD [20142] run at <unknown>:0"]; } subgraph cluster45087 { label="WholeStageCodegen (1)"; 20144 [labelType="html" label="MapPartitionsRDD [20144] toJavaRDD at <unknown>:0"]; } subgraph cluster45086 { label="Filter"; 20145 [labelType="html" label="MapPartitionsRDD [20145] toJavaRDD at <unknown>:0"]; } subgraph cluster45085 { label="Project"; 20146 [labelType="html" label="MapPartitionsRDD [20146] toJavaRDD at <unknown>:0"]; } subgraph cluster45082 { label="WholeStageCodegen (2)"; 20147 [labelType="html" label="MapPartitionsRDD [20147] toJavaRDD at <unknown>:0"]; } subgraph cluster45081 { label="Project"; 20148 [labelType="html" label="MapPartitionsRDD [20148] toJavaRDD at <unknown>:0"]; } subgraph cluster45080 { label="DeserializeToObject"; 20149 [labelType="html" label="MapPartitionsRDD [20149] toJavaRDD at <unknown>:0"]; } subgraph cluster45079 { label="MapPartitions"; 20150 [labelType="html" label="MapPartitionsRDD [20150] toJavaRDD at <unknown>:0"]; } subgraph cluster45089 { label="mapPartitions"; 20152 [labelType="html" label="MapPartitionsRDD [20152] toJavaRDD at <unknown>:0"]; } } 20139->20140; 20140->20141; 20141->20142; 20142->20143; 20143->20144; 20144->20145; 20145->20146; 20146->20147; 20147->20148; 20148->20149; 20149->20150; 20150->20151; 20151->20152; 20152->20153; }

Event Timeline

Enable zooming