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

digraph G { subgraph clusterstage_1401 { label="Stage 1401"; 14726 [labelType="html" label="SQLExecutionRDD [14726] run at <unknown>:0"]; 14734 [labelType="html" label="SQLExecutionRDD [14734] toJavaRDD at <unknown>:0"]; 14736 [labelType="html" label="PythonRDD [14736] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster32948 { label="MicroBatchScan"; 14722 [labelType="html" label="DataSourceRDD [14722] run at <unknown>:0"]; 14723 [labelType="html" label="MapPartitionsRDD [14723] run at <unknown>:0"]; } subgraph cluster32947 { label="Project"; 14724 [labelType="html" label="MapPartitionsRDD [14724] run at <unknown>:0"]; } subgraph cluster32943 { label="WholeStageCodegen (1)"; 14725 [labelType="html" label="MapPartitionsRDD [14725] run at <unknown>:0"]; } subgraph cluster32957 { label="WholeStageCodegen (1)"; 14727 [labelType="html" label="MapPartitionsRDD [14727] toJavaRDD at <unknown>:0"]; } subgraph cluster32956 { label="Filter"; 14728 [labelType="html" label="MapPartitionsRDD [14728] toJavaRDD at <unknown>:0"]; } subgraph cluster32955 { label="Project"; 14729 [labelType="html" label="MapPartitionsRDD [14729] toJavaRDD at <unknown>:0"]; } subgraph cluster32952 { label="WholeStageCodegen (2)"; 14730 [labelType="html" label="MapPartitionsRDD [14730] toJavaRDD at <unknown>:0"]; } subgraph cluster32951 { label="Project"; 14731 [labelType="html" label="MapPartitionsRDD [14731] toJavaRDD at <unknown>:0"]; } subgraph cluster32950 { label="DeserializeToObject"; 14732 [labelType="html" label="MapPartitionsRDD [14732] toJavaRDD at <unknown>:0"]; } subgraph cluster32949 { label="MapPartitions"; 14733 [labelType="html" label="MapPartitionsRDD [14733] toJavaRDD at <unknown>:0"]; } subgraph cluster32959 { label="mapPartitions"; 14735 [labelType="html" label="MapPartitionsRDD [14735] toJavaRDD at <unknown>:0"]; } } 14722->14723; 14723->14724; 14724->14725; 14725->14726; 14726->14727; 14727->14728; 14728->14729; 14729->14730; 14730->14731; 14731->14732; 14732->14733; 14733->14734; 14734->14735; 14735->14736; }

Event Timeline

Enable zooming