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

digraph G { subgraph clusterstage_1720 { label="Stage 1720"; 18071 [labelType="html" label="SQLExecutionRDD [18071] run at <unknown>:0"]; 18079 [labelType="html" label="SQLExecutionRDD [18079] toJavaRDD at <unknown>:0"]; 18081 [labelType="html" label="PythonRDD [18081] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster40429 { label="MicroBatchScan"; 18067 [labelType="html" label="DataSourceRDD [18067] run at <unknown>:0"]; 18068 [labelType="html" label="MapPartitionsRDD [18068] run at <unknown>:0"]; } subgraph cluster40428 { label="Project"; 18069 [labelType="html" label="MapPartitionsRDD [18069] run at <unknown>:0"]; } subgraph cluster40424 { label="WholeStageCodegen (1)"; 18070 [labelType="html" label="MapPartitionsRDD [18070] run at <unknown>:0"]; } subgraph cluster40438 { label="WholeStageCodegen (1)"; 18072 [labelType="html" label="MapPartitionsRDD [18072] toJavaRDD at <unknown>:0"]; } subgraph cluster40437 { label="Filter"; 18073 [labelType="html" label="MapPartitionsRDD [18073] toJavaRDD at <unknown>:0"]; } subgraph cluster40436 { label="Project"; 18074 [labelType="html" label="MapPartitionsRDD [18074] toJavaRDD at <unknown>:0"]; } subgraph cluster40433 { label="WholeStageCodegen (2)"; 18075 [labelType="html" label="MapPartitionsRDD [18075] toJavaRDD at <unknown>:0"]; } subgraph cluster40432 { label="Project"; 18076 [labelType="html" label="MapPartitionsRDD [18076] toJavaRDD at <unknown>:0"]; } subgraph cluster40431 { label="DeserializeToObject"; 18077 [labelType="html" label="MapPartitionsRDD [18077] toJavaRDD at <unknown>:0"]; } subgraph cluster40430 { label="MapPartitions"; 18078 [labelType="html" label="MapPartitionsRDD [18078] toJavaRDD at <unknown>:0"]; } subgraph cluster40440 { label="mapPartitions"; 18080 [labelType="html" label="MapPartitionsRDD [18080] toJavaRDD at <unknown>:0"]; } } 18067->18068; 18068->18069; 18069->18070; 18070->18071; 18071->18072; 18072->18073; 18073->18074; 18074->18075; 18075->18076; 18076->18077; 18077->18078; 18078->18079; 18079->18080; 18080->18081; }

Event Timeline

Enable zooming