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

digraph G { subgraph clusterstage_1258 { label="Stage 1258"; 13214 [labelType="html" label="SQLExecutionRDD [13214] run at <unknown>:0"]; 13228 [labelType="html" label="SQLExecutionRDD [13228] toJavaRDD at <unknown>:0"]; 13230 [labelType="html" label="PythonRDD [13230] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29564 { label="MicroBatchScan"; 13210 [labelType="html" label="DataSourceRDD [13210] run at <unknown>:0"]; 13211 [labelType="html" label="MapPartitionsRDD [13211] run at <unknown>:0"]; } subgraph cluster29563 { label="Project"; 13212 [labelType="html" label="MapPartitionsRDD [13212] run at <unknown>:0"]; } subgraph cluster29559 { label="WholeStageCodegen (1)"; 13213 [labelType="html" label="MapPartitionsRDD [13213] run at <unknown>:0"]; } subgraph cluster29581 { label="WholeStageCodegen (1)"; 13221 [labelType="html" label="MapPartitionsRDD [13221] toJavaRDD at <unknown>:0"]; } subgraph cluster29580 { label="Filter"; 13222 [labelType="html" label="MapPartitionsRDD [13222] toJavaRDD at <unknown>:0"]; } subgraph cluster29579 { label="Project"; 13223 [labelType="html" label="MapPartitionsRDD [13223] toJavaRDD at <unknown>:0"]; } subgraph cluster29576 { label="WholeStageCodegen (2)"; 13224 [labelType="html" label="MapPartitionsRDD [13224] toJavaRDD at <unknown>:0"]; } subgraph cluster29575 { label="Project"; 13225 [labelType="html" label="MapPartitionsRDD [13225] toJavaRDD at <unknown>:0"]; } subgraph cluster29574 { label="DeserializeToObject"; 13226 [labelType="html" label="MapPartitionsRDD [13226] toJavaRDD at <unknown>:0"]; } subgraph cluster29573 { label="MapPartitions"; 13227 [labelType="html" label="MapPartitionsRDD [13227] toJavaRDD at <unknown>:0"]; } subgraph cluster29583 { label="mapPartitions"; 13229 [labelType="html" label="MapPartitionsRDD [13229] toJavaRDD at <unknown>:0"]; } } 13210->13211; 13211->13212; 13212->13213; 13213->13214; 13214->13221; 13221->13222; 13222->13223; 13223->13224; 13224->13225; 13225->13226; 13226->13227; 13227->13228; 13228->13229; 13229->13230; }

Event Timeline

Enable zooming