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

digraph G { subgraph clusterstage_1731 { label="Stage 1731"; 18175 [labelType="html" label="SQLExecutionRDD [18175] run at <unknown>:0"]; 18183 [labelType="html" label="SQLExecutionRDD [18183] toJavaRDD at <unknown>:0"]; 18185 [labelType="html" label="PythonRDD [18185] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster40668 { label="MicroBatchScan"; 18171 [labelType="html" label="DataSourceRDD [18171] run at <unknown>:0"]; 18172 [labelType="html" label="MapPartitionsRDD [18172] run at <unknown>:0"]; } subgraph cluster40667 { label="Project"; 18173 [labelType="html" label="MapPartitionsRDD [18173] run at <unknown>:0"]; } subgraph cluster40663 { label="WholeStageCodegen (1)"; 18174 [labelType="html" label="MapPartitionsRDD [18174] run at <unknown>:0"]; } subgraph cluster40677 { label="WholeStageCodegen (1)"; 18176 [labelType="html" label="MapPartitionsRDD [18176] toJavaRDD at <unknown>:0"]; } subgraph cluster40676 { label="Filter"; 18177 [labelType="html" label="MapPartitionsRDD [18177] toJavaRDD at <unknown>:0"]; } subgraph cluster40675 { label="Project"; 18178 [labelType="html" label="MapPartitionsRDD [18178] toJavaRDD at <unknown>:0"]; } subgraph cluster40672 { label="WholeStageCodegen (2)"; 18179 [labelType="html" label="MapPartitionsRDD [18179] toJavaRDD at <unknown>:0"]; } subgraph cluster40671 { label="Project"; 18180 [labelType="html" label="MapPartitionsRDD [18180] toJavaRDD at <unknown>:0"]; } subgraph cluster40670 { label="DeserializeToObject"; 18181 [labelType="html" label="MapPartitionsRDD [18181] toJavaRDD at <unknown>:0"]; } subgraph cluster40669 { label="MapPartitions"; 18182 [labelType="html" label="MapPartitionsRDD [18182] toJavaRDD at <unknown>:0"]; } subgraph cluster40679 { label="mapPartitions"; 18184 [labelType="html" label="MapPartitionsRDD [18184] toJavaRDD at <unknown>:0"]; } } 18171->18172; 18172->18173; 18173->18174; 18174->18175; 18175->18176; 18176->18177; 18177->18178; 18178->18179; 18179->18180; 18180->18181; 18181->18182; 18182->18183; 18183->18184; 18184->18185; }

Event Timeline

Enable zooming