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

digraph G { subgraph clusterstage_1331 { label="Stage 1331"; 13975 [labelType="html" label="SQLExecutionRDD [13975] run at <unknown>:0"]; 13983 [labelType="html" label="SQLExecutionRDD [13983] toJavaRDD at <unknown>:0"]; 13985 [labelType="html" label="PythonRDD [13985] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31268 { label="MicroBatchScan"; 13971 [labelType="html" label="DataSourceRDD [13971] run at <unknown>:0"]; 13972 [labelType="html" label="MapPartitionsRDD [13972] run at <unknown>:0"]; } subgraph cluster31267 { label="Project"; 13973 [labelType="html" label="MapPartitionsRDD [13973] run at <unknown>:0"]; } subgraph cluster31263 { label="WholeStageCodegen (1)"; 13974 [labelType="html" label="MapPartitionsRDD [13974] run at <unknown>:0"]; } subgraph cluster31277 { label="WholeStageCodegen (1)"; 13976 [labelType="html" label="MapPartitionsRDD [13976] toJavaRDD at <unknown>:0"]; } subgraph cluster31276 { label="Filter"; 13977 [labelType="html" label="MapPartitionsRDD [13977] toJavaRDD at <unknown>:0"]; } subgraph cluster31275 { label="Project"; 13978 [labelType="html" label="MapPartitionsRDD [13978] toJavaRDD at <unknown>:0"]; } subgraph cluster31272 { label="WholeStageCodegen (2)"; 13979 [labelType="html" label="MapPartitionsRDD [13979] toJavaRDD at <unknown>:0"]; } subgraph cluster31271 { label="Project"; 13980 [labelType="html" label="MapPartitionsRDD [13980] toJavaRDD at <unknown>:0"]; } subgraph cluster31270 { label="DeserializeToObject"; 13981 [labelType="html" label="MapPartitionsRDD [13981] toJavaRDD at <unknown>:0"]; } subgraph cluster31269 { label="MapPartitions"; 13982 [labelType="html" label="MapPartitionsRDD [13982] toJavaRDD at <unknown>:0"]; } subgraph cluster31279 { label="mapPartitions"; 13984 [labelType="html" label="MapPartitionsRDD [13984] toJavaRDD at <unknown>:0"]; } } 13971->13972; 13972->13973; 13973->13974; 13974->13975; 13975->13976; 13976->13977; 13977->13978; 13978->13979; 13979->13980; 13980->13981; 13981->13982; 13982->13983; 13983->13984; 13984->13985; }

Event Timeline

Enable zooming