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

digraph G { subgraph clusterstage_921 { label="Stage 921"; 9686 [labelType="html" label="SQLExecutionRDD [9686] run at <unknown>:0"]; 9694 [labelType="html" label="SQLExecutionRDD [9694] toJavaRDD at <unknown>:0"]; 9696 [labelType="html" label="PythonRDD [9696] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster21668 { label="MicroBatchScan"; 9682 [labelType="html" label="DataSourceRDD [9682] run at <unknown>:0"]; 9683 [labelType="html" label="MapPartitionsRDD [9683] run at <unknown>:0"]; } subgraph cluster21667 { label="Project"; 9684 [labelType="html" label="MapPartitionsRDD [9684] run at <unknown>:0"]; } subgraph cluster21663 { label="WholeStageCodegen (1)"; 9685 [labelType="html" label="MapPartitionsRDD [9685] run at <unknown>:0"]; } subgraph cluster21677 { label="WholeStageCodegen (1)"; 9687 [labelType="html" label="MapPartitionsRDD [9687] toJavaRDD at <unknown>:0"]; } subgraph cluster21676 { label="Filter"; 9688 [labelType="html" label="MapPartitionsRDD [9688] toJavaRDD at <unknown>:0"]; } subgraph cluster21675 { label="Project"; 9689 [labelType="html" label="MapPartitionsRDD [9689] toJavaRDD at <unknown>:0"]; } subgraph cluster21672 { label="WholeStageCodegen (2)"; 9690 [labelType="html" label="MapPartitionsRDD [9690] toJavaRDD at <unknown>:0"]; } subgraph cluster21671 { label="Project"; 9691 [labelType="html" label="MapPartitionsRDD [9691] toJavaRDD at <unknown>:0"]; } subgraph cluster21670 { label="DeserializeToObject"; 9692 [labelType="html" label="MapPartitionsRDD [9692] toJavaRDD at <unknown>:0"]; } subgraph cluster21669 { label="MapPartitions"; 9693 [labelType="html" label="MapPartitionsRDD [9693] toJavaRDD at <unknown>:0"]; } subgraph cluster21679 { label="mapPartitions"; 9695 [labelType="html" label="MapPartitionsRDD [9695] toJavaRDD at <unknown>:0"]; } } 9682->9683; 9683->9684; 9684->9685; 9685->9686; 9686->9687; 9687->9688; 9688->9689; 9689->9690; 9690->9691; 9691->9692; 9692->9693; 9693->9694; 9694->9695; 9695->9696; }

Event Timeline

Enable zooming