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

digraph G { subgraph clusterstage_563 { label="Stage 563"; 5911 [labelType="html" label="SQLExecutionRDD [5911] run at <unknown>:0"]; 5919 [labelType="html" label="SQLExecutionRDD [5919] toJavaRDD at <unknown>:0"]; 5921 [labelType="html" label="PythonRDD [5921] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster13220 { label="MicroBatchScan"; 5907 [labelType="html" label="DataSourceRDD [5907] run at <unknown>:0"]; 5908 [labelType="html" label="MapPartitionsRDD [5908] run at <unknown>:0"]; } subgraph cluster13219 { label="Project"; 5909 [labelType="html" label="MapPartitionsRDD [5909] run at <unknown>:0"]; } subgraph cluster13215 { label="WholeStageCodegen (1)"; 5910 [labelType="html" label="MapPartitionsRDD [5910] run at <unknown>:0"]; } subgraph cluster13229 { label="WholeStageCodegen (1)"; 5912 [labelType="html" label="MapPartitionsRDD [5912] toJavaRDD at <unknown>:0"]; } subgraph cluster13228 { label="Filter"; 5913 [labelType="html" label="MapPartitionsRDD [5913] toJavaRDD at <unknown>:0"]; } subgraph cluster13227 { label="Project"; 5914 [labelType="html" label="MapPartitionsRDD [5914] toJavaRDD at <unknown>:0"]; } subgraph cluster13224 { label="WholeStageCodegen (2)"; 5915 [labelType="html" label="MapPartitionsRDD [5915] toJavaRDD at <unknown>:0"]; } subgraph cluster13223 { label="Project"; 5916 [labelType="html" label="MapPartitionsRDD [5916] toJavaRDD at <unknown>:0"]; } subgraph cluster13222 { label="DeserializeToObject"; 5917 [labelType="html" label="MapPartitionsRDD [5917] toJavaRDD at <unknown>:0"]; } subgraph cluster13221 { label="MapPartitions"; 5918 [labelType="html" label="MapPartitionsRDD [5918] toJavaRDD at <unknown>:0"]; } subgraph cluster13231 { label="mapPartitions"; 5920 [labelType="html" label="MapPartitionsRDD [5920] toJavaRDD at <unknown>:0"]; } } 5907->5908; 5908->5909; 5909->5910; 5910->5911; 5911->5912; 5912->5913; 5913->5914; 5914->5915; 5915->5916; 5916->5917; 5917->5918; 5918->5919; 5919->5920; 5920->5921; }

Event Timeline

Enable zooming