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

digraph G { subgraph clusterstage_853 { label="Stage 853"; 8956 [labelType="html" label="SQLExecutionRDD [8956] run at <unknown>:0"]; 8964 [labelType="html" label="SQLExecutionRDD [8964] toJavaRDD at <unknown>:0"]; 8966 [labelType="html" label="PythonRDD [8966] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster20035 { label="MicroBatchScan"; 8952 [labelType="html" label="DataSourceRDD [8952] run at <unknown>:0"]; 8953 [labelType="html" label="MapPartitionsRDD [8953] run at <unknown>:0"]; } subgraph cluster20034 { label="Project"; 8954 [labelType="html" label="MapPartitionsRDD [8954] run at <unknown>:0"]; } subgraph cluster20030 { label="WholeStageCodegen (1)"; 8955 [labelType="html" label="MapPartitionsRDD [8955] run at <unknown>:0"]; } subgraph cluster20044 { label="WholeStageCodegen (1)"; 8957 [labelType="html" label="MapPartitionsRDD [8957] toJavaRDD at <unknown>:0"]; } subgraph cluster20043 { label="Filter"; 8958 [labelType="html" label="MapPartitionsRDD [8958] toJavaRDD at <unknown>:0"]; } subgraph cluster20042 { label="Project"; 8959 [labelType="html" label="MapPartitionsRDD [8959] toJavaRDD at <unknown>:0"]; } subgraph cluster20039 { label="WholeStageCodegen (2)"; 8960 [labelType="html" label="MapPartitionsRDD [8960] toJavaRDD at <unknown>:0"]; } subgraph cluster20038 { label="Project"; 8961 [labelType="html" label="MapPartitionsRDD [8961] toJavaRDD at <unknown>:0"]; } subgraph cluster20037 { label="DeserializeToObject"; 8962 [labelType="html" label="MapPartitionsRDD [8962] toJavaRDD at <unknown>:0"]; } subgraph cluster20036 { label="MapPartitions"; 8963 [labelType="html" label="MapPartitionsRDD [8963] toJavaRDD at <unknown>:0"]; } subgraph cluster20046 { label="mapPartitions"; 8965 [labelType="html" label="MapPartitionsRDD [8965] toJavaRDD at <unknown>:0"]; } } 8952->8953; 8953->8954; 8954->8955; 8955->8956; 8956->8957; 8957->8958; 8958->8959; 8959->8960; 8960->8961; 8961->8962; 8962->8963; 8963->8964; 8964->8965; 8965->8966; }

Event Timeline

Enable zooming