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

digraph G { subgraph clusterstage_376 { label="Stage 376"; 3952 [labelType="html" label="SQLExecutionRDD [3952] run at <unknown>:0"]; 3960 [labelType="html" label="SQLExecutionRDD [3960] toJavaRDD at <unknown>:0"]; 3962 [labelType="html" label="PythonRDD [3962] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster8841 { label="MicroBatchScan"; 3948 [labelType="html" label="DataSourceRDD [3948] run at <unknown>:0"]; 3949 [labelType="html" label="MapPartitionsRDD [3949] run at <unknown>:0"]; } subgraph cluster8840 { label="Project"; 3950 [labelType="html" label="MapPartitionsRDD [3950] run at <unknown>:0"]; } subgraph cluster8836 { label="WholeStageCodegen (1)"; 3951 [labelType="html" label="MapPartitionsRDD [3951] run at <unknown>:0"]; } subgraph cluster8850 { label="WholeStageCodegen (1)"; 3953 [labelType="html" label="MapPartitionsRDD [3953] toJavaRDD at <unknown>:0"]; } subgraph cluster8849 { label="Filter"; 3954 [labelType="html" label="MapPartitionsRDD [3954] toJavaRDD at <unknown>:0"]; } subgraph cluster8848 { label="Project"; 3955 [labelType="html" label="MapPartitionsRDD [3955] toJavaRDD at <unknown>:0"]; } subgraph cluster8845 { label="WholeStageCodegen (2)"; 3956 [labelType="html" label="MapPartitionsRDD [3956] toJavaRDD at <unknown>:0"]; } subgraph cluster8844 { label="Project"; 3957 [labelType="html" label="MapPartitionsRDD [3957] toJavaRDD at <unknown>:0"]; } subgraph cluster8843 { label="DeserializeToObject"; 3958 [labelType="html" label="MapPartitionsRDD [3958] toJavaRDD at <unknown>:0"]; } subgraph cluster8842 { label="MapPartitions"; 3959 [labelType="html" label="MapPartitionsRDD [3959] toJavaRDD at <unknown>:0"]; } subgraph cluster8852 { label="mapPartitions"; 3961 [labelType="html" label="MapPartitionsRDD [3961] toJavaRDD at <unknown>:0"]; } } 3948->3949; 3949->3950; 3950->3951; 3951->3952; 3952->3953; 3953->3954; 3954->3955; 3955->3956; 3956->3957; 3957->3958; 3958->3959; 3959->3960; 3960->3961; 3961->3962; }

Event Timeline

Enable zooming