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

digraph G { subgraph clusterstage_1752 { label="Stage 1752"; 18400 [labelType="html" label="SQLExecutionRDD [18400] run at <unknown>:0"]; 18408 [labelType="html" label="SQLExecutionRDD [18408] toJavaRDD at <unknown>:0"]; 18410 [labelType="html" label="PythonRDD [18410] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster41177 { label="MicroBatchScan"; 18396 [labelType="html" label="DataSourceRDD [18396] run at <unknown>:0"]; 18397 [labelType="html" label="MapPartitionsRDD [18397] run at <unknown>:0"]; } subgraph cluster41176 { label="Project"; 18398 [labelType="html" label="MapPartitionsRDD [18398] run at <unknown>:0"]; } subgraph cluster41172 { label="WholeStageCodegen (1)"; 18399 [labelType="html" label="MapPartitionsRDD [18399] run at <unknown>:0"]; } subgraph cluster41186 { label="WholeStageCodegen (1)"; 18401 [labelType="html" label="MapPartitionsRDD [18401] toJavaRDD at <unknown>:0"]; } subgraph cluster41185 { label="Filter"; 18402 [labelType="html" label="MapPartitionsRDD [18402] toJavaRDD at <unknown>:0"]; } subgraph cluster41184 { label="Project"; 18403 [labelType="html" label="MapPartitionsRDD [18403] toJavaRDD at <unknown>:0"]; } subgraph cluster41181 { label="WholeStageCodegen (2)"; 18404 [labelType="html" label="MapPartitionsRDD [18404] toJavaRDD at <unknown>:0"]; } subgraph cluster41180 { label="Project"; 18405 [labelType="html" label="MapPartitionsRDD [18405] toJavaRDD at <unknown>:0"]; } subgraph cluster41179 { label="DeserializeToObject"; 18406 [labelType="html" label="MapPartitionsRDD [18406] toJavaRDD at <unknown>:0"]; } subgraph cluster41178 { label="MapPartitions"; 18407 [labelType="html" label="MapPartitionsRDD [18407] toJavaRDD at <unknown>:0"]; } subgraph cluster41188 { label="mapPartitions"; 18409 [labelType="html" label="MapPartitionsRDD [18409] toJavaRDD at <unknown>:0"]; } } 18396->18397; 18397->18398; 18398->18399; 18399->18400; 18400->18401; 18401->18402; 18402->18403; 18403->18404; 18404->18405; 18405->18406; 18406->18407; 18407->18408; 18408->18409; 18409->18410; }

Event Timeline

Enable zooming