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

digraph G { subgraph clusterstage_1854 { label="Stage 1854"; 19471 [labelType="html" label="SQLExecutionRDD [19471] run at <unknown>:0"]; 19479 [labelType="html" label="SQLExecutionRDD [19479] toJavaRDD at <unknown>:0"]; 19481 [labelType="html" label="PythonRDD [19481] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster43574 { label="MicroBatchScan"; 19467 [labelType="html" label="DataSourceRDD [19467] run at <unknown>:0"]; 19468 [labelType="html" label="MapPartitionsRDD [19468] run at <unknown>:0"]; } subgraph cluster43573 { label="Project"; 19469 [labelType="html" label="MapPartitionsRDD [19469] run at <unknown>:0"]; } subgraph cluster43569 { label="WholeStageCodegen (1)"; 19470 [labelType="html" label="MapPartitionsRDD [19470] run at <unknown>:0"]; } subgraph cluster43583 { label="WholeStageCodegen (1)"; 19472 [labelType="html" label="MapPartitionsRDD [19472] toJavaRDD at <unknown>:0"]; } subgraph cluster43582 { label="Filter"; 19473 [labelType="html" label="MapPartitionsRDD [19473] toJavaRDD at <unknown>:0"]; } subgraph cluster43581 { label="Project"; 19474 [labelType="html" label="MapPartitionsRDD [19474] toJavaRDD at <unknown>:0"]; } subgraph cluster43578 { label="WholeStageCodegen (2)"; 19475 [labelType="html" label="MapPartitionsRDD [19475] toJavaRDD at <unknown>:0"]; } subgraph cluster43577 { label="Project"; 19476 [labelType="html" label="MapPartitionsRDD [19476] toJavaRDD at <unknown>:0"]; } subgraph cluster43576 { label="DeserializeToObject"; 19477 [labelType="html" label="MapPartitionsRDD [19477] toJavaRDD at <unknown>:0"]; } subgraph cluster43575 { label="MapPartitions"; 19478 [labelType="html" label="MapPartitionsRDD [19478] toJavaRDD at <unknown>:0"]; } subgraph cluster43585 { label="mapPartitions"; 19480 [labelType="html" label="MapPartitionsRDD [19480] toJavaRDD at <unknown>:0"]; } } 19467->19468; 19468->19469; 19469->19470; 19470->19471; 19471->19472; 19472->19473; 19473->19474; 19474->19475; 19475->19476; 19476->19477; 19477->19478; 19478->19479; 19479->19480; 19480->19481; }

Event Timeline

Enable zooming