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

digraph G { subgraph clusterstage_833 { label="Stage 833"; 8740 [labelType="html" label="SQLExecutionRDD [8740] run at <unknown>:0"]; 8754 [labelType="html" label="SQLExecutionRDD [8754] toJavaRDD at <unknown>:0"]; 8756 [labelType="html" label="PythonRDD [8756] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster19557 { label="MicroBatchScan"; 8736 [labelType="html" label="DataSourceRDD [8736] run at <unknown>:0"]; 8737 [labelType="html" label="MapPartitionsRDD [8737] run at <unknown>:0"]; } subgraph cluster19556 { label="Project"; 8738 [labelType="html" label="MapPartitionsRDD [8738] run at <unknown>:0"]; } subgraph cluster19552 { label="WholeStageCodegen (1)"; 8739 [labelType="html" label="MapPartitionsRDD [8739] run at <unknown>:0"]; } subgraph cluster19574 { label="WholeStageCodegen (1)"; 8747 [labelType="html" label="MapPartitionsRDD [8747] toJavaRDD at <unknown>:0"]; } subgraph cluster19573 { label="Filter"; 8748 [labelType="html" label="MapPartitionsRDD [8748] toJavaRDD at <unknown>:0"]; } subgraph cluster19572 { label="Project"; 8749 [labelType="html" label="MapPartitionsRDD [8749] toJavaRDD at <unknown>:0"]; } subgraph cluster19569 { label="WholeStageCodegen (2)"; 8750 [labelType="html" label="MapPartitionsRDD [8750] toJavaRDD at <unknown>:0"]; } subgraph cluster19568 { label="Project"; 8751 [labelType="html" label="MapPartitionsRDD [8751] toJavaRDD at <unknown>:0"]; } subgraph cluster19567 { label="DeserializeToObject"; 8752 [labelType="html" label="MapPartitionsRDD [8752] toJavaRDD at <unknown>:0"]; } subgraph cluster19566 { label="MapPartitions"; 8753 [labelType="html" label="MapPartitionsRDD [8753] toJavaRDD at <unknown>:0"]; } subgraph cluster19576 { label="mapPartitions"; 8755 [labelType="html" label="MapPartitionsRDD [8755] toJavaRDD at <unknown>:0"]; } } 8736->8737; 8737->8738; 8738->8739; 8739->8740; 8740->8747; 8747->8748; 8748->8749; 8749->8750; 8750->8751; 8751->8752; 8752->8753; 8753->8754; 8754->8755; 8755->8756; }

Event Timeline

Enable zooming