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

digraph G { subgraph clusterstage_88 { label="Stage 88"; 928 [labelType="html" label="SQLExecutionRDD [928] run at <unknown>:0"]; 936 [labelType="html" label="SQLExecutionRDD [936] toJavaRDD at <unknown>:0"]; 938 [labelType="html" label="PythonRDD [938] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2073 { label="MicroBatchScan"; 924 [labelType="html" label="DataSourceRDD [924] run at <unknown>:0"]; 925 [labelType="html" label="MapPartitionsRDD [925] run at <unknown>:0"]; } subgraph cluster2072 { label="Project"; 926 [labelType="html" label="MapPartitionsRDD [926] run at <unknown>:0"]; } subgraph cluster2068 { label="WholeStageCodegen (1)"; 927 [labelType="html" label="MapPartitionsRDD [927] run at <unknown>:0"]; } subgraph cluster2082 { label="WholeStageCodegen (1)"; 929 [labelType="html" label="MapPartitionsRDD [929] toJavaRDD at <unknown>:0"]; } subgraph cluster2081 { label="Filter"; 930 [labelType="html" label="MapPartitionsRDD [930] toJavaRDD at <unknown>:0"]; } subgraph cluster2080 { label="Project"; 931 [labelType="html" label="MapPartitionsRDD [931] toJavaRDD at <unknown>:0"]; } subgraph cluster2077 { label="WholeStageCodegen (2)"; 932 [labelType="html" label="MapPartitionsRDD [932] toJavaRDD at <unknown>:0"]; } subgraph cluster2076 { label="Project"; 933 [labelType="html" label="MapPartitionsRDD [933] toJavaRDD at <unknown>:0"]; } subgraph cluster2075 { label="DeserializeToObject"; 934 [labelType="html" label="MapPartitionsRDD [934] toJavaRDD at <unknown>:0"]; } subgraph cluster2074 { label="MapPartitions"; 935 [labelType="html" label="MapPartitionsRDD [935] toJavaRDD at <unknown>:0"]; } subgraph cluster2084 { label="mapPartitions"; 937 [labelType="html" label="MapPartitionsRDD [937] toJavaRDD at <unknown>:0"]; } } 924->925; 925->926; 926->927; 927->928; 928->929; 929->930; 930->931; 931->932; 932->933; 933->934; 934->935; 935->936; 936->937; 937->938; }

Event Timeline

Enable zooming