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

digraph G { subgraph clusterstage_897 { label="Stage 897"; 9434 [labelType="html" label="SQLExecutionRDD [9434] run at <unknown>:0"]; 9442 [labelType="html" label="SQLExecutionRDD [9442] toJavaRDD at <unknown>:0"]; 9444 [labelType="html" label="PythonRDD [9444] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster21104 { label="MicroBatchScan"; 9430 [labelType="html" label="DataSourceRDD [9430] run at <unknown>:0"]; 9431 [labelType="html" label="MapPartitionsRDD [9431] run at <unknown>:0"]; } subgraph cluster21103 { label="Project"; 9432 [labelType="html" label="MapPartitionsRDD [9432] run at <unknown>:0"]; } subgraph cluster21099 { label="WholeStageCodegen (1)"; 9433 [labelType="html" label="MapPartitionsRDD [9433] run at <unknown>:0"]; } subgraph cluster21113 { label="WholeStageCodegen (1)"; 9435 [labelType="html" label="MapPartitionsRDD [9435] toJavaRDD at <unknown>:0"]; } subgraph cluster21112 { label="Filter"; 9436 [labelType="html" label="MapPartitionsRDD [9436] toJavaRDD at <unknown>:0"]; } subgraph cluster21111 { label="Project"; 9437 [labelType="html" label="MapPartitionsRDD [9437] toJavaRDD at <unknown>:0"]; } subgraph cluster21108 { label="WholeStageCodegen (2)"; 9438 [labelType="html" label="MapPartitionsRDD [9438] toJavaRDD at <unknown>:0"]; } subgraph cluster21107 { label="Project"; 9439 [labelType="html" label="MapPartitionsRDD [9439] toJavaRDD at <unknown>:0"]; } subgraph cluster21106 { label="DeserializeToObject"; 9440 [labelType="html" label="MapPartitionsRDD [9440] toJavaRDD at <unknown>:0"]; } subgraph cluster21105 { label="MapPartitions"; 9441 [labelType="html" label="MapPartitionsRDD [9441] toJavaRDD at <unknown>:0"]; } subgraph cluster21115 { label="mapPartitions"; 9443 [labelType="html" label="MapPartitionsRDD [9443] toJavaRDD at <unknown>:0"]; } } 9430->9431; 9431->9432; 9432->9433; 9433->9434; 9434->9435; 9435->9436; 9436->9437; 9437->9438; 9438->9439; 9439->9440; 9440->9441; 9441->9442; 9442->9443; 9443->9444; }

Event Timeline

Enable zooming