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

digraph G { subgraph clusterstage_1013 { label="Stage 1013"; 10652 [labelType="html" label="SQLExecutionRDD [10652] run at <unknown>:0"]; 10660 [labelType="html" label="SQLExecutionRDD [10660] toJavaRDD at <unknown>:0"]; 10662 [labelType="html" label="PythonRDD [10662] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23830 { label="MicroBatchScan"; 10648 [labelType="html" label="DataSourceRDD [10648] run at <unknown>:0"]; 10649 [labelType="html" label="MapPartitionsRDD [10649] run at <unknown>:0"]; } subgraph cluster23829 { label="Project"; 10650 [labelType="html" label="MapPartitionsRDD [10650] run at <unknown>:0"]; } subgraph cluster23825 { label="WholeStageCodegen (1)"; 10651 [labelType="html" label="MapPartitionsRDD [10651] run at <unknown>:0"]; } subgraph cluster23839 { label="WholeStageCodegen (1)"; 10653 [labelType="html" label="MapPartitionsRDD [10653] toJavaRDD at <unknown>:0"]; } subgraph cluster23838 { label="Filter"; 10654 [labelType="html" label="MapPartitionsRDD [10654] toJavaRDD at <unknown>:0"]; } subgraph cluster23837 { label="Project"; 10655 [labelType="html" label="MapPartitionsRDD [10655] toJavaRDD at <unknown>:0"]; } subgraph cluster23834 { label="WholeStageCodegen (2)"; 10656 [labelType="html" label="MapPartitionsRDD [10656] toJavaRDD at <unknown>:0"]; } subgraph cluster23833 { label="Project"; 10657 [labelType="html" label="MapPartitionsRDD [10657] toJavaRDD at <unknown>:0"]; } subgraph cluster23832 { label="DeserializeToObject"; 10658 [labelType="html" label="MapPartitionsRDD [10658] toJavaRDD at <unknown>:0"]; } subgraph cluster23831 { label="MapPartitions"; 10659 [labelType="html" label="MapPartitionsRDD [10659] toJavaRDD at <unknown>:0"]; } subgraph cluster23841 { label="mapPartitions"; 10661 [labelType="html" label="MapPartitionsRDD [10661] toJavaRDD at <unknown>:0"]; } } 10648->10649; 10649->10650; 10650->10651; 10651->10652; 10652->10653; 10653->10654; 10654->10655; 10655->10656; 10656->10657; 10657->10658; 10658->10659; 10659->10660; 10660->10661; 10661->10662; }

Event Timeline

Enable zooming