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

digraph G { subgraph clusterstage_633 { label="Stage 633"; 6662 [labelType="html" label="SQLExecutionRDD [6662] run at <unknown>:0"]; 6670 [labelType="html" label="SQLExecutionRDD [6670] toJavaRDD at <unknown>:0"]; 6672 [labelType="html" label="PythonRDD [6672] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster14900 { label="MicroBatchScan"; 6658 [labelType="html" label="DataSourceRDD [6658] run at <unknown>:0"]; 6659 [labelType="html" label="MapPartitionsRDD [6659] run at <unknown>:0"]; } subgraph cluster14899 { label="Project"; 6660 [labelType="html" label="MapPartitionsRDD [6660] run at <unknown>:0"]; } subgraph cluster14895 { label="WholeStageCodegen (1)"; 6661 [labelType="html" label="MapPartitionsRDD [6661] run at <unknown>:0"]; } subgraph cluster14909 { label="WholeStageCodegen (1)"; 6663 [labelType="html" label="MapPartitionsRDD [6663] toJavaRDD at <unknown>:0"]; } subgraph cluster14908 { label="Filter"; 6664 [labelType="html" label="MapPartitionsRDD [6664] toJavaRDD at <unknown>:0"]; } subgraph cluster14907 { label="Project"; 6665 [labelType="html" label="MapPartitionsRDD [6665] toJavaRDD at <unknown>:0"]; } subgraph cluster14904 { label="WholeStageCodegen (2)"; 6666 [labelType="html" label="MapPartitionsRDD [6666] toJavaRDD at <unknown>:0"]; } subgraph cluster14903 { label="Project"; 6667 [labelType="html" label="MapPartitionsRDD [6667] toJavaRDD at <unknown>:0"]; } subgraph cluster14902 { label="DeserializeToObject"; 6668 [labelType="html" label="MapPartitionsRDD [6668] toJavaRDD at <unknown>:0"]; } subgraph cluster14901 { label="MapPartitions"; 6669 [labelType="html" label="MapPartitionsRDD [6669] toJavaRDD at <unknown>:0"]; } subgraph cluster14911 { label="mapPartitions"; 6671 [labelType="html" label="MapPartitionsRDD [6671] toJavaRDD at <unknown>:0"]; } } 6658->6659; 6659->6660; 6660->6661; 6661->6662; 6662->6663; 6663->6664; 6664->6665; 6665->6666; 6666->6667; 6667->6668; 6668->6669; 6669->6670; 6670->6671; 6671->6672; }

Event Timeline

Enable zooming