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

digraph G { subgraph clusterstage_680 { label="Stage 680"; 7144 [labelType="html" label="SQLExecutionRDD [7144] run at <unknown>:0"]; 7152 [labelType="html" label="SQLExecutionRDD [7152] toJavaRDD at <unknown>:0"]; 7154 [labelType="html" label="PythonRDD [7154] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster15985 { label="MicroBatchScan"; 7140 [labelType="html" label="DataSourceRDD [7140] run at <unknown>:0"]; 7141 [labelType="html" label="MapPartitionsRDD [7141] run at <unknown>:0"]; } subgraph cluster15984 { label="Project"; 7142 [labelType="html" label="MapPartitionsRDD [7142] run at <unknown>:0"]; } subgraph cluster15980 { label="WholeStageCodegen (1)"; 7143 [labelType="html" label="MapPartitionsRDD [7143] run at <unknown>:0"]; } subgraph cluster15994 { label="WholeStageCodegen (1)"; 7145 [labelType="html" label="MapPartitionsRDD [7145] toJavaRDD at <unknown>:0"]; } subgraph cluster15993 { label="Filter"; 7146 [labelType="html" label="MapPartitionsRDD [7146] toJavaRDD at <unknown>:0"]; } subgraph cluster15992 { label="Project"; 7147 [labelType="html" label="MapPartitionsRDD [7147] toJavaRDD at <unknown>:0"]; } subgraph cluster15989 { label="WholeStageCodegen (2)"; 7148 [labelType="html" label="MapPartitionsRDD [7148] toJavaRDD at <unknown>:0"]; } subgraph cluster15988 { label="Project"; 7149 [labelType="html" label="MapPartitionsRDD [7149] toJavaRDD at <unknown>:0"]; } subgraph cluster15987 { label="DeserializeToObject"; 7150 [labelType="html" label="MapPartitionsRDD [7150] toJavaRDD at <unknown>:0"]; } subgraph cluster15986 { label="MapPartitions"; 7151 [labelType="html" label="MapPartitionsRDD [7151] toJavaRDD at <unknown>:0"]; } subgraph cluster15996 { label="mapPartitions"; 7153 [labelType="html" label="MapPartitionsRDD [7153] toJavaRDD at <unknown>:0"]; } } 7140->7141; 7141->7142; 7142->7143; 7143->7144; 7144->7145; 7145->7146; 7146->7147; 7147->7148; 7148->7149; 7149->7150; 7150->7151; 7151->7152; 7152->7153; 7153->7154; }

Event Timeline

Enable zooming