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

digraph G { subgraph clusterstage_829 { label="Stage 829"; 8698 [labelType="html" label="SQLExecutionRDD [8698] run at <unknown>:0"]; 8712 [labelType="html" label="SQLExecutionRDD [8712] toJavaRDD at <unknown>:0"]; 8714 [labelType="html" label="PythonRDD [8714] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster19463 { label="MicroBatchScan"; 8694 [labelType="html" label="DataSourceRDD [8694] run at <unknown>:0"]; 8695 [labelType="html" label="MapPartitionsRDD [8695] run at <unknown>:0"]; } subgraph cluster19462 { label="Project"; 8696 [labelType="html" label="MapPartitionsRDD [8696] run at <unknown>:0"]; } subgraph cluster19458 { label="WholeStageCodegen (1)"; 8697 [labelType="html" label="MapPartitionsRDD [8697] run at <unknown>:0"]; } subgraph cluster19480 { label="WholeStageCodegen (1)"; 8705 [labelType="html" label="MapPartitionsRDD [8705] toJavaRDD at <unknown>:0"]; } subgraph cluster19479 { label="Filter"; 8706 [labelType="html" label="MapPartitionsRDD [8706] toJavaRDD at <unknown>:0"]; } subgraph cluster19478 { label="Project"; 8707 [labelType="html" label="MapPartitionsRDD [8707] toJavaRDD at <unknown>:0"]; } subgraph cluster19475 { label="WholeStageCodegen (2)"; 8708 [labelType="html" label="MapPartitionsRDD [8708] toJavaRDD at <unknown>:0"]; } subgraph cluster19474 { label="Project"; 8709 [labelType="html" label="MapPartitionsRDD [8709] toJavaRDD at <unknown>:0"]; } subgraph cluster19473 { label="DeserializeToObject"; 8710 [labelType="html" label="MapPartitionsRDD [8710] toJavaRDD at <unknown>:0"]; } subgraph cluster19472 { label="MapPartitions"; 8711 [labelType="html" label="MapPartitionsRDD [8711] toJavaRDD at <unknown>:0"]; } subgraph cluster19482 { label="mapPartitions"; 8713 [labelType="html" label="MapPartitionsRDD [8713] toJavaRDD at <unknown>:0"]; } } 8694->8695; 8695->8696; 8696->8697; 8697->8698; 8698->8705; 8705->8706; 8706->8707; 8707->8708; 8708->8709; 8709->8710; 8710->8711; 8711->8712; 8712->8713; 8713->8714; }

Event Timeline

Enable zooming