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

digraph G { subgraph clusterstage_350 { label="Stage 350"; 3679 [labelType="html" label="SQLExecutionRDD [3679] run at <unknown>:0"]; 3687 [labelType="html" label="SQLExecutionRDD [3687] toJavaRDD at <unknown>:0"]; 3689 [labelType="html" label="PythonRDD [3689] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster8230 { label="MicroBatchScan"; 3675 [labelType="html" label="DataSourceRDD [3675] run at <unknown>:0"]; 3676 [labelType="html" label="MapPartitionsRDD [3676] run at <unknown>:0"]; } subgraph cluster8229 { label="Project"; 3677 [labelType="html" label="MapPartitionsRDD [3677] run at <unknown>:0"]; } subgraph cluster8225 { label="WholeStageCodegen (1)"; 3678 [labelType="html" label="MapPartitionsRDD [3678] run at <unknown>:0"]; } subgraph cluster8239 { label="WholeStageCodegen (1)"; 3680 [labelType="html" label="MapPartitionsRDD [3680] toJavaRDD at <unknown>:0"]; } subgraph cluster8238 { label="Filter"; 3681 [labelType="html" label="MapPartitionsRDD [3681] toJavaRDD at <unknown>:0"]; } subgraph cluster8237 { label="Project"; 3682 [labelType="html" label="MapPartitionsRDD [3682] toJavaRDD at <unknown>:0"]; } subgraph cluster8234 { label="WholeStageCodegen (2)"; 3683 [labelType="html" label="MapPartitionsRDD [3683] toJavaRDD at <unknown>:0"]; } subgraph cluster8233 { label="Project"; 3684 [labelType="html" label="MapPartitionsRDD [3684] toJavaRDD at <unknown>:0"]; } subgraph cluster8232 { label="DeserializeToObject"; 3685 [labelType="html" label="MapPartitionsRDD [3685] toJavaRDD at <unknown>:0"]; } subgraph cluster8231 { label="MapPartitions"; 3686 [labelType="html" label="MapPartitionsRDD [3686] toJavaRDD at <unknown>:0"]; } subgraph cluster8241 { label="mapPartitions"; 3688 [labelType="html" label="MapPartitionsRDD [3688] toJavaRDD at <unknown>:0"]; } } 3675->3676; 3676->3677; 3677->3678; 3678->3679; 3679->3680; 3680->3681; 3681->3682; 3682->3683; 3683->3684; 3684->3685; 3685->3686; 3686->3687; 3687->3688; 3688->3689; }

Event Timeline

Enable zooming