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

digraph G { subgraph clusterstage_748 { label="Stage 748"; 7858 [labelType="html" label="SQLExecutionRDD [7858] run at <unknown>:0"]; 7866 [labelType="html" label="SQLExecutionRDD [7866] toJavaRDD at <unknown>:0"]; 7868 [labelType="html" label="PythonRDD [7868] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster17583 { label="MicroBatchScan"; 7854 [labelType="html" label="DataSourceRDD [7854] run at <unknown>:0"]; 7855 [labelType="html" label="MapPartitionsRDD [7855] run at <unknown>:0"]; } subgraph cluster17582 { label="Project"; 7856 [labelType="html" label="MapPartitionsRDD [7856] run at <unknown>:0"]; } subgraph cluster17578 { label="WholeStageCodegen (1)"; 7857 [labelType="html" label="MapPartitionsRDD [7857] run at <unknown>:0"]; } subgraph cluster17592 { label="WholeStageCodegen (1)"; 7859 [labelType="html" label="MapPartitionsRDD [7859] toJavaRDD at <unknown>:0"]; } subgraph cluster17591 { label="Filter"; 7860 [labelType="html" label="MapPartitionsRDD [7860] toJavaRDD at <unknown>:0"]; } subgraph cluster17590 { label="Project"; 7861 [labelType="html" label="MapPartitionsRDD [7861] toJavaRDD at <unknown>:0"]; } subgraph cluster17587 { label="WholeStageCodegen (2)"; 7862 [labelType="html" label="MapPartitionsRDD [7862] toJavaRDD at <unknown>:0"]; } subgraph cluster17586 { label="Project"; 7863 [labelType="html" label="MapPartitionsRDD [7863] toJavaRDD at <unknown>:0"]; } subgraph cluster17585 { label="DeserializeToObject"; 7864 [labelType="html" label="MapPartitionsRDD [7864] toJavaRDD at <unknown>:0"]; } subgraph cluster17584 { label="MapPartitions"; 7865 [labelType="html" label="MapPartitionsRDD [7865] toJavaRDD at <unknown>:0"]; } subgraph cluster17594 { label="mapPartitions"; 7867 [labelType="html" label="MapPartitionsRDD [7867] toJavaRDD at <unknown>:0"]; } } 7854->7855; 7855->7856; 7856->7857; 7857->7858; 7858->7859; 7859->7860; 7860->7861; 7861->7862; 7862->7863; 7863->7864; 7864->7865; 7865->7866; 7866->7867; 7867->7868; }

Event Timeline

Enable zooming