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

digraph G { subgraph clusterstage_1365 { label="Stage 1365"; 14348 [labelType="html" label="SQLExecutionRDD [14348] run at <unknown>:0"]; 14356 [labelType="html" label="SQLExecutionRDD [14356] toJavaRDD at <unknown>:0"]; 14358 [labelType="html" label="PythonRDD [14358] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32102 { label="MicroBatchScan"; 14344 [labelType="html" label="DataSourceRDD [14344] run at <unknown>:0"]; 14345 [labelType="html" label="MapPartitionsRDD [14345] run at <unknown>:0"]; } subgraph cluster32101 { label="Project"; 14346 [labelType="html" label="MapPartitionsRDD [14346] run at <unknown>:0"]; } subgraph cluster32097 { label="WholeStageCodegen (1)"; 14347 [labelType="html" label="MapPartitionsRDD [14347] run at <unknown>:0"]; } subgraph cluster32111 { label="WholeStageCodegen (1)"; 14349 [labelType="html" label="MapPartitionsRDD [14349] toJavaRDD at <unknown>:0"]; } subgraph cluster32110 { label="Filter"; 14350 [labelType="html" label="MapPartitionsRDD [14350] toJavaRDD at <unknown>:0"]; } subgraph cluster32109 { label="Project"; 14351 [labelType="html" label="MapPartitionsRDD [14351] toJavaRDD at <unknown>:0"]; } subgraph cluster32106 { label="WholeStageCodegen (2)"; 14352 [labelType="html" label="MapPartitionsRDD [14352] toJavaRDD at <unknown>:0"]; } subgraph cluster32105 { label="Project"; 14353 [labelType="html" label="MapPartitionsRDD [14353] toJavaRDD at <unknown>:0"]; } subgraph cluster32104 { label="DeserializeToObject"; 14354 [labelType="html" label="MapPartitionsRDD [14354] toJavaRDD at <unknown>:0"]; } subgraph cluster32103 { label="MapPartitions"; 14355 [labelType="html" label="MapPartitionsRDD [14355] toJavaRDD at <unknown>:0"]; } subgraph cluster32113 { label="mapPartitions"; 14357 [labelType="html" label="MapPartitionsRDD [14357] toJavaRDD at <unknown>:0"]; } } 14344->14345; 14345->14346; 14346->14347; 14347->14348; 14348->14349; 14349->14350; 14350->14351; 14351->14352; 14352->14353; 14353->14354; 14354->14355; 14355->14356; 14356->14357; 14357->14358; }

Event Timeline

Enable zooming