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

digraph G { subgraph clusterstage_2056 { label="Stage 2056"; 21593 [labelType="html" label="SQLExecutionRDD [21593] run at <unknown>:0"]; 21607 [labelType="html" label="SQLExecutionRDD [21607] toJavaRDD at <unknown>:0"]; 21609 [labelType="html" label="PythonRDD [21609] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster48317 { label="MicroBatchScan"; 21589 [labelType="html" label="DataSourceRDD [21589] run at <unknown>:0"]; 21590 [labelType="html" label="MapPartitionsRDD [21590] run at <unknown>:0"]; } subgraph cluster48316 { label="Project"; 21591 [labelType="html" label="MapPartitionsRDD [21591] run at <unknown>:0"]; } subgraph cluster48312 { label="WholeStageCodegen (1)"; 21592 [labelType="html" label="MapPartitionsRDD [21592] run at <unknown>:0"]; } subgraph cluster48334 { label="WholeStageCodegen (1)"; 21600 [labelType="html" label="MapPartitionsRDD [21600] toJavaRDD at <unknown>:0"]; } subgraph cluster48333 { label="Filter"; 21601 [labelType="html" label="MapPartitionsRDD [21601] toJavaRDD at <unknown>:0"]; } subgraph cluster48332 { label="Project"; 21602 [labelType="html" label="MapPartitionsRDD [21602] toJavaRDD at <unknown>:0"]; } subgraph cluster48329 { label="WholeStageCodegen (2)"; 21603 [labelType="html" label="MapPartitionsRDD [21603] toJavaRDD at <unknown>:0"]; } subgraph cluster48328 { label="Project"; 21604 [labelType="html" label="MapPartitionsRDD [21604] toJavaRDD at <unknown>:0"]; } subgraph cluster48327 { label="DeserializeToObject"; 21605 [labelType="html" label="MapPartitionsRDD [21605] toJavaRDD at <unknown>:0"]; } subgraph cluster48326 { label="MapPartitions"; 21606 [labelType="html" label="MapPartitionsRDD [21606] toJavaRDD at <unknown>:0"]; } subgraph cluster48336 { label="mapPartitions"; 21608 [labelType="html" label="MapPartitionsRDD [21608] toJavaRDD at <unknown>:0"]; } } 21589->21590; 21590->21591; 21591->21592; 21592->21593; 21593->21600; 21600->21601; 21601->21602; 21602->21603; 21603->21604; 21604->21605; 21605->21606; 21606->21607; 21607->21608; 21608->21609; }

Event Timeline

Enable zooming