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

digraph G { subgraph clusterstage_1614 { label="Stage 1614"; 16952 [labelType="html" label="SQLExecutionRDD [16952] run at <unknown>:0"]; 16966 [labelType="html" label="SQLExecutionRDD [16966] toJavaRDD at <unknown>:0"]; 16968 [labelType="html" label="PythonRDD [16968] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster37930 { label="MicroBatchScan"; 16948 [labelType="html" label="DataSourceRDD [16948] run at <unknown>:0"]; 16949 [labelType="html" label="MapPartitionsRDD [16949] run at <unknown>:0"]; } subgraph cluster37929 { label="Project"; 16950 [labelType="html" label="MapPartitionsRDD [16950] run at <unknown>:0"]; } subgraph cluster37925 { label="WholeStageCodegen (1)"; 16951 [labelType="html" label="MapPartitionsRDD [16951] run at <unknown>:0"]; } subgraph cluster37947 { label="WholeStageCodegen (1)"; 16959 [labelType="html" label="MapPartitionsRDD [16959] toJavaRDD at <unknown>:0"]; } subgraph cluster37946 { label="Filter"; 16960 [labelType="html" label="MapPartitionsRDD [16960] toJavaRDD at <unknown>:0"]; } subgraph cluster37945 { label="Project"; 16961 [labelType="html" label="MapPartitionsRDD [16961] toJavaRDD at <unknown>:0"]; } subgraph cluster37942 { label="WholeStageCodegen (2)"; 16962 [labelType="html" label="MapPartitionsRDD [16962] toJavaRDD at <unknown>:0"]; } subgraph cluster37941 { label="Project"; 16963 [labelType="html" label="MapPartitionsRDD [16963] toJavaRDD at <unknown>:0"]; } subgraph cluster37940 { label="DeserializeToObject"; 16964 [labelType="html" label="MapPartitionsRDD [16964] toJavaRDD at <unknown>:0"]; } subgraph cluster37939 { label="MapPartitions"; 16965 [labelType="html" label="MapPartitionsRDD [16965] toJavaRDD at <unknown>:0"]; } subgraph cluster37949 { label="mapPartitions"; 16967 [labelType="html" label="MapPartitionsRDD [16967] toJavaRDD at <unknown>:0"]; } } 16948->16949; 16949->16950; 16950->16951; 16951->16952; 16952->16959; 16959->16960; 16960->16961; 16961->16962; 16962->16963; 16963->16964; 16964->16965; 16965->16966; 16966->16967; 16967->16968; }

Event Timeline

Enable zooming