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

digraph G { subgraph clusterstage_535 { label="Stage 535"; 5611 [labelType="html" label="SQLExecutionRDD [5611] run at <unknown>:0"]; 5625 [labelType="html" label="SQLExecutionRDD [5625] toJavaRDD at <unknown>:0"]; 5627 [labelType="html" label="PythonRDD [5627] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12554 { label="MicroBatchScan"; 5607 [labelType="html" label="DataSourceRDD [5607] run at <unknown>:0"]; 5608 [labelType="html" label="MapPartitionsRDD [5608] run at <unknown>:0"]; } subgraph cluster12553 { label="Project"; 5609 [labelType="html" label="MapPartitionsRDD [5609] run at <unknown>:0"]; } subgraph cluster12549 { label="WholeStageCodegen (1)"; 5610 [labelType="html" label="MapPartitionsRDD [5610] run at <unknown>:0"]; } subgraph cluster12571 { label="WholeStageCodegen (1)"; 5618 [labelType="html" label="MapPartitionsRDD [5618] toJavaRDD at <unknown>:0"]; } subgraph cluster12570 { label="Filter"; 5619 [labelType="html" label="MapPartitionsRDD [5619] toJavaRDD at <unknown>:0"]; } subgraph cluster12569 { label="Project"; 5620 [labelType="html" label="MapPartitionsRDD [5620] toJavaRDD at <unknown>:0"]; } subgraph cluster12566 { label="WholeStageCodegen (2)"; 5621 [labelType="html" label="MapPartitionsRDD [5621] toJavaRDD at <unknown>:0"]; } subgraph cluster12565 { label="Project"; 5622 [labelType="html" label="MapPartitionsRDD [5622] toJavaRDD at <unknown>:0"]; } subgraph cluster12564 { label="DeserializeToObject"; 5623 [labelType="html" label="MapPartitionsRDD [5623] toJavaRDD at <unknown>:0"]; } subgraph cluster12563 { label="MapPartitions"; 5624 [labelType="html" label="MapPartitionsRDD [5624] toJavaRDD at <unknown>:0"]; } subgraph cluster12573 { label="mapPartitions"; 5626 [labelType="html" label="MapPartitionsRDD [5626] toJavaRDD at <unknown>:0"]; } } 5607->5608; 5608->5609; 5609->5610; 5610->5611; 5611->5618; 5618->5619; 5619->5620; 5620->5621; 5621->5622; 5622->5623; 5623->5624; 5624->5625; 5625->5626; 5626->5627; }

Event Timeline

Enable zooming