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

digraph G { subgraph clusterstage_1101 { label="Stage 1101"; 11576 [labelType="html" label="SQLExecutionRDD [11576] run at <unknown>:0"]; 11584 [labelType="html" label="SQLExecutionRDD [11584] toJavaRDD at <unknown>:0"]; 11586 [labelType="html" label="PythonRDD [11586] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster25898 { label="MicroBatchScan"; 11572 [labelType="html" label="DataSourceRDD [11572] run at <unknown>:0"]; 11573 [labelType="html" label="MapPartitionsRDD [11573] run at <unknown>:0"]; } subgraph cluster25897 { label="Project"; 11574 [labelType="html" label="MapPartitionsRDD [11574] run at <unknown>:0"]; } subgraph cluster25893 { label="WholeStageCodegen (1)"; 11575 [labelType="html" label="MapPartitionsRDD [11575] run at <unknown>:0"]; } subgraph cluster25907 { label="WholeStageCodegen (1)"; 11577 [labelType="html" label="MapPartitionsRDD [11577] toJavaRDD at <unknown>:0"]; } subgraph cluster25906 { label="Filter"; 11578 [labelType="html" label="MapPartitionsRDD [11578] toJavaRDD at <unknown>:0"]; } subgraph cluster25905 { label="Project"; 11579 [labelType="html" label="MapPartitionsRDD [11579] toJavaRDD at <unknown>:0"]; } subgraph cluster25902 { label="WholeStageCodegen (2)"; 11580 [labelType="html" label="MapPartitionsRDD [11580] toJavaRDD at <unknown>:0"]; } subgraph cluster25901 { label="Project"; 11581 [labelType="html" label="MapPartitionsRDD [11581] toJavaRDD at <unknown>:0"]; } subgraph cluster25900 { label="DeserializeToObject"; 11582 [labelType="html" label="MapPartitionsRDD [11582] toJavaRDD at <unknown>:0"]; } subgraph cluster25899 { label="MapPartitions"; 11583 [labelType="html" label="MapPartitionsRDD [11583] toJavaRDD at <unknown>:0"]; } subgraph cluster25909 { label="mapPartitions"; 11585 [labelType="html" label="MapPartitionsRDD [11585] toJavaRDD at <unknown>:0"]; } } 11572->11573; 11573->11574; 11574->11575; 11575->11576; 11576->11577; 11577->11578; 11578->11579; 11579->11580; 11580->11581; 11581->11582; 11582->11583; 11583->11584; 11584->11585; 11585->11586; }

Event Timeline

Enable zooming