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

digraph G { subgraph clusterstage_2020 { label="Stage 2020"; 21215 [labelType="html" label="SQLExecutionRDD [21215] run at <unknown>:0"]; 21229 [labelType="html" label="SQLExecutionRDD [21229] toJavaRDD at <unknown>:0"]; 21231 [labelType="html" label="PythonRDD [21231] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47471 { label="MicroBatchScan"; 21211 [labelType="html" label="DataSourceRDD [21211] run at <unknown>:0"]; 21212 [labelType="html" label="MapPartitionsRDD [21212] run at <unknown>:0"]; } subgraph cluster47470 { label="Project"; 21213 [labelType="html" label="MapPartitionsRDD [21213] run at <unknown>:0"]; } subgraph cluster47466 { label="WholeStageCodegen (1)"; 21214 [labelType="html" label="MapPartitionsRDD [21214] run at <unknown>:0"]; } subgraph cluster47488 { label="WholeStageCodegen (1)"; 21222 [labelType="html" label="MapPartitionsRDD [21222] toJavaRDD at <unknown>:0"]; } subgraph cluster47487 { label="Filter"; 21223 [labelType="html" label="MapPartitionsRDD [21223] toJavaRDD at <unknown>:0"]; } subgraph cluster47486 { label="Project"; 21224 [labelType="html" label="MapPartitionsRDD [21224] toJavaRDD at <unknown>:0"]; } subgraph cluster47483 { label="WholeStageCodegen (2)"; 21225 [labelType="html" label="MapPartitionsRDD [21225] toJavaRDD at <unknown>:0"]; } subgraph cluster47482 { label="Project"; 21226 [labelType="html" label="MapPartitionsRDD [21226] toJavaRDD at <unknown>:0"]; } subgraph cluster47481 { label="DeserializeToObject"; 21227 [labelType="html" label="MapPartitionsRDD [21227] toJavaRDD at <unknown>:0"]; } subgraph cluster47480 { label="MapPartitions"; 21228 [labelType="html" label="MapPartitionsRDD [21228] toJavaRDD at <unknown>:0"]; } subgraph cluster47490 { label="mapPartitions"; 21230 [labelType="html" label="MapPartitionsRDD [21230] toJavaRDD at <unknown>:0"]; } } 21211->21212; 21212->21213; 21213->21214; 21214->21215; 21215->21222; 21222->21223; 21223->21224; 21224->21225; 21225->21226; 21226->21227; 21227->21228; 21228->21229; 21229->21230; 21230->21231; }

Event Timeline

Enable zooming