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

digraph G { subgraph clusterstage_1058 { label="Stage 1058"; 11120 [labelType="html" label="SQLExecutionRDD [11120] run at <unknown>:0"]; 11128 [labelType="html" label="SQLExecutionRDD [11128] toJavaRDD at <unknown>:0"]; 11130 [labelType="html" label="PythonRDD [11130] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24872 { label="MicroBatchScan"; 11116 [labelType="html" label="DataSourceRDD [11116] run at <unknown>:0"]; 11117 [labelType="html" label="MapPartitionsRDD [11117] run at <unknown>:0"]; } subgraph cluster24871 { label="Project"; 11118 [labelType="html" label="MapPartitionsRDD [11118] run at <unknown>:0"]; } subgraph cluster24867 { label="WholeStageCodegen (1)"; 11119 [labelType="html" label="MapPartitionsRDD [11119] run at <unknown>:0"]; } subgraph cluster24881 { label="WholeStageCodegen (1)"; 11121 [labelType="html" label="MapPartitionsRDD [11121] toJavaRDD at <unknown>:0"]; } subgraph cluster24880 { label="Filter"; 11122 [labelType="html" label="MapPartitionsRDD [11122] toJavaRDD at <unknown>:0"]; } subgraph cluster24879 { label="Project"; 11123 [labelType="html" label="MapPartitionsRDD [11123] toJavaRDD at <unknown>:0"]; } subgraph cluster24876 { label="WholeStageCodegen (2)"; 11124 [labelType="html" label="MapPartitionsRDD [11124] toJavaRDD at <unknown>:0"]; } subgraph cluster24875 { label="Project"; 11125 [labelType="html" label="MapPartitionsRDD [11125] toJavaRDD at <unknown>:0"]; } subgraph cluster24874 { label="DeserializeToObject"; 11126 [labelType="html" label="MapPartitionsRDD [11126] toJavaRDD at <unknown>:0"]; } subgraph cluster24873 { label="MapPartitions"; 11127 [labelType="html" label="MapPartitionsRDD [11127] toJavaRDD at <unknown>:0"]; } subgraph cluster24883 { label="mapPartitions"; 11129 [labelType="html" label="MapPartitionsRDD [11129] toJavaRDD at <unknown>:0"]; } } 11116->11117; 11117->11118; 11118->11119; 11119->11120; 11120->11121; 11121->11122; 11122->11123; 11123->11124; 11124->11125; 11125->11126; 11126->11127; 11127->11128; 11128->11129; 11129->11130; }

Event Timeline

Enable zooming