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

digraph G { subgraph clusterstage_340 { label="Stage 340"; 3574 [labelType="html" label="SQLExecutionRDD [3574] run at <unknown>:0"]; 3582 [labelType="html" label="SQLExecutionRDD [3582] toJavaRDD at <unknown>:0"]; 3584 [labelType="html" label="PythonRDD [3584] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster7995 { label="MicroBatchScan"; 3570 [labelType="html" label="DataSourceRDD [3570] run at <unknown>:0"]; 3571 [labelType="html" label="MapPartitionsRDD [3571] run at <unknown>:0"]; } subgraph cluster7994 { label="Project"; 3572 [labelType="html" label="MapPartitionsRDD [3572] run at <unknown>:0"]; } subgraph cluster7990 { label="WholeStageCodegen (1)"; 3573 [labelType="html" label="MapPartitionsRDD [3573] run at <unknown>:0"]; } subgraph cluster8004 { label="WholeStageCodegen (1)"; 3575 [labelType="html" label="MapPartitionsRDD [3575] toJavaRDD at <unknown>:0"]; } subgraph cluster8003 { label="Filter"; 3576 [labelType="html" label="MapPartitionsRDD [3576] toJavaRDD at <unknown>:0"]; } subgraph cluster8002 { label="Project"; 3577 [labelType="html" label="MapPartitionsRDD [3577] toJavaRDD at <unknown>:0"]; } subgraph cluster7999 { label="WholeStageCodegen (2)"; 3578 [labelType="html" label="MapPartitionsRDD [3578] toJavaRDD at <unknown>:0"]; } subgraph cluster7998 { label="Project"; 3579 [labelType="html" label="MapPartitionsRDD [3579] toJavaRDD at <unknown>:0"]; } subgraph cluster7997 { label="DeserializeToObject"; 3580 [labelType="html" label="MapPartitionsRDD [3580] toJavaRDD at <unknown>:0"]; } subgraph cluster7996 { label="MapPartitions"; 3581 [labelType="html" label="MapPartitionsRDD [3581] toJavaRDD at <unknown>:0"]; } subgraph cluster8006 { label="mapPartitions"; 3583 [labelType="html" label="MapPartitionsRDD [3583] toJavaRDD at <unknown>:0"]; } } 3570->3571; 3571->3572; 3572->3573; 3573->3574; 3574->3575; 3575->3576; 3576->3577; 3577->3578; 3578->3579; 3579->3580; 3580->3581; 3581->3582; 3582->3583; 3583->3584; }

Event Timeline

Enable zooming