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

digraph G { subgraph clusterstage_1251 { label="Stage 1251"; 13151 [labelType="html" label="SQLExecutionRDD [13151] run at <unknown>:0"]; 13159 [labelType="html" label="SQLExecutionRDD [13159] toJavaRDD at <unknown>:0"]; 13161 [labelType="html" label="PythonRDD [13161] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29423 { label="MicroBatchScan"; 13147 [labelType="html" label="DataSourceRDD [13147] run at <unknown>:0"]; 13148 [labelType="html" label="MapPartitionsRDD [13148] run at <unknown>:0"]; } subgraph cluster29422 { label="Project"; 13149 [labelType="html" label="MapPartitionsRDD [13149] run at <unknown>:0"]; } subgraph cluster29418 { label="WholeStageCodegen (1)"; 13150 [labelType="html" label="MapPartitionsRDD [13150] run at <unknown>:0"]; } subgraph cluster29432 { label="WholeStageCodegen (1)"; 13152 [labelType="html" label="MapPartitionsRDD [13152] toJavaRDD at <unknown>:0"]; } subgraph cluster29431 { label="Filter"; 13153 [labelType="html" label="MapPartitionsRDD [13153] toJavaRDD at <unknown>:0"]; } subgraph cluster29430 { label="Project"; 13154 [labelType="html" label="MapPartitionsRDD [13154] toJavaRDD at <unknown>:0"]; } subgraph cluster29427 { label="WholeStageCodegen (2)"; 13155 [labelType="html" label="MapPartitionsRDD [13155] toJavaRDD at <unknown>:0"]; } subgraph cluster29426 { label="Project"; 13156 [labelType="html" label="MapPartitionsRDD [13156] toJavaRDD at <unknown>:0"]; } subgraph cluster29425 { label="DeserializeToObject"; 13157 [labelType="html" label="MapPartitionsRDD [13157] toJavaRDD at <unknown>:0"]; } subgraph cluster29424 { label="MapPartitions"; 13158 [labelType="html" label="MapPartitionsRDD [13158] toJavaRDD at <unknown>:0"]; } subgraph cluster29434 { label="mapPartitions"; 13160 [labelType="html" label="MapPartitionsRDD [13160] toJavaRDD at <unknown>:0"]; } } 13147->13148; 13148->13149; 13149->13150; 13150->13151; 13151->13152; 13152->13153; 13153->13154; 13154->13155; 13155->13156; 13156->13157; 13157->13158; 13158->13159; 13159->13160; 13160->13161; }

Event Timeline

Enable zooming