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

digraph G { subgraph clusterstage_746 { label="Stage 746"; 7837 [labelType="html" label="SQLExecutionRDD [7837] run at <unknown>:0"]; 7845 [labelType="html" label="SQLExecutionRDD [7845] toJavaRDD at <unknown>:0"]; 7847 [labelType="html" label="PythonRDD [7847] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster17536 { label="MicroBatchScan"; 7833 [labelType="html" label="DataSourceRDD [7833] run at <unknown>:0"]; 7834 [labelType="html" label="MapPartitionsRDD [7834] run at <unknown>:0"]; } subgraph cluster17535 { label="Project"; 7835 [labelType="html" label="MapPartitionsRDD [7835] run at <unknown>:0"]; } subgraph cluster17531 { label="WholeStageCodegen (1)"; 7836 [labelType="html" label="MapPartitionsRDD [7836] run at <unknown>:0"]; } subgraph cluster17545 { label="WholeStageCodegen (1)"; 7838 [labelType="html" label="MapPartitionsRDD [7838] toJavaRDD at <unknown>:0"]; } subgraph cluster17544 { label="Filter"; 7839 [labelType="html" label="MapPartitionsRDD [7839] toJavaRDD at <unknown>:0"]; } subgraph cluster17543 { label="Project"; 7840 [labelType="html" label="MapPartitionsRDD [7840] toJavaRDD at <unknown>:0"]; } subgraph cluster17540 { label="WholeStageCodegen (2)"; 7841 [labelType="html" label="MapPartitionsRDD [7841] toJavaRDD at <unknown>:0"]; } subgraph cluster17539 { label="Project"; 7842 [labelType="html" label="MapPartitionsRDD [7842] toJavaRDD at <unknown>:0"]; } subgraph cluster17538 { label="DeserializeToObject"; 7843 [labelType="html" label="MapPartitionsRDD [7843] toJavaRDD at <unknown>:0"]; } subgraph cluster17537 { label="MapPartitions"; 7844 [labelType="html" label="MapPartitionsRDD [7844] toJavaRDD at <unknown>:0"]; } subgraph cluster17547 { label="mapPartitions"; 7846 [labelType="html" label="MapPartitionsRDD [7846] toJavaRDD at <unknown>:0"]; } } 7833->7834; 7834->7835; 7835->7836; 7836->7837; 7837->7838; 7838->7839; 7839->7840; 7840->7841; 7841->7842; 7842->7843; 7843->7844; 7844->7845; 7845->7846; 7846->7847; }

Event Timeline

Enable zooming