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

digraph G { subgraph clusterstage_592 { label="Stage 592"; 6220 [labelType="html" label="SQLExecutionRDD [6220] run at <unknown>:0"]; 6228 [labelType="html" label="SQLExecutionRDD [6228] toJavaRDD at <unknown>:0"]; 6230 [labelType="html" label="PythonRDD [6230] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster13917 { label="MicroBatchScan"; 6216 [labelType="html" label="DataSourceRDD [6216] run at <unknown>:0"]; 6217 [labelType="html" label="MapPartitionsRDD [6217] run at <unknown>:0"]; } subgraph cluster13916 { label="Project"; 6218 [labelType="html" label="MapPartitionsRDD [6218] run at <unknown>:0"]; } subgraph cluster13912 { label="WholeStageCodegen (1)"; 6219 [labelType="html" label="MapPartitionsRDD [6219] run at <unknown>:0"]; } subgraph cluster13926 { label="WholeStageCodegen (1)"; 6221 [labelType="html" label="MapPartitionsRDD [6221] toJavaRDD at <unknown>:0"]; } subgraph cluster13925 { label="Filter"; 6222 [labelType="html" label="MapPartitionsRDD [6222] toJavaRDD at <unknown>:0"]; } subgraph cluster13924 { label="Project"; 6223 [labelType="html" label="MapPartitionsRDD [6223] toJavaRDD at <unknown>:0"]; } subgraph cluster13921 { label="WholeStageCodegen (2)"; 6224 [labelType="html" label="MapPartitionsRDD [6224] toJavaRDD at <unknown>:0"]; } subgraph cluster13920 { label="Project"; 6225 [labelType="html" label="MapPartitionsRDD [6225] toJavaRDD at <unknown>:0"]; } subgraph cluster13919 { label="DeserializeToObject"; 6226 [labelType="html" label="MapPartitionsRDD [6226] toJavaRDD at <unknown>:0"]; } subgraph cluster13918 { label="MapPartitions"; 6227 [labelType="html" label="MapPartitionsRDD [6227] toJavaRDD at <unknown>:0"]; } subgraph cluster13928 { label="mapPartitions"; 6229 [labelType="html" label="MapPartitionsRDD [6229] toJavaRDD at <unknown>:0"]; } } 6216->6217; 6217->6218; 6218->6219; 6219->6220; 6220->6221; 6221->6222; 6222->6223; 6223->6224; 6224->6225; 6225->6226; 6226->6227; 6227->6228; 6228->6229; 6229->6230; }

Event Timeline

Enable zooming