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

digraph G { subgraph clusterstage_137 { label="Stage 137"; 1438 [labelType="html" label="SQLExecutionRDD [1438] run at <unknown>:0"]; 1446 [labelType="html" label="SQLExecutionRDD [1446] toJavaRDD at <unknown>:0"]; 1448 [labelType="html" label="PythonRDD [1448] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster3209 { label="MicroBatchScan"; 1434 [labelType="html" label="DataSourceRDD [1434] run at <unknown>:0"]; 1435 [labelType="html" label="MapPartitionsRDD [1435] run at <unknown>:0"]; } subgraph cluster3208 { label="Project"; 1436 [labelType="html" label="MapPartitionsRDD [1436] run at <unknown>:0"]; } subgraph cluster3204 { label="WholeStageCodegen (1)"; 1437 [labelType="html" label="MapPartitionsRDD [1437] run at <unknown>:0"]; } subgraph cluster3218 { label="WholeStageCodegen (1)"; 1439 [labelType="html" label="MapPartitionsRDD [1439] toJavaRDD at <unknown>:0"]; } subgraph cluster3217 { label="Filter"; 1440 [labelType="html" label="MapPartitionsRDD [1440] toJavaRDD at <unknown>:0"]; } subgraph cluster3216 { label="Project"; 1441 [labelType="html" label="MapPartitionsRDD [1441] toJavaRDD at <unknown>:0"]; } subgraph cluster3213 { label="WholeStageCodegen (2)"; 1442 [labelType="html" label="MapPartitionsRDD [1442] toJavaRDD at <unknown>:0"]; } subgraph cluster3212 { label="Project"; 1443 [labelType="html" label="MapPartitionsRDD [1443] toJavaRDD at <unknown>:0"]; } subgraph cluster3211 { label="DeserializeToObject"; 1444 [labelType="html" label="MapPartitionsRDD [1444] toJavaRDD at <unknown>:0"]; } subgraph cluster3210 { label="MapPartitions"; 1445 [labelType="html" label="MapPartitionsRDD [1445] toJavaRDD at <unknown>:0"]; } subgraph cluster3220 { label="mapPartitions"; 1447 [labelType="html" label="MapPartitionsRDD [1447] toJavaRDD at <unknown>:0"]; } } 1434->1435; 1435->1436; 1436->1437; 1437->1438; 1438->1439; 1439->1440; 1440->1441; 1441->1442; 1442->1443; 1443->1444; 1444->1445; 1445->1446; 1446->1447; 1447->1448; }

Event Timeline

Enable zooming