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

digraph G { subgraph clusterstage_370 { label="Stage 370"; 3889 [labelType="html" label="SQLExecutionRDD [3889] run at <unknown>:0"]; 3897 [labelType="html" label="SQLExecutionRDD [3897] toJavaRDD at <unknown>:0"]; 3899 [labelType="html" label="PythonRDD [3899] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster8700 { label="MicroBatchScan"; 3885 [labelType="html" label="DataSourceRDD [3885] run at <unknown>:0"]; 3886 [labelType="html" label="MapPartitionsRDD [3886] run at <unknown>:0"]; } subgraph cluster8699 { label="Project"; 3887 [labelType="html" label="MapPartitionsRDD [3887] run at <unknown>:0"]; } subgraph cluster8695 { label="WholeStageCodegen (1)"; 3888 [labelType="html" label="MapPartitionsRDD [3888] run at <unknown>:0"]; } subgraph cluster8709 { label="WholeStageCodegen (1)"; 3890 [labelType="html" label="MapPartitionsRDD [3890] toJavaRDD at <unknown>:0"]; } subgraph cluster8708 { label="Filter"; 3891 [labelType="html" label="MapPartitionsRDD [3891] toJavaRDD at <unknown>:0"]; } subgraph cluster8707 { label="Project"; 3892 [labelType="html" label="MapPartitionsRDD [3892] toJavaRDD at <unknown>:0"]; } subgraph cluster8704 { label="WholeStageCodegen (2)"; 3893 [labelType="html" label="MapPartitionsRDD [3893] toJavaRDD at <unknown>:0"]; } subgraph cluster8703 { label="Project"; 3894 [labelType="html" label="MapPartitionsRDD [3894] toJavaRDD at <unknown>:0"]; } subgraph cluster8702 { label="DeserializeToObject"; 3895 [labelType="html" label="MapPartitionsRDD [3895] toJavaRDD at <unknown>:0"]; } subgraph cluster8701 { label="MapPartitions"; 3896 [labelType="html" label="MapPartitionsRDD [3896] toJavaRDD at <unknown>:0"]; } subgraph cluster8711 { label="mapPartitions"; 3898 [labelType="html" label="MapPartitionsRDD [3898] toJavaRDD at <unknown>:0"]; } } 3885->3886; 3886->3887; 3887->3888; 3888->3889; 3889->3890; 3890->3891; 3891->3892; 3892->3893; 3893->3894; 3894->3895; 3895->3896; 3896->3897; 3897->3898; 3898->3899; }

Event Timeline

Enable zooming