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

digraph G { subgraph clusterstage_1955 { label="Stage 1955"; 20543 [labelType="html" label="SQLExecutionRDD [20543] run at <unknown>:0"]; 20551 [labelType="html" label="SQLExecutionRDD [20551] toJavaRDD at <unknown>:0"]; 20553 [labelType="html" label="PythonRDD [20553] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster45967 { label="MicroBatchScan"; 20539 [labelType="html" label="DataSourceRDD [20539] run at <unknown>:0"]; 20540 [labelType="html" label="MapPartitionsRDD [20540] run at <unknown>:0"]; } subgraph cluster45966 { label="Project"; 20541 [labelType="html" label="MapPartitionsRDD [20541] run at <unknown>:0"]; } subgraph cluster45962 { label="WholeStageCodegen (1)"; 20542 [labelType="html" label="MapPartitionsRDD [20542] run at <unknown>:0"]; } subgraph cluster45976 { label="WholeStageCodegen (1)"; 20544 [labelType="html" label="MapPartitionsRDD [20544] toJavaRDD at <unknown>:0"]; } subgraph cluster45975 { label="Filter"; 20545 [labelType="html" label="MapPartitionsRDD [20545] toJavaRDD at <unknown>:0"]; } subgraph cluster45974 { label="Project"; 20546 [labelType="html" label="MapPartitionsRDD [20546] toJavaRDD at <unknown>:0"]; } subgraph cluster45971 { label="WholeStageCodegen (2)"; 20547 [labelType="html" label="MapPartitionsRDD [20547] toJavaRDD at <unknown>:0"]; } subgraph cluster45970 { label="Project"; 20548 [labelType="html" label="MapPartitionsRDD [20548] toJavaRDD at <unknown>:0"]; } subgraph cluster45969 { label="DeserializeToObject"; 20549 [labelType="html" label="MapPartitionsRDD [20549] toJavaRDD at <unknown>:0"]; } subgraph cluster45968 { label="MapPartitions"; 20550 [labelType="html" label="MapPartitionsRDD [20550] toJavaRDD at <unknown>:0"]; } subgraph cluster45978 { label="mapPartitions"; 20552 [labelType="html" label="MapPartitionsRDD [20552] toJavaRDD at <unknown>:0"]; } } 20539->20540; 20540->20541; 20541->20542; 20542->20543; 20543->20544; 20544->20545; 20545->20546; 20546->20547; 20547->20548; 20548->20549; 20549->20550; 20550->20551; 20551->20552; 20552->20553; }

Event Timeline

Enable zooming