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

digraph G { subgraph clusterstage_1329 { label="Stage 1329"; 13948 [labelType="html" label="SQLExecutionRDD [13948] run at <unknown>:0"]; 13962 [labelType="html" label="SQLExecutionRDD [13962] toJavaRDD at <unknown>:0"]; 13964 [labelType="html" label="PythonRDD [13964] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31213 { label="MicroBatchScan"; 13944 [labelType="html" label="DataSourceRDD [13944] run at <unknown>:0"]; 13945 [labelType="html" label="MapPartitionsRDD [13945] run at <unknown>:0"]; } subgraph cluster31212 { label="Project"; 13946 [labelType="html" label="MapPartitionsRDD [13946] run at <unknown>:0"]; } subgraph cluster31208 { label="WholeStageCodegen (1)"; 13947 [labelType="html" label="MapPartitionsRDD [13947] run at <unknown>:0"]; } subgraph cluster31230 { label="WholeStageCodegen (1)"; 13955 [labelType="html" label="MapPartitionsRDD [13955] toJavaRDD at <unknown>:0"]; } subgraph cluster31229 { label="Filter"; 13956 [labelType="html" label="MapPartitionsRDD [13956] toJavaRDD at <unknown>:0"]; } subgraph cluster31228 { label="Project"; 13957 [labelType="html" label="MapPartitionsRDD [13957] toJavaRDD at <unknown>:0"]; } subgraph cluster31225 { label="WholeStageCodegen (2)"; 13958 [labelType="html" label="MapPartitionsRDD [13958] toJavaRDD at <unknown>:0"]; } subgraph cluster31224 { label="Project"; 13959 [labelType="html" label="MapPartitionsRDD [13959] toJavaRDD at <unknown>:0"]; } subgraph cluster31223 { label="DeserializeToObject"; 13960 [labelType="html" label="MapPartitionsRDD [13960] toJavaRDD at <unknown>:0"]; } subgraph cluster31222 { label="MapPartitions"; 13961 [labelType="html" label="MapPartitionsRDD [13961] toJavaRDD at <unknown>:0"]; } subgraph cluster31232 { label="mapPartitions"; 13963 [labelType="html" label="MapPartitionsRDD [13963] toJavaRDD at <unknown>:0"]; } } 13944->13945; 13945->13946; 13946->13947; 13947->13948; 13948->13955; 13955->13956; 13956->13957; 13957->13958; 13958->13959; 13959->13960; 13960->13961; 13961->13962; 13962->13963; 13963->13964; }

Event Timeline

Enable zooming