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

digraph G { subgraph clusterstage_1275 { label="Stage 1275"; 13381 [labelType="html" label="SQLExecutionRDD [13381] run at <unknown>:0"]; 13395 [labelType="html" label="SQLExecutionRDD [13395] toJavaRDD at <unknown>:0"]; 13397 [labelType="html" label="PythonRDD [13397] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29944 { label="MicroBatchScan"; 13377 [labelType="html" label="DataSourceRDD [13377] run at <unknown>:0"]; 13378 [labelType="html" label="MapPartitionsRDD [13378] run at <unknown>:0"]; } subgraph cluster29943 { label="Project"; 13379 [labelType="html" label="MapPartitionsRDD [13379] run at <unknown>:0"]; } subgraph cluster29939 { label="WholeStageCodegen (1)"; 13380 [labelType="html" label="MapPartitionsRDD [13380] run at <unknown>:0"]; } subgraph cluster29961 { label="WholeStageCodegen (1)"; 13388 [labelType="html" label="MapPartitionsRDD [13388] toJavaRDD at <unknown>:0"]; } subgraph cluster29960 { label="Filter"; 13389 [labelType="html" label="MapPartitionsRDD [13389] toJavaRDD at <unknown>:0"]; } subgraph cluster29959 { label="Project"; 13390 [labelType="html" label="MapPartitionsRDD [13390] toJavaRDD at <unknown>:0"]; } subgraph cluster29956 { label="WholeStageCodegen (2)"; 13391 [labelType="html" label="MapPartitionsRDD [13391] toJavaRDD at <unknown>:0"]; } subgraph cluster29955 { label="Project"; 13392 [labelType="html" label="MapPartitionsRDD [13392] toJavaRDD at <unknown>:0"]; } subgraph cluster29954 { label="DeserializeToObject"; 13393 [labelType="html" label="MapPartitionsRDD [13393] toJavaRDD at <unknown>:0"]; } subgraph cluster29953 { label="MapPartitions"; 13394 [labelType="html" label="MapPartitionsRDD [13394] toJavaRDD at <unknown>:0"]; } subgraph cluster29963 { label="mapPartitions"; 13396 [labelType="html" label="MapPartitionsRDD [13396] toJavaRDD at <unknown>:0"]; } } 13377->13378; 13378->13379; 13379->13380; 13380->13381; 13381->13388; 13388->13389; 13389->13390; 13390->13391; 13391->13392; 13392->13393; 13393->13394; 13394->13395; 13395->13396; 13396->13397; }

Event Timeline

Enable zooming