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

digraph G { subgraph clusterstage_1091 { label="Stage 1091"; 11471 [labelType="html" label="SQLExecutionRDD [11471] run at <unknown>:0"]; 11479 [labelType="html" label="SQLExecutionRDD [11479] toJavaRDD at <unknown>:0"]; 11481 [labelType="html" label="PythonRDD [11481] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster25663 { label="MicroBatchScan"; 11467 [labelType="html" label="DataSourceRDD [11467] run at <unknown>:0"]; 11468 [labelType="html" label="MapPartitionsRDD [11468] run at <unknown>:0"]; } subgraph cluster25662 { label="Project"; 11469 [labelType="html" label="MapPartitionsRDD [11469] run at <unknown>:0"]; } subgraph cluster25658 { label="WholeStageCodegen (1)"; 11470 [labelType="html" label="MapPartitionsRDD [11470] run at <unknown>:0"]; } subgraph cluster25672 { label="WholeStageCodegen (1)"; 11472 [labelType="html" label="MapPartitionsRDD [11472] toJavaRDD at <unknown>:0"]; } subgraph cluster25671 { label="Filter"; 11473 [labelType="html" label="MapPartitionsRDD [11473] toJavaRDD at <unknown>:0"]; } subgraph cluster25670 { label="Project"; 11474 [labelType="html" label="MapPartitionsRDD [11474] toJavaRDD at <unknown>:0"]; } subgraph cluster25667 { label="WholeStageCodegen (2)"; 11475 [labelType="html" label="MapPartitionsRDD [11475] toJavaRDD at <unknown>:0"]; } subgraph cluster25666 { label="Project"; 11476 [labelType="html" label="MapPartitionsRDD [11476] toJavaRDD at <unknown>:0"]; } subgraph cluster25665 { label="DeserializeToObject"; 11477 [labelType="html" label="MapPartitionsRDD [11477] toJavaRDD at <unknown>:0"]; } subgraph cluster25664 { label="MapPartitions"; 11478 [labelType="html" label="MapPartitionsRDD [11478] toJavaRDD at <unknown>:0"]; } subgraph cluster25674 { label="mapPartitions"; 11480 [labelType="html" label="MapPartitionsRDD [11480] toJavaRDD at <unknown>:0"]; } } 11467->11468; 11468->11469; 11469->11470; 11470->11471; 11471->11472; 11472->11473; 11473->11474; 11474->11475; 11475->11476; 11476->11477; 11477->11478; 11478->11479; 11479->11480; 11480->11481; }

Event Timeline

Enable zooming