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

digraph G { subgraph clusterstage_936 { label="Stage 936"; 9832 [labelType="html" label="SQLExecutionRDD [9832] run at <unknown>:0"]; 9840 [labelType="html" label="SQLExecutionRDD [9840] toJavaRDD at <unknown>:0"]; 9842 [labelType="html" label="PythonRDD [9842] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22001 { label="MicroBatchScan"; 9828 [labelType="html" label="DataSourceRDD [9828] run at <unknown>:0"]; 9829 [labelType="html" label="MapPartitionsRDD [9829] run at <unknown>:0"]; } subgraph cluster22000 { label="Project"; 9830 [labelType="html" label="MapPartitionsRDD [9830] run at <unknown>:0"]; } subgraph cluster21996 { label="WholeStageCodegen (1)"; 9831 [labelType="html" label="MapPartitionsRDD [9831] run at <unknown>:0"]; } subgraph cluster22010 { label="WholeStageCodegen (1)"; 9833 [labelType="html" label="MapPartitionsRDD [9833] toJavaRDD at <unknown>:0"]; } subgraph cluster22009 { label="Filter"; 9834 [labelType="html" label="MapPartitionsRDD [9834] toJavaRDD at <unknown>:0"]; } subgraph cluster22008 { label="Project"; 9835 [labelType="html" label="MapPartitionsRDD [9835] toJavaRDD at <unknown>:0"]; } subgraph cluster22005 { label="WholeStageCodegen (2)"; 9836 [labelType="html" label="MapPartitionsRDD [9836] toJavaRDD at <unknown>:0"]; } subgraph cluster22004 { label="Project"; 9837 [labelType="html" label="MapPartitionsRDD [9837] toJavaRDD at <unknown>:0"]; } subgraph cluster22003 { label="DeserializeToObject"; 9838 [labelType="html" label="MapPartitionsRDD [9838] toJavaRDD at <unknown>:0"]; } subgraph cluster22002 { label="MapPartitions"; 9839 [labelType="html" label="MapPartitionsRDD [9839] toJavaRDD at <unknown>:0"]; } subgraph cluster22012 { label="mapPartitions"; 9841 [labelType="html" label="MapPartitionsRDD [9841] toJavaRDD at <unknown>:0"]; } } 9828->9829; 9829->9830; 9830->9831; 9831->9832; 9832->9833; 9833->9834; 9834->9835; 9835->9836; 9836->9837; 9837->9838; 9838->9839; 9839->9840; 9840->9841; 9841->9842; }

Event Timeline

Enable zooming