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

digraph G { subgraph clusterstage_931 { label="Stage 931"; 9791 [labelType="html" label="SQLExecutionRDD [9791] run at <unknown>:0"]; 9799 [labelType="html" label="SQLExecutionRDD [9799] toJavaRDD at <unknown>:0"]; 9801 [labelType="html" label="PythonRDD [9801] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster21903 { label="MicroBatchScan"; 9787 [labelType="html" label="DataSourceRDD [9787] run at <unknown>:0"]; 9788 [labelType="html" label="MapPartitionsRDD [9788] run at <unknown>:0"]; } subgraph cluster21902 { label="Project"; 9789 [labelType="html" label="MapPartitionsRDD [9789] run at <unknown>:0"]; } subgraph cluster21898 { label="WholeStageCodegen (1)"; 9790 [labelType="html" label="MapPartitionsRDD [9790] run at <unknown>:0"]; } subgraph cluster21912 { label="WholeStageCodegen (1)"; 9792 [labelType="html" label="MapPartitionsRDD [9792] toJavaRDD at <unknown>:0"]; } subgraph cluster21911 { label="Filter"; 9793 [labelType="html" label="MapPartitionsRDD [9793] toJavaRDD at <unknown>:0"]; } subgraph cluster21910 { label="Project"; 9794 [labelType="html" label="MapPartitionsRDD [9794] toJavaRDD at <unknown>:0"]; } subgraph cluster21907 { label="WholeStageCodegen (2)"; 9795 [labelType="html" label="MapPartitionsRDD [9795] toJavaRDD at <unknown>:0"]; } subgraph cluster21906 { label="Project"; 9796 [labelType="html" label="MapPartitionsRDD [9796] toJavaRDD at <unknown>:0"]; } subgraph cluster21905 { label="DeserializeToObject"; 9797 [labelType="html" label="MapPartitionsRDD [9797] toJavaRDD at <unknown>:0"]; } subgraph cluster21904 { label="MapPartitions"; 9798 [labelType="html" label="MapPartitionsRDD [9798] toJavaRDD at <unknown>:0"]; } subgraph cluster21914 { label="mapPartitions"; 9800 [labelType="html" label="MapPartitionsRDD [9800] toJavaRDD at <unknown>:0"]; } } 9787->9788; 9788->9789; 9789->9790; 9790->9791; 9791->9792; 9792->9793; 9793->9794; 9794->9795; 9795->9796; 9796->9797; 9797->9798; 9798->9799; 9799->9800; 9800->9801; }

Event Timeline

Enable zooming