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

digraph G { subgraph clusterstage_483 { label="Stage 483"; 5071 [labelType="html" label="SQLExecutionRDD [5071] run at <unknown>:0"]; 5079 [labelType="html" label="SQLExecutionRDD [5079] toJavaRDD at <unknown>:0"]; 5081 [labelType="html" label="PythonRDD [5081] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster11340 { label="MicroBatchScan"; 5067 [labelType="html" label="DataSourceRDD [5067] run at <unknown>:0"]; 5068 [labelType="html" label="MapPartitionsRDD [5068] run at <unknown>:0"]; } subgraph cluster11339 { label="Project"; 5069 [labelType="html" label="MapPartitionsRDD [5069] run at <unknown>:0"]; } subgraph cluster11335 { label="WholeStageCodegen (1)"; 5070 [labelType="html" label="MapPartitionsRDD [5070] run at <unknown>:0"]; } subgraph cluster11349 { label="WholeStageCodegen (1)"; 5072 [labelType="html" label="MapPartitionsRDD [5072] toJavaRDD at <unknown>:0"]; } subgraph cluster11348 { label="Filter"; 5073 [labelType="html" label="MapPartitionsRDD [5073] toJavaRDD at <unknown>:0"]; } subgraph cluster11347 { label="Project"; 5074 [labelType="html" label="MapPartitionsRDD [5074] toJavaRDD at <unknown>:0"]; } subgraph cluster11344 { label="WholeStageCodegen (2)"; 5075 [labelType="html" label="MapPartitionsRDD [5075] toJavaRDD at <unknown>:0"]; } subgraph cluster11343 { label="Project"; 5076 [labelType="html" label="MapPartitionsRDD [5076] toJavaRDD at <unknown>:0"]; } subgraph cluster11342 { label="DeserializeToObject"; 5077 [labelType="html" label="MapPartitionsRDD [5077] toJavaRDD at <unknown>:0"]; } subgraph cluster11341 { label="MapPartitions"; 5078 [labelType="html" label="MapPartitionsRDD [5078] toJavaRDD at <unknown>:0"]; } subgraph cluster11351 { label="mapPartitions"; 5080 [labelType="html" label="MapPartitionsRDD [5080] toJavaRDD at <unknown>:0"]; } } 5067->5068; 5068->5069; 5069->5070; 5070->5071; 5071->5072; 5072->5073; 5073->5074; 5074->5075; 5075->5076; 5076->5077; 5077->5078; 5078->5079; 5079->5080; 5080->5081; }

Event Timeline

Enable zooming