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

digraph G { subgraph clusterstage_867 { label="Stage 867"; 9103 [labelType="html" label="SQLExecutionRDD [9103] run at <unknown>:0"]; 9111 [labelType="html" label="SQLExecutionRDD [9111] toJavaRDD at <unknown>:0"]; 9113 [labelType="html" label="PythonRDD [9113] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster20364 { label="MicroBatchScan"; 9099 [labelType="html" label="DataSourceRDD [9099] run at <unknown>:0"]; 9100 [labelType="html" label="MapPartitionsRDD [9100] run at <unknown>:0"]; } subgraph cluster20363 { label="Project"; 9101 [labelType="html" label="MapPartitionsRDD [9101] run at <unknown>:0"]; } subgraph cluster20357 { label="WholeStageCodegen (1)"; 9102 [labelType="html" label="MapPartitionsRDD [9102] run at <unknown>:0"]; } subgraph cluster20373 { label="WholeStageCodegen (1)"; 9104 [labelType="html" label="MapPartitionsRDD [9104] toJavaRDD at <unknown>:0"]; } subgraph cluster20372 { label="Filter"; 9105 [labelType="html" label="MapPartitionsRDD [9105] toJavaRDD at <unknown>:0"]; } subgraph cluster20371 { label="Project"; 9106 [labelType="html" label="MapPartitionsRDD [9106] toJavaRDD at <unknown>:0"]; } subgraph cluster20368 { label="WholeStageCodegen (2)"; 9107 [labelType="html" label="MapPartitionsRDD [9107] toJavaRDD at <unknown>:0"]; } subgraph cluster20367 { label="Project"; 9108 [labelType="html" label="MapPartitionsRDD [9108] toJavaRDD at <unknown>:0"]; } subgraph cluster20366 { label="DeserializeToObject"; 9109 [labelType="html" label="MapPartitionsRDD [9109] toJavaRDD at <unknown>:0"]; } subgraph cluster20365 { label="MapPartitions"; 9110 [labelType="html" label="MapPartitionsRDD [9110] toJavaRDD at <unknown>:0"]; } subgraph cluster20375 { label="mapPartitions"; 9112 [labelType="html" label="MapPartitionsRDD [9112] toJavaRDD at <unknown>:0"]; } } 9099->9100; 9100->9101; 9101->9102; 9102->9103; 9103->9104; 9104->9105; 9105->9106; 9106->9107; 9107->9108; 9108->9109; 9109->9110; 9110->9111; 9111->9112; 9112->9113; }

Event Timeline

Enable zooming