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

digraph G { subgraph clusterstage_1407 { label="Stage 1407"; 14789 [labelType="html" label="SQLExecutionRDD [14789] run at <unknown>:0"]; 14797 [labelType="html" label="SQLExecutionRDD [14797] toJavaRDD at <unknown>:0"]; 14799 [labelType="html" label="PythonRDD [14799] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33089 { label="MicroBatchScan"; 14785 [labelType="html" label="DataSourceRDD [14785] run at <unknown>:0"]; 14786 [labelType="html" label="MapPartitionsRDD [14786] run at <unknown>:0"]; } subgraph cluster33088 { label="Project"; 14787 [labelType="html" label="MapPartitionsRDD [14787] run at <unknown>:0"]; } subgraph cluster33084 { label="WholeStageCodegen (1)"; 14788 [labelType="html" label="MapPartitionsRDD [14788] run at <unknown>:0"]; } subgraph cluster33098 { label="WholeStageCodegen (1)"; 14790 [labelType="html" label="MapPartitionsRDD [14790] toJavaRDD at <unknown>:0"]; } subgraph cluster33097 { label="Filter"; 14791 [labelType="html" label="MapPartitionsRDD [14791] toJavaRDD at <unknown>:0"]; } subgraph cluster33096 { label="Project"; 14792 [labelType="html" label="MapPartitionsRDD [14792] toJavaRDD at <unknown>:0"]; } subgraph cluster33093 { label="WholeStageCodegen (2)"; 14793 [labelType="html" label="MapPartitionsRDD [14793] toJavaRDD at <unknown>:0"]; } subgraph cluster33092 { label="Project"; 14794 [labelType="html" label="MapPartitionsRDD [14794] toJavaRDD at <unknown>:0"]; } subgraph cluster33091 { label="DeserializeToObject"; 14795 [labelType="html" label="MapPartitionsRDD [14795] toJavaRDD at <unknown>:0"]; } subgraph cluster33090 { label="MapPartitions"; 14796 [labelType="html" label="MapPartitionsRDD [14796] toJavaRDD at <unknown>:0"]; } subgraph cluster33100 { label="mapPartitions"; 14798 [labelType="html" label="MapPartitionsRDD [14798] toJavaRDD at <unknown>:0"]; } } 14785->14786; 14786->14787; 14787->14788; 14788->14789; 14789->14790; 14790->14791; 14791->14792; 14792->14793; 14793->14794; 14794->14795; 14795->14796; 14796->14797; 14797->14798; 14798->14799; }

Event Timeline

Enable zooming