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

digraph G { subgraph clusterstage_1961 { label="Stage 1961"; 20606 [labelType="html" label="SQLExecutionRDD [20606] run at <unknown>:0"]; 20614 [labelType="html" label="SQLExecutionRDD [20614] toJavaRDD at <unknown>:0"]; 20616 [labelType="html" label="PythonRDD [20616] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster46108 { label="MicroBatchScan"; 20602 [labelType="html" label="DataSourceRDD [20602] run at <unknown>:0"]; 20603 [labelType="html" label="MapPartitionsRDD [20603] run at <unknown>:0"]; } subgraph cluster46107 { label="Project"; 20604 [labelType="html" label="MapPartitionsRDD [20604] run at <unknown>:0"]; } subgraph cluster46103 { label="WholeStageCodegen (1)"; 20605 [labelType="html" label="MapPartitionsRDD [20605] run at <unknown>:0"]; } subgraph cluster46117 { label="WholeStageCodegen (1)"; 20607 [labelType="html" label="MapPartitionsRDD [20607] toJavaRDD at <unknown>:0"]; } subgraph cluster46116 { label="Filter"; 20608 [labelType="html" label="MapPartitionsRDD [20608] toJavaRDD at <unknown>:0"]; } subgraph cluster46115 { label="Project"; 20609 [labelType="html" label="MapPartitionsRDD [20609] toJavaRDD at <unknown>:0"]; } subgraph cluster46112 { label="WholeStageCodegen (2)"; 20610 [labelType="html" label="MapPartitionsRDD [20610] toJavaRDD at <unknown>:0"]; } subgraph cluster46111 { label="Project"; 20611 [labelType="html" label="MapPartitionsRDD [20611] toJavaRDD at <unknown>:0"]; } subgraph cluster46110 { label="DeserializeToObject"; 20612 [labelType="html" label="MapPartitionsRDD [20612] toJavaRDD at <unknown>:0"]; } subgraph cluster46109 { label="MapPartitions"; 20613 [labelType="html" label="MapPartitionsRDD [20613] toJavaRDD at <unknown>:0"]; } subgraph cluster46119 { label="mapPartitions"; 20615 [labelType="html" label="MapPartitionsRDD [20615] toJavaRDD at <unknown>:0"]; } } 20602->20603; 20603->20604; 20604->20605; 20605->20606; 20606->20607; 20607->20608; 20608->20609; 20609->20610; 20610->20611; 20611->20612; 20612->20613; 20613->20614; 20614->20615; 20615->20616; }

Event Timeline

Enable zooming