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

digraph G { subgraph clusterstage_653 { label="Stage 653"; 6872 [labelType="html" label="SQLExecutionRDD [6872] run at <unknown>:0"]; 6880 [labelType="html" label="SQLExecutionRDD [6880] toJavaRDD at <unknown>:0"]; 6882 [labelType="html" label="PythonRDD [6882] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster15370 { label="MicroBatchScan"; 6868 [labelType="html" label="DataSourceRDD [6868] run at <unknown>:0"]; 6869 [labelType="html" label="MapPartitionsRDD [6869] run at <unknown>:0"]; } subgraph cluster15369 { label="Project"; 6870 [labelType="html" label="MapPartitionsRDD [6870] run at <unknown>:0"]; } subgraph cluster15365 { label="WholeStageCodegen (1)"; 6871 [labelType="html" label="MapPartitionsRDD [6871] run at <unknown>:0"]; } subgraph cluster15379 { label="WholeStageCodegen (1)"; 6873 [labelType="html" label="MapPartitionsRDD [6873] toJavaRDD at <unknown>:0"]; } subgraph cluster15378 { label="Filter"; 6874 [labelType="html" label="MapPartitionsRDD [6874] toJavaRDD at <unknown>:0"]; } subgraph cluster15377 { label="Project"; 6875 [labelType="html" label="MapPartitionsRDD [6875] toJavaRDD at <unknown>:0"]; } subgraph cluster15374 { label="WholeStageCodegen (2)"; 6876 [labelType="html" label="MapPartitionsRDD [6876] toJavaRDD at <unknown>:0"]; } subgraph cluster15373 { label="Project"; 6877 [labelType="html" label="MapPartitionsRDD [6877] toJavaRDD at <unknown>:0"]; } subgraph cluster15372 { label="DeserializeToObject"; 6878 [labelType="html" label="MapPartitionsRDD [6878] toJavaRDD at <unknown>:0"]; } subgraph cluster15371 { label="MapPartitions"; 6879 [labelType="html" label="MapPartitionsRDD [6879] toJavaRDD at <unknown>:0"]; } subgraph cluster15381 { label="mapPartitions"; 6881 [labelType="html" label="MapPartitionsRDD [6881] toJavaRDD at <unknown>:0"]; } } 6868->6869; 6869->6870; 6870->6871; 6871->6872; 6872->6873; 6873->6874; 6874->6875; 6875->6876; 6876->6877; 6877->6878; 6878->6879; 6879->6880; 6880->6881; 6881->6882; }

Event Timeline

Enable zooming