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

digraph G { subgraph clusterstage_800 { label="Stage 800"; 8404 [labelType="html" label="SQLExecutionRDD [8404] run at <unknown>:0"]; 8412 [labelType="html" label="SQLExecutionRDD [8412] toJavaRDD at <unknown>:0"]; 8414 [labelType="html" label="PythonRDD [8414] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster18805 { label="MicroBatchScan"; 8400 [labelType="html" label="DataSourceRDD [8400] run at <unknown>:0"]; 8401 [labelType="html" label="MapPartitionsRDD [8401] run at <unknown>:0"]; } subgraph cluster18804 { label="Project"; 8402 [labelType="html" label="MapPartitionsRDD [8402] run at <unknown>:0"]; } subgraph cluster18800 { label="WholeStageCodegen (1)"; 8403 [labelType="html" label="MapPartitionsRDD [8403] run at <unknown>:0"]; } subgraph cluster18814 { label="WholeStageCodegen (1)"; 8405 [labelType="html" label="MapPartitionsRDD [8405] toJavaRDD at <unknown>:0"]; } subgraph cluster18813 { label="Filter"; 8406 [labelType="html" label="MapPartitionsRDD [8406] toJavaRDD at <unknown>:0"]; } subgraph cluster18812 { label="Project"; 8407 [labelType="html" label="MapPartitionsRDD [8407] toJavaRDD at <unknown>:0"]; } subgraph cluster18809 { label="WholeStageCodegen (2)"; 8408 [labelType="html" label="MapPartitionsRDD [8408] toJavaRDD at <unknown>:0"]; } subgraph cluster18808 { label="Project"; 8409 [labelType="html" label="MapPartitionsRDD [8409] toJavaRDD at <unknown>:0"]; } subgraph cluster18807 { label="DeserializeToObject"; 8410 [labelType="html" label="MapPartitionsRDD [8410] toJavaRDD at <unknown>:0"]; } subgraph cluster18806 { label="MapPartitions"; 8411 [labelType="html" label="MapPartitionsRDD [8411] toJavaRDD at <unknown>:0"]; } subgraph cluster18816 { label="mapPartitions"; 8413 [labelType="html" label="MapPartitionsRDD [8413] toJavaRDD at <unknown>:0"]; } } 8400->8401; 8401->8402; 8402->8403; 8403->8404; 8404->8405; 8405->8406; 8406->8407; 8407->8408; 8408->8409; 8409->8410; 8410->8411; 8411->8412; 8412->8413; 8413->8414; }

Event Timeline

Enable zooming