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

digraph G { subgraph clusterstage_39 { label="Stage 39"; 403 [labelType="html" label="SQLExecutionRDD [403] run at <unknown>:0"]; 417 [labelType="html" label="SQLExecutionRDD [417] toJavaRDD at <unknown>:0"]; 419 [labelType="html" label="PythonRDD [419] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster898 { label="MicroBatchScan"; 399 [labelType="html" label="DataSourceRDD [399] run at <unknown>:0"]; 400 [labelType="html" label="MapPartitionsRDD [400] run at <unknown>:0"]; } subgraph cluster897 { label="Project"; 401 [labelType="html" label="MapPartitionsRDD [401] run at <unknown>:0"]; } subgraph cluster893 { label="WholeStageCodegen (1)"; 402 [labelType="html" label="MapPartitionsRDD [402] run at <unknown>:0"]; } subgraph cluster915 { label="WholeStageCodegen (1)"; 410 [labelType="html" label="MapPartitionsRDD [410] toJavaRDD at <unknown>:0"]; } subgraph cluster914 { label="Filter"; 411 [labelType="html" label="MapPartitionsRDD [411] toJavaRDD at <unknown>:0"]; } subgraph cluster913 { label="Project"; 412 [labelType="html" label="MapPartitionsRDD [412] toJavaRDD at <unknown>:0"]; } subgraph cluster910 { label="WholeStageCodegen (2)"; 413 [labelType="html" label="MapPartitionsRDD [413] toJavaRDD at <unknown>:0"]; } subgraph cluster909 { label="Project"; 414 [labelType="html" label="MapPartitionsRDD [414] toJavaRDD at <unknown>:0"]; } subgraph cluster908 { label="DeserializeToObject"; 415 [labelType="html" label="MapPartitionsRDD [415] toJavaRDD at <unknown>:0"]; } subgraph cluster907 { label="MapPartitions"; 416 [labelType="html" label="MapPartitionsRDD [416] toJavaRDD at <unknown>:0"]; } subgraph cluster917 { label="mapPartitions"; 418 [labelType="html" label="MapPartitionsRDD [418] toJavaRDD at <unknown>:0"]; } } 399->400; 400->401; 401->402; 402->403; 403->410; 410->411; 411->412; 412->413; 413->414; 414->415; 415->416; 416->417; 417->418; 418->419; }

Event Timeline

Enable zooming