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

digraph G { subgraph clusterstage_676 { label="Stage 676"; 7102 [labelType="html" label="SQLExecutionRDD [7102] run at <unknown>:0"]; 7110 [labelType="html" label="SQLExecutionRDD [7110] toJavaRDD at <unknown>:0"]; 7112 [labelType="html" label="PythonRDD [7112] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster15891 { label="MicroBatchScan"; 7098 [labelType="html" label="DataSourceRDD [7098] run at <unknown>:0"]; 7099 [labelType="html" label="MapPartitionsRDD [7099] run at <unknown>:0"]; } subgraph cluster15890 { label="Project"; 7100 [labelType="html" label="MapPartitionsRDD [7100] run at <unknown>:0"]; } subgraph cluster15886 { label="WholeStageCodegen (1)"; 7101 [labelType="html" label="MapPartitionsRDD [7101] run at <unknown>:0"]; } subgraph cluster15900 { label="WholeStageCodegen (1)"; 7103 [labelType="html" label="MapPartitionsRDD [7103] toJavaRDD at <unknown>:0"]; } subgraph cluster15899 { label="Filter"; 7104 [labelType="html" label="MapPartitionsRDD [7104] toJavaRDD at <unknown>:0"]; } subgraph cluster15898 { label="Project"; 7105 [labelType="html" label="MapPartitionsRDD [7105] toJavaRDD at <unknown>:0"]; } subgraph cluster15895 { label="WholeStageCodegen (2)"; 7106 [labelType="html" label="MapPartitionsRDD [7106] toJavaRDD at <unknown>:0"]; } subgraph cluster15894 { label="Project"; 7107 [labelType="html" label="MapPartitionsRDD [7107] toJavaRDD at <unknown>:0"]; } subgraph cluster15893 { label="DeserializeToObject"; 7108 [labelType="html" label="MapPartitionsRDD [7108] toJavaRDD at <unknown>:0"]; } subgraph cluster15892 { label="MapPartitions"; 7109 [labelType="html" label="MapPartitionsRDD [7109] toJavaRDD at <unknown>:0"]; } subgraph cluster15902 { label="mapPartitions"; 7111 [labelType="html" label="MapPartitionsRDD [7111] toJavaRDD at <unknown>:0"]; } } 7098->7099; 7099->7100; 7100->7101; 7101->7102; 7102->7103; 7103->7104; 7104->7105; 7105->7106; 7106->7107; 7107->7108; 7108->7109; 7109->7110; 7110->7111; 7111->7112; }

Event Timeline

Enable zooming