processing-stream-kafka-raw-to-minio - Details for Stage 1082 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 493
Associated Job Ids: 1083

digraph G { subgraph clusterstage_1082 { label="Stage 1082"; 11366 [labelType="html" label="SQLExecutionRDD [11366] run at <unknown>:0"]; 11380 [labelType="html" label="SQLExecutionRDD [11380] toJavaRDD at <unknown>:0"]; 11382 [labelType="html" label="PythonRDD [11382] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster25428 { label="MicroBatchScan"; 11362 [labelType="html" label="DataSourceRDD [11362] run at <unknown>:0"]; 11363 [labelType="html" label="MapPartitionsRDD [11363] run at <unknown>:0"]; } subgraph cluster25427 { label="Project"; 11364 [labelType="html" label="MapPartitionsRDD [11364] run at <unknown>:0"]; } subgraph cluster25423 { label="WholeStageCodegen (1)"; 11365 [labelType="html" label="MapPartitionsRDD [11365] run at <unknown>:0"]; } subgraph cluster25445 { label="WholeStageCodegen (1)"; 11373 [labelType="html" label="MapPartitionsRDD [11373] toJavaRDD at <unknown>:0"]; } subgraph cluster25444 { label="Filter"; 11374 [labelType="html" label="MapPartitionsRDD [11374] toJavaRDD at <unknown>:0"]; } subgraph cluster25443 { label="Project"; 11375 [labelType="html" label="MapPartitionsRDD [11375] toJavaRDD at <unknown>:0"]; } subgraph cluster25440 { label="WholeStageCodegen (2)"; 11376 [labelType="html" label="MapPartitionsRDD [11376] toJavaRDD at <unknown>:0"]; } subgraph cluster25439 { label="Project"; 11377 [labelType="html" label="MapPartitionsRDD [11377] toJavaRDD at <unknown>:0"]; } subgraph cluster25438 { label="DeserializeToObject"; 11378 [labelType="html" label="MapPartitionsRDD [11378] toJavaRDD at <unknown>:0"]; } subgraph cluster25437 { label="MapPartitions"; 11379 [labelType="html" label="MapPartitionsRDD [11379] toJavaRDD at <unknown>:0"]; } subgraph cluster25447 { label="mapPartitions"; 11381 [labelType="html" label="MapPartitionsRDD [11381] toJavaRDD at <unknown>:0"]; } } 11362->11363; 11363->11364; 11364->11365; 11365->11366; 11366->11373; 11373->11374; 11374->11375; 11375->11376; 11376->11377; 11377->11378; 11378->11379; 11379->11380; 11380->11381; 11381->11382; }

Event Timeline

Enable zooming