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

digraph G { subgraph clusterstage_2038 { label="Stage 2038"; 21404 [labelType="html" label="SQLExecutionRDD [21404] run at <unknown>:0"]; 21418 [labelType="html" label="SQLExecutionRDD [21418] toJavaRDD at <unknown>:0"]; 21420 [labelType="html" label="PythonRDD [21420] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster47894 { label="MicroBatchScan"; 21400 [labelType="html" label="DataSourceRDD [21400] run at <unknown>:0"]; 21401 [labelType="html" label="MapPartitionsRDD [21401] run at <unknown>:0"]; } subgraph cluster47893 { label="Project"; 21402 [labelType="html" label="MapPartitionsRDD [21402] run at <unknown>:0"]; } subgraph cluster47889 { label="WholeStageCodegen (1)"; 21403 [labelType="html" label="MapPartitionsRDD [21403] run at <unknown>:0"]; } subgraph cluster47911 { label="WholeStageCodegen (1)"; 21411 [labelType="html" label="MapPartitionsRDD [21411] toJavaRDD at <unknown>:0"]; } subgraph cluster47910 { label="Filter"; 21412 [labelType="html" label="MapPartitionsRDD [21412] toJavaRDD at <unknown>:0"]; } subgraph cluster47909 { label="Project"; 21413 [labelType="html" label="MapPartitionsRDD [21413] toJavaRDD at <unknown>:0"]; } subgraph cluster47906 { label="WholeStageCodegen (2)"; 21414 [labelType="html" label="MapPartitionsRDD [21414] toJavaRDD at <unknown>:0"]; } subgraph cluster47905 { label="Project"; 21415 [labelType="html" label="MapPartitionsRDD [21415] toJavaRDD at <unknown>:0"]; } subgraph cluster47904 { label="DeserializeToObject"; 21416 [labelType="html" label="MapPartitionsRDD [21416] toJavaRDD at <unknown>:0"]; } subgraph cluster47903 { label="MapPartitions"; 21417 [labelType="html" label="MapPartitionsRDD [21417] toJavaRDD at <unknown>:0"]; } subgraph cluster47913 { label="mapPartitions"; 21419 [labelType="html" label="MapPartitionsRDD [21419] toJavaRDD at <unknown>:0"]; } } 21400->21401; 21401->21402; 21402->21403; 21403->21404; 21404->21411; 21411->21412; 21412->21413; 21413->21414; 21414->21415; 21415->21416; 21416->21417; 21417->21418; 21418->21419; 21419->21420; }

Event Timeline

Enable zooming