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

digraph G { subgraph clusterstage_963 { label="Stage 963"; 10127 [labelType="html" label="SQLExecutionRDD [10127] run at <unknown>:0"]; 10135 [labelType="html" label="SQLExecutionRDD [10135] toJavaRDD at <unknown>:0"]; 10137 [labelType="html" label="PythonRDD [10137] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22655 { label="MicroBatchScan"; 10123 [labelType="html" label="DataSourceRDD [10123] run at <unknown>:0"]; 10124 [labelType="html" label="MapPartitionsRDD [10124] run at <unknown>:0"]; } subgraph cluster22654 { label="Project"; 10125 [labelType="html" label="MapPartitionsRDD [10125] run at <unknown>:0"]; } subgraph cluster22650 { label="WholeStageCodegen (1)"; 10126 [labelType="html" label="MapPartitionsRDD [10126] run at <unknown>:0"]; } subgraph cluster22664 { label="WholeStageCodegen (1)"; 10128 [labelType="html" label="MapPartitionsRDD [10128] toJavaRDD at <unknown>:0"]; } subgraph cluster22663 { label="Filter"; 10129 [labelType="html" label="MapPartitionsRDD [10129] toJavaRDD at <unknown>:0"]; } subgraph cluster22662 { label="Project"; 10130 [labelType="html" label="MapPartitionsRDD [10130] toJavaRDD at <unknown>:0"]; } subgraph cluster22659 { label="WholeStageCodegen (2)"; 10131 [labelType="html" label="MapPartitionsRDD [10131] toJavaRDD at <unknown>:0"]; } subgraph cluster22658 { label="Project"; 10132 [labelType="html" label="MapPartitionsRDD [10132] toJavaRDD at <unknown>:0"]; } subgraph cluster22657 { label="DeserializeToObject"; 10133 [labelType="html" label="MapPartitionsRDD [10133] toJavaRDD at <unknown>:0"]; } subgraph cluster22656 { label="MapPartitions"; 10134 [labelType="html" label="MapPartitionsRDD [10134] toJavaRDD at <unknown>:0"]; } subgraph cluster22666 { label="mapPartitions"; 10136 [labelType="html" label="MapPartitionsRDD [10136] toJavaRDD at <unknown>:0"]; } } 10123->10124; 10124->10125; 10125->10126; 10126->10127; 10127->10128; 10128->10129; 10129->10130; 10130->10131; 10131->10132; 10132->10133; 10133->10134; 10134->10135; 10135->10136; 10136->10137; }

Event Timeline

Enable zooming