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

digraph G { subgraph clusterstage_758 { label="Stage 758"; 7963 [labelType="html" label="SQLExecutionRDD [7963] run at <unknown>:0"]; 7971 [labelType="html" label="SQLExecutionRDD [7971] toJavaRDD at <unknown>:0"]; 7973 [labelType="html" label="PythonRDD [7973] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster17818 { label="MicroBatchScan"; 7959 [labelType="html" label="DataSourceRDD [7959] run at <unknown>:0"]; 7960 [labelType="html" label="MapPartitionsRDD [7960] run at <unknown>:0"]; } subgraph cluster17817 { label="Project"; 7961 [labelType="html" label="MapPartitionsRDD [7961] run at <unknown>:0"]; } subgraph cluster17813 { label="WholeStageCodegen (1)"; 7962 [labelType="html" label="MapPartitionsRDD [7962] run at <unknown>:0"]; } subgraph cluster17827 { label="WholeStageCodegen (1)"; 7964 [labelType="html" label="MapPartitionsRDD [7964] toJavaRDD at <unknown>:0"]; } subgraph cluster17826 { label="Filter"; 7965 [labelType="html" label="MapPartitionsRDD [7965] toJavaRDD at <unknown>:0"]; } subgraph cluster17825 { label="Project"; 7966 [labelType="html" label="MapPartitionsRDD [7966] toJavaRDD at <unknown>:0"]; } subgraph cluster17822 { label="WholeStageCodegen (2)"; 7967 [labelType="html" label="MapPartitionsRDD [7967] toJavaRDD at <unknown>:0"]; } subgraph cluster17821 { label="Project"; 7968 [labelType="html" label="MapPartitionsRDD [7968] toJavaRDD at <unknown>:0"]; } subgraph cluster17820 { label="DeserializeToObject"; 7969 [labelType="html" label="MapPartitionsRDD [7969] toJavaRDD at <unknown>:0"]; } subgraph cluster17819 { label="MapPartitions"; 7970 [labelType="html" label="MapPartitionsRDD [7970] toJavaRDD at <unknown>:0"]; } subgraph cluster17829 { label="mapPartitions"; 7972 [labelType="html" label="MapPartitionsRDD [7972] toJavaRDD at <unknown>:0"]; } } 7959->7960; 7960->7961; 7961->7962; 7962->7963; 7963->7964; 7964->7965; 7965->7966; 7966->7967; 7967->7968; 7968->7969; 7969->7970; 7970->7971; 7971->7972; 7972->7973; }

Event Timeline

Enable zooming