processing-stream-kafka-raw-to-minio - Details for Stage 937 (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: 938

digraph G { subgraph clusterstage_937 { label="Stage 937"; 9854 [labelType="html" label="SQLExecutionRDD [9854] run at <unknown>:0"]; 9862 [labelType="html" label="SQLExecutionRDD [9862] toJavaRDD at <unknown>:0"]; 9864 [labelType="html" label="PythonRDD [9864] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22044 { label="MicroBatchScan"; 9850 [labelType="html" label="DataSourceRDD [9850] run at <unknown>:0"]; 9851 [labelType="html" label="MapPartitionsRDD [9851] run at <unknown>:0"]; } subgraph cluster22043 { label="Project"; 9852 [labelType="html" label="MapPartitionsRDD [9852] run at <unknown>:0"]; } subgraph cluster22039 { label="WholeStageCodegen (1)"; 9853 [labelType="html" label="MapPartitionsRDD [9853] run at <unknown>:0"]; } subgraph cluster22053 { label="WholeStageCodegen (1)"; 9855 [labelType="html" label="MapPartitionsRDD [9855] toJavaRDD at <unknown>:0"]; } subgraph cluster22052 { label="Filter"; 9856 [labelType="html" label="MapPartitionsRDD [9856] toJavaRDD at <unknown>:0"]; } subgraph cluster22051 { label="Project"; 9857 [labelType="html" label="MapPartitionsRDD [9857] toJavaRDD at <unknown>:0"]; } subgraph cluster22048 { label="WholeStageCodegen (2)"; 9858 [labelType="html" label="MapPartitionsRDD [9858] toJavaRDD at <unknown>:0"]; } subgraph cluster22047 { label="Project"; 9859 [labelType="html" label="MapPartitionsRDD [9859] toJavaRDD at <unknown>:0"]; } subgraph cluster22046 { label="DeserializeToObject"; 9860 [labelType="html" label="MapPartitionsRDD [9860] toJavaRDD at <unknown>:0"]; } subgraph cluster22045 { label="MapPartitions"; 9861 [labelType="html" label="MapPartitionsRDD [9861] toJavaRDD at <unknown>:0"]; } subgraph cluster22055 { label="mapPartitions"; 9863 [labelType="html" label="MapPartitionsRDD [9863] toJavaRDD at <unknown>:0"]; } } 9850->9851; 9851->9852; 9852->9853; 9853->9854; 9854->9855; 9855->9856; 9856->9857; 9857->9858; 9858->9859; 9859->9860; 9860->9861; 9861->9862; 9862->9863; 9863->9864; }

Event Timeline

Enable zooming