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

digraph G { subgraph clusterstage_148 { label="Stage 148"; 1558 [labelType="html" label="SQLExecutionRDD [1558] run at <unknown>:0"]; 1566 [labelType="html" label="SQLExecutionRDD [1566] toJavaRDD at <unknown>:0"]; 1568 [labelType="html" label="PythonRDD [1568] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster3483 { label="MicroBatchScan"; 1554 [labelType="html" label="DataSourceRDD [1554] run at <unknown>:0"]; 1555 [labelType="html" label="MapPartitionsRDD [1555] run at <unknown>:0"]; } subgraph cluster3482 { label="Project"; 1556 [labelType="html" label="MapPartitionsRDD [1556] run at <unknown>:0"]; } subgraph cluster3478 { label="WholeStageCodegen (1)"; 1557 [labelType="html" label="MapPartitionsRDD [1557] run at <unknown>:0"]; } subgraph cluster3492 { label="WholeStageCodegen (1)"; 1559 [labelType="html" label="MapPartitionsRDD [1559] toJavaRDD at <unknown>:0"]; } subgraph cluster3491 { label="Filter"; 1560 [labelType="html" label="MapPartitionsRDD [1560] toJavaRDD at <unknown>:0"]; } subgraph cluster3490 { label="Project"; 1561 [labelType="html" label="MapPartitionsRDD [1561] toJavaRDD at <unknown>:0"]; } subgraph cluster3487 { label="WholeStageCodegen (2)"; 1562 [labelType="html" label="MapPartitionsRDD [1562] toJavaRDD at <unknown>:0"]; } subgraph cluster3486 { label="Project"; 1563 [labelType="html" label="MapPartitionsRDD [1563] toJavaRDD at <unknown>:0"]; } subgraph cluster3485 { label="DeserializeToObject"; 1564 [labelType="html" label="MapPartitionsRDD [1564] toJavaRDD at <unknown>:0"]; } subgraph cluster3484 { label="MapPartitions"; 1565 [labelType="html" label="MapPartitionsRDD [1565] toJavaRDD at <unknown>:0"]; } subgraph cluster3494 { label="mapPartitions"; 1567 [labelType="html" label="MapPartitionsRDD [1567] toJavaRDD at <unknown>:0"]; } } 1554->1555; 1555->1556; 1556->1557; 1557->1558; 1558->1559; 1559->1560; 1560->1561; 1561->1562; 1562->1563; 1563->1564; 1564->1565; 1565->1566; 1566->1567; 1567->1568; }

Event Timeline

Enable zooming