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

digraph G { subgraph clusterstage_1538 { label="Stage 1538"; 16153 [labelType="html" label="SQLExecutionRDD [16153] run at <unknown>:0"]; 16161 [labelType="html" label="SQLExecutionRDD [16161] toJavaRDD at <unknown>:0"]; 16166 [labelType="html" label="PythonRDD [16166] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster36148 { label="MicroBatchScan"; 16149 [labelType="html" label="DataSourceRDD [16149] run at <unknown>:0"]; 16150 [labelType="html" label="MapPartitionsRDD [16150] run at <unknown>:0"]; } subgraph cluster36147 { label="Project"; 16151 [labelType="html" label="MapPartitionsRDD [16151] run at <unknown>:0"]; } subgraph cluster36143 { label="WholeStageCodegen (1)"; 16152 [labelType="html" label="MapPartitionsRDD [16152] run at <unknown>:0"]; } subgraph cluster36157 { label="WholeStageCodegen (1)"; 16154 [labelType="html" label="MapPartitionsRDD [16154] toJavaRDD at <unknown>:0"]; } subgraph cluster36156 { label="Filter"; 16155 [labelType="html" label="MapPartitionsRDD [16155] toJavaRDD at <unknown>:0"]; } subgraph cluster36155 { label="Project"; 16156 [labelType="html" label="MapPartitionsRDD [16156] toJavaRDD at <unknown>:0"]; } subgraph cluster36152 { label="WholeStageCodegen (2)"; 16157 [labelType="html" label="MapPartitionsRDD [16157] toJavaRDD at <unknown>:0"]; } subgraph cluster36151 { label="Project"; 16158 [labelType="html" label="MapPartitionsRDD [16158] toJavaRDD at <unknown>:0"]; } subgraph cluster36150 { label="DeserializeToObject"; 16159 [labelType="html" label="MapPartitionsRDD [16159] toJavaRDD at <unknown>:0"]; } subgraph cluster36149 { label="MapPartitions"; 16160 [labelType="html" label="MapPartitionsRDD [16160] toJavaRDD at <unknown>:0"]; } subgraph cluster36159 { label="mapPartitions"; 16162 [labelType="html" label="MapPartitionsRDD [16162] toJavaRDD at <unknown>:0"]; } } 16149->16150; 16150->16151; 16151->16152; 16152->16153; 16153->16154; 16154->16155; 16155->16156; 16156->16157; 16157->16158; 16158->16159; 16159->16160; 16160->16161; 16161->16162; 16162->16166; }

Event Timeline

Enable zooming