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

digraph G { subgraph clusterstage_1425 { label="Stage 1425"; 14978 [labelType="html" label="SQLExecutionRDD [14978] run at <unknown>:0"]; 14986 [labelType="html" label="SQLExecutionRDD [14986] toJavaRDD at <unknown>:0"]; 14988 [labelType="html" label="PythonRDD [14988] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33512 { label="MicroBatchScan"; 14974 [labelType="html" label="DataSourceRDD [14974] run at <unknown>:0"]; 14975 [labelType="html" label="MapPartitionsRDD [14975] run at <unknown>:0"]; } subgraph cluster33511 { label="Project"; 14976 [labelType="html" label="MapPartitionsRDD [14976] run at <unknown>:0"]; } subgraph cluster33507 { label="WholeStageCodegen (1)"; 14977 [labelType="html" label="MapPartitionsRDD [14977] run at <unknown>:0"]; } subgraph cluster33521 { label="WholeStageCodegen (1)"; 14979 [labelType="html" label="MapPartitionsRDD [14979] toJavaRDD at <unknown>:0"]; } subgraph cluster33520 { label="Filter"; 14980 [labelType="html" label="MapPartitionsRDD [14980] toJavaRDD at <unknown>:0"]; } subgraph cluster33519 { label="Project"; 14981 [labelType="html" label="MapPartitionsRDD [14981] toJavaRDD at <unknown>:0"]; } subgraph cluster33516 { label="WholeStageCodegen (2)"; 14982 [labelType="html" label="MapPartitionsRDD [14982] toJavaRDD at <unknown>:0"]; } subgraph cluster33515 { label="Project"; 14983 [labelType="html" label="MapPartitionsRDD [14983] toJavaRDD at <unknown>:0"]; } subgraph cluster33514 { label="DeserializeToObject"; 14984 [labelType="html" label="MapPartitionsRDD [14984] toJavaRDD at <unknown>:0"]; } subgraph cluster33513 { label="MapPartitions"; 14985 [labelType="html" label="MapPartitionsRDD [14985] toJavaRDD at <unknown>:0"]; } subgraph cluster33523 { label="mapPartitions"; 14987 [labelType="html" label="MapPartitionsRDD [14987] toJavaRDD at <unknown>:0"]; } } 14974->14975; 14975->14976; 14976->14977; 14977->14978; 14978->14979; 14979->14980; 14980->14981; 14981->14982; 14982->14983; 14983->14984; 14984->14985; 14985->14986; 14986->14987; 14987->14988; }

Event Timeline

Enable zooming