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

digraph G { subgraph clusterstage_949 { label="Stage 949"; 9980 [labelType="html" label="SQLExecutionRDD [9980] run at <unknown>:0"]; 9988 [labelType="html" label="SQLExecutionRDD [9988] toJavaRDD at <unknown>:0"]; 9990 [labelType="html" label="PythonRDD [9990] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22326 { label="MicroBatchScan"; 9976 [labelType="html" label="DataSourceRDD [9976] run at <unknown>:0"]; 9977 [labelType="html" label="MapPartitionsRDD [9977] run at <unknown>:0"]; } subgraph cluster22325 { label="Project"; 9978 [labelType="html" label="MapPartitionsRDD [9978] run at <unknown>:0"]; } subgraph cluster22321 { label="WholeStageCodegen (1)"; 9979 [labelType="html" label="MapPartitionsRDD [9979] run at <unknown>:0"]; } subgraph cluster22335 { label="WholeStageCodegen (1)"; 9981 [labelType="html" label="MapPartitionsRDD [9981] toJavaRDD at <unknown>:0"]; } subgraph cluster22334 { label="Filter"; 9982 [labelType="html" label="MapPartitionsRDD [9982] toJavaRDD at <unknown>:0"]; } subgraph cluster22333 { label="Project"; 9983 [labelType="html" label="MapPartitionsRDD [9983] toJavaRDD at <unknown>:0"]; } subgraph cluster22330 { label="WholeStageCodegen (2)"; 9984 [labelType="html" label="MapPartitionsRDD [9984] toJavaRDD at <unknown>:0"]; } subgraph cluster22329 { label="Project"; 9985 [labelType="html" label="MapPartitionsRDD [9985] toJavaRDD at <unknown>:0"]; } subgraph cluster22328 { label="DeserializeToObject"; 9986 [labelType="html" label="MapPartitionsRDD [9986] toJavaRDD at <unknown>:0"]; } subgraph cluster22327 { label="MapPartitions"; 9987 [labelType="html" label="MapPartitionsRDD [9987] toJavaRDD at <unknown>:0"]; } subgraph cluster22337 { label="mapPartitions"; 9989 [labelType="html" label="MapPartitionsRDD [9989] toJavaRDD at <unknown>:0"]; } } 9976->9977; 9977->9978; 9978->9979; 9979->9980; 9980->9981; 9981->9982; 9982->9983; 9983->9984; 9984->9985; 9985->9986; 9986->9987; 9987->9988; 9988->9989; 9989->9990; }

Event Timeline

Enable zooming