processing-stream-kafka-raw-to-minio - Details for Stage 783 (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: 783

digraph G { subgraph clusterstage_783 { label="Stage 783"; 8221 [labelType="html" label="SQLExecutionRDD [8221] run at <unknown>:0"]; 8229 [labelType="html" label="SQLExecutionRDD [8229] toJavaRDD at <unknown>:0"]; 8231 [labelType="html" label="PythonRDD [8231] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster18390 { label="MicroBatchScan"; 8217 [labelType="html" label="DataSourceRDD [8217] run at <unknown>:0"]; 8218 [labelType="html" label="MapPartitionsRDD [8218] run at <unknown>:0"]; } subgraph cluster18389 { label="Project"; 8219 [labelType="html" label="MapPartitionsRDD [8219] run at <unknown>:0"]; } subgraph cluster18383 { label="WholeStageCodegen (1)"; 8220 [labelType="html" label="MapPartitionsRDD [8220] run at <unknown>:0"]; } subgraph cluster18399 { label="WholeStageCodegen (1)"; 8222 [labelType="html" label="MapPartitionsRDD [8222] toJavaRDD at <unknown>:0"]; } subgraph cluster18398 { label="Filter"; 8223 [labelType="html" label="MapPartitionsRDD [8223] toJavaRDD at <unknown>:0"]; } subgraph cluster18397 { label="Project"; 8224 [labelType="html" label="MapPartitionsRDD [8224] toJavaRDD at <unknown>:0"]; } subgraph cluster18394 { label="WholeStageCodegen (2)"; 8225 [labelType="html" label="MapPartitionsRDD [8225] toJavaRDD at <unknown>:0"]; } subgraph cluster18393 { label="Project"; 8226 [labelType="html" label="MapPartitionsRDD [8226] toJavaRDD at <unknown>:0"]; } subgraph cluster18392 { label="DeserializeToObject"; 8227 [labelType="html" label="MapPartitionsRDD [8227] toJavaRDD at <unknown>:0"]; } subgraph cluster18391 { label="MapPartitions"; 8228 [labelType="html" label="MapPartitionsRDD [8228] toJavaRDD at <unknown>:0"]; } subgraph cluster18401 { label="mapPartitions"; 8230 [labelType="html" label="MapPartitionsRDD [8230] toJavaRDD at <unknown>:0"]; } } 8217->8218; 8218->8219; 8219->8220; 8220->8221; 8221->8222; 8222->8223; 8223->8224; 8224->8225; 8225->8226; 8226->8227; 8227->8228; 8228->8229; 8229->8230; 8230->8231; }

Event Timeline

Enable zooming