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

digraph G { subgraph clusterstage_516 { label="Stage 516"; 5422 [labelType="html" label="SQLExecutionRDD [5422] run at <unknown>:0"]; 5430 [labelType="html" label="SQLExecutionRDD [5430] toJavaRDD at <unknown>:0"]; 5432 [labelType="html" label="PythonRDD [5432] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12131 { label="MicroBatchScan"; 5418 [labelType="html" label="DataSourceRDD [5418] run at <unknown>:0"]; 5419 [labelType="html" label="MapPartitionsRDD [5419] run at <unknown>:0"]; } subgraph cluster12130 { label="Project"; 5420 [labelType="html" label="MapPartitionsRDD [5420] run at <unknown>:0"]; } subgraph cluster12126 { label="WholeStageCodegen (1)"; 5421 [labelType="html" label="MapPartitionsRDD [5421] run at <unknown>:0"]; } subgraph cluster12140 { label="WholeStageCodegen (1)"; 5423 [labelType="html" label="MapPartitionsRDD [5423] toJavaRDD at <unknown>:0"]; } subgraph cluster12139 { label="Filter"; 5424 [labelType="html" label="MapPartitionsRDD [5424] toJavaRDD at <unknown>:0"]; } subgraph cluster12138 { label="Project"; 5425 [labelType="html" label="MapPartitionsRDD [5425] toJavaRDD at <unknown>:0"]; } subgraph cluster12135 { label="WholeStageCodegen (2)"; 5426 [labelType="html" label="MapPartitionsRDD [5426] toJavaRDD at <unknown>:0"]; } subgraph cluster12134 { label="Project"; 5427 [labelType="html" label="MapPartitionsRDD [5427] toJavaRDD at <unknown>:0"]; } subgraph cluster12133 { label="DeserializeToObject"; 5428 [labelType="html" label="MapPartitionsRDD [5428] toJavaRDD at <unknown>:0"]; } subgraph cluster12132 { label="MapPartitions"; 5429 [labelType="html" label="MapPartitionsRDD [5429] toJavaRDD at <unknown>:0"]; } subgraph cluster12142 { label="mapPartitions"; 5431 [labelType="html" label="MapPartitionsRDD [5431] toJavaRDD at <unknown>:0"]; } } 5418->5419; 5419->5420; 5420->5421; 5421->5422; 5422->5423; 5423->5424; 5424->5425; 5425->5426; 5426->5427; 5427->5428; 5428->5429; 5429->5430; 5430->5431; 5431->5432; }

Event Timeline

Enable zooming