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

digraph G { subgraph clusterstage_893 { label="Stage 893"; 9392 [labelType="html" label="SQLExecutionRDD [9392] run at <unknown>:0"]; 9400 [labelType="html" label="SQLExecutionRDD [9400] toJavaRDD at <unknown>:0"]; 9402 [labelType="html" label="PythonRDD [9402] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster21010 { label="MicroBatchScan"; 9388 [labelType="html" label="DataSourceRDD [9388] run at <unknown>:0"]; 9389 [labelType="html" label="MapPartitionsRDD [9389] run at <unknown>:0"]; } subgraph cluster21009 { label="Project"; 9390 [labelType="html" label="MapPartitionsRDD [9390] run at <unknown>:0"]; } subgraph cluster21005 { label="WholeStageCodegen (1)"; 9391 [labelType="html" label="MapPartitionsRDD [9391] run at <unknown>:0"]; } subgraph cluster21019 { label="WholeStageCodegen (1)"; 9393 [labelType="html" label="MapPartitionsRDD [9393] toJavaRDD at <unknown>:0"]; } subgraph cluster21018 { label="Filter"; 9394 [labelType="html" label="MapPartitionsRDD [9394] toJavaRDD at <unknown>:0"]; } subgraph cluster21017 { label="Project"; 9395 [labelType="html" label="MapPartitionsRDD [9395] toJavaRDD at <unknown>:0"]; } subgraph cluster21014 { label="WholeStageCodegen (2)"; 9396 [labelType="html" label="MapPartitionsRDD [9396] toJavaRDD at <unknown>:0"]; } subgraph cluster21013 { label="Project"; 9397 [labelType="html" label="MapPartitionsRDD [9397] toJavaRDD at <unknown>:0"]; } subgraph cluster21012 { label="DeserializeToObject"; 9398 [labelType="html" label="MapPartitionsRDD [9398] toJavaRDD at <unknown>:0"]; } subgraph cluster21011 { label="MapPartitions"; 9399 [labelType="html" label="MapPartitionsRDD [9399] toJavaRDD at <unknown>:0"]; } subgraph cluster21021 { label="mapPartitions"; 9401 [labelType="html" label="MapPartitionsRDD [9401] toJavaRDD at <unknown>:0"]; } } 9388->9389; 9389->9390; 9390->9391; 9391->9392; 9392->9393; 9393->9394; 9394->9395; 9395->9396; 9396->9397; 9397->9398; 9398->9399; 9399->9400; 9400->9401; 9401->9402; }

Event Timeline

Enable zooming