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

digraph G { subgraph clusterstage_1276 { label="Stage 1276"; 13402 [labelType="html" label="SQLExecutionRDD [13402] run at <unknown>:0"]; 13410 [labelType="html" label="SQLExecutionRDD [13410] toJavaRDD at <unknown>:0"]; 13412 [labelType="html" label="PythonRDD [13412] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster29991 { label="MicroBatchScan"; 13398 [labelType="html" label="DataSourceRDD [13398] run at <unknown>:0"]; 13399 [labelType="html" label="MapPartitionsRDD [13399] run at <unknown>:0"]; } subgraph cluster29990 { label="Project"; 13400 [labelType="html" label="MapPartitionsRDD [13400] run at <unknown>:0"]; } subgraph cluster29986 { label="WholeStageCodegen (1)"; 13401 [labelType="html" label="MapPartitionsRDD [13401] run at <unknown>:0"]; } subgraph cluster30000 { label="WholeStageCodegen (1)"; 13403 [labelType="html" label="MapPartitionsRDD [13403] toJavaRDD at <unknown>:0"]; } subgraph cluster29999 { label="Filter"; 13404 [labelType="html" label="MapPartitionsRDD [13404] toJavaRDD at <unknown>:0"]; } subgraph cluster29998 { label="Project"; 13405 [labelType="html" label="MapPartitionsRDD [13405] toJavaRDD at <unknown>:0"]; } subgraph cluster29995 { label="WholeStageCodegen (2)"; 13406 [labelType="html" label="MapPartitionsRDD [13406] toJavaRDD at <unknown>:0"]; } subgraph cluster29994 { label="Project"; 13407 [labelType="html" label="MapPartitionsRDD [13407] toJavaRDD at <unknown>:0"]; } subgraph cluster29993 { label="DeserializeToObject"; 13408 [labelType="html" label="MapPartitionsRDD [13408] toJavaRDD at <unknown>:0"]; } subgraph cluster29992 { label="MapPartitions"; 13409 [labelType="html" label="MapPartitionsRDD [13409] toJavaRDD at <unknown>:0"]; } subgraph cluster30002 { label="mapPartitions"; 13411 [labelType="html" label="MapPartitionsRDD [13411] toJavaRDD at <unknown>:0"]; } } 13398->13399; 13399->13400; 13400->13401; 13401->13402; 13402->13403; 13403->13404; 13404->13405; 13405->13406; 13406->13407; 13407->13408; 13408->13409; 13409->13410; 13410->13411; 13411->13412; }

Event Timeline

Enable zooming