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

digraph G { subgraph clusterstage_940 { label="Stage 940"; 9874 [labelType="html" label="SQLExecutionRDD [9874] run at <unknown>:0"]; 9882 [labelType="html" label="SQLExecutionRDD [9882] toJavaRDD at <unknown>:0"]; 9884 [labelType="html" label="PythonRDD [9884] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22095 { label="MicroBatchScan"; 9870 [labelType="html" label="DataSourceRDD [9870] run at <unknown>:0"]; 9871 [labelType="html" label="MapPartitionsRDD [9871] run at <unknown>:0"]; } subgraph cluster22094 { label="Project"; 9872 [labelType="html" label="MapPartitionsRDD [9872] run at <unknown>:0"]; } subgraph cluster22090 { label="WholeStageCodegen (1)"; 9873 [labelType="html" label="MapPartitionsRDD [9873] run at <unknown>:0"]; } subgraph cluster22104 { label="WholeStageCodegen (1)"; 9875 [labelType="html" label="MapPartitionsRDD [9875] toJavaRDD at <unknown>:0"]; } subgraph cluster22103 { label="Filter"; 9876 [labelType="html" label="MapPartitionsRDD [9876] toJavaRDD at <unknown>:0"]; } subgraph cluster22102 { label="Project"; 9877 [labelType="html" label="MapPartitionsRDD [9877] toJavaRDD at <unknown>:0"]; } subgraph cluster22099 { label="WholeStageCodegen (2)"; 9878 [labelType="html" label="MapPartitionsRDD [9878] toJavaRDD at <unknown>:0"]; } subgraph cluster22098 { label="Project"; 9879 [labelType="html" label="MapPartitionsRDD [9879] toJavaRDD at <unknown>:0"]; } subgraph cluster22097 { label="DeserializeToObject"; 9880 [labelType="html" label="MapPartitionsRDD [9880] toJavaRDD at <unknown>:0"]; } subgraph cluster22096 { label="MapPartitions"; 9881 [labelType="html" label="MapPartitionsRDD [9881] toJavaRDD at <unknown>:0"]; } subgraph cluster22106 { label="mapPartitions"; 9883 [labelType="html" label="MapPartitionsRDD [9883] toJavaRDD at <unknown>:0"]; } } 9870->9871; 9871->9872; 9872->9873; 9873->9874; 9874->9875; 9875->9876; 9876->9877; 9877->9878; 9878->9879; 9879->9880; 9880->9881; 9881->9882; 9882->9883; 9883->9884; }

Event Timeline

Enable zooming