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

digraph G { subgraph clusterstage_958 { label="Stage 958"; 10064 [labelType="html" label="SQLExecutionRDD [10064] run at <unknown>:0"]; 10078 [labelType="html" label="SQLExecutionRDD [10078] toJavaRDD at <unknown>:0"]; 10080 [labelType="html" label="PythonRDD [10080] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22514 { label="MicroBatchScan"; 10060 [labelType="html" label="DataSourceRDD [10060] run at <unknown>:0"]; 10061 [labelType="html" label="MapPartitionsRDD [10061] run at <unknown>:0"]; } subgraph cluster22513 { label="Project"; 10062 [labelType="html" label="MapPartitionsRDD [10062] run at <unknown>:0"]; } subgraph cluster22509 { label="WholeStageCodegen (1)"; 10063 [labelType="html" label="MapPartitionsRDD [10063] run at <unknown>:0"]; } subgraph cluster22531 { label="WholeStageCodegen (1)"; 10071 [labelType="html" label="MapPartitionsRDD [10071] toJavaRDD at <unknown>:0"]; } subgraph cluster22530 { label="Filter"; 10072 [labelType="html" label="MapPartitionsRDD [10072] toJavaRDD at <unknown>:0"]; } subgraph cluster22529 { label="Project"; 10073 [labelType="html" label="MapPartitionsRDD [10073] toJavaRDD at <unknown>:0"]; } subgraph cluster22526 { label="WholeStageCodegen (2)"; 10074 [labelType="html" label="MapPartitionsRDD [10074] toJavaRDD at <unknown>:0"]; } subgraph cluster22525 { label="Project"; 10075 [labelType="html" label="MapPartitionsRDD [10075] toJavaRDD at <unknown>:0"]; } subgraph cluster22524 { label="DeserializeToObject"; 10076 [labelType="html" label="MapPartitionsRDD [10076] toJavaRDD at <unknown>:0"]; } subgraph cluster22523 { label="MapPartitions"; 10077 [labelType="html" label="MapPartitionsRDD [10077] toJavaRDD at <unknown>:0"]; } subgraph cluster22533 { label="mapPartitions"; 10079 [labelType="html" label="MapPartitionsRDD [10079] toJavaRDD at <unknown>:0"]; } } 10060->10061; 10061->10062; 10062->10063; 10063->10064; 10064->10071; 10071->10072; 10072->10073; 10073->10074; 10074->10075; 10075->10076; 10076->10077; 10077->10078; 10078->10079; 10079->10080; }

Event Timeline

Enable zooming