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

digraph G { subgraph clusterstage_1597 { label="Stage 1597"; 16784 [labelType="html" label="SQLExecutionRDD [16784] run at <unknown>:0"]; 16792 [labelType="html" label="SQLExecutionRDD [16792] toJavaRDD at <unknown>:0"]; 16794 [labelType="html" label="PythonRDD [16794] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37554 { label="MicroBatchScan"; 16780 [labelType="html" label="DataSourceRDD [16780] run at <unknown>:0"]; 16781 [labelType="html" label="MapPartitionsRDD [16781] run at <unknown>:0"]; } subgraph cluster37553 { label="Project"; 16782 [labelType="html" label="MapPartitionsRDD [16782] run at <unknown>:0"]; } subgraph cluster37549 { label="WholeStageCodegen (1)"; 16783 [labelType="html" label="MapPartitionsRDD [16783] run at <unknown>:0"]; } subgraph cluster37563 { label="WholeStageCodegen (1)"; 16785 [labelType="html" label="MapPartitionsRDD [16785] toJavaRDD at <unknown>:0"]; } subgraph cluster37562 { label="Filter"; 16786 [labelType="html" label="MapPartitionsRDD [16786] toJavaRDD at <unknown>:0"]; } subgraph cluster37561 { label="Project"; 16787 [labelType="html" label="MapPartitionsRDD [16787] toJavaRDD at <unknown>:0"]; } subgraph cluster37558 { label="WholeStageCodegen (2)"; 16788 [labelType="html" label="MapPartitionsRDD [16788] toJavaRDD at <unknown>:0"]; } subgraph cluster37557 { label="Project"; 16789 [labelType="html" label="MapPartitionsRDD [16789] toJavaRDD at <unknown>:0"]; } subgraph cluster37556 { label="DeserializeToObject"; 16790 [labelType="html" label="MapPartitionsRDD [16790] toJavaRDD at <unknown>:0"]; } subgraph cluster37555 { label="MapPartitions"; 16791 [labelType="html" label="MapPartitionsRDD [16791] toJavaRDD at <unknown>:0"]; } subgraph cluster37565 { label="mapPartitions"; 16793 [labelType="html" label="MapPartitionsRDD [16793] toJavaRDD at <unknown>:0"]; } } 16780->16781; 16781->16782; 16782->16783; 16783->16784; 16784->16785; 16785->16786; 16786->16787; 16787->16788; 16788->16789; 16789->16790; 16790->16791; 16791->16792; 16792->16793; 16793->16794; }

Event Timeline

Enable zooming