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

digraph G { subgraph clusterstage_523 { label="Stage 523"; 5491 [labelType="html" label="SQLExecutionRDD [5491] run at <unknown>:0"]; 5499 [labelType="html" label="SQLExecutionRDD [5499] toJavaRDD at <unknown>:0"]; 5501 [labelType="html" label="PythonRDD [5501] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12280 { label="MicroBatchScan"; 5487 [labelType="html" label="DataSourceRDD [5487] run at <unknown>:0"]; 5488 [labelType="html" label="MapPartitionsRDD [5488] run at <unknown>:0"]; } subgraph cluster12279 { label="Project"; 5489 [labelType="html" label="MapPartitionsRDD [5489] run at <unknown>:0"]; } subgraph cluster12275 { label="WholeStageCodegen (1)"; 5490 [labelType="html" label="MapPartitionsRDD [5490] run at <unknown>:0"]; } subgraph cluster12289 { label="WholeStageCodegen (1)"; 5492 [labelType="html" label="MapPartitionsRDD [5492] toJavaRDD at <unknown>:0"]; } subgraph cluster12288 { label="Filter"; 5493 [labelType="html" label="MapPartitionsRDD [5493] toJavaRDD at <unknown>:0"]; } subgraph cluster12287 { label="Project"; 5494 [labelType="html" label="MapPartitionsRDD [5494] toJavaRDD at <unknown>:0"]; } subgraph cluster12284 { label="WholeStageCodegen (2)"; 5495 [labelType="html" label="MapPartitionsRDD [5495] toJavaRDD at <unknown>:0"]; } subgraph cluster12283 { label="Project"; 5496 [labelType="html" label="MapPartitionsRDD [5496] toJavaRDD at <unknown>:0"]; } subgraph cluster12282 { label="DeserializeToObject"; 5497 [labelType="html" label="MapPartitionsRDD [5497] toJavaRDD at <unknown>:0"]; } subgraph cluster12281 { label="MapPartitions"; 5498 [labelType="html" label="MapPartitionsRDD [5498] toJavaRDD at <unknown>:0"]; } subgraph cluster12291 { label="mapPartitions"; 5500 [labelType="html" label="MapPartitionsRDD [5500] toJavaRDD at <unknown>:0"]; } } 5487->5488; 5488->5489; 5489->5490; 5490->5491; 5491->5492; 5492->5493; 5493->5494; 5494->5495; 5495->5496; 5496->5497; 5497->5498; 5498->5499; 5499->5500; 5500->5501; }

Event Timeline

Enable zooming