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

digraph G { subgraph clusterstage_1710 { label="Stage 1710"; 17960 [labelType="html" label="SQLExecutionRDD [17960] run at <unknown>:0"]; 17974 [labelType="html" label="SQLExecutionRDD [17974] toJavaRDD at <unknown>:0"]; 17976 [labelType="html" label="PythonRDD [17976] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster40186 { label="MicroBatchScan"; 17956 [labelType="html" label="DataSourceRDD [17956] run at <unknown>:0"]; 17957 [labelType="html" label="MapPartitionsRDD [17957] run at <unknown>:0"]; } subgraph cluster40185 { label="Project"; 17958 [labelType="html" label="MapPartitionsRDD [17958] run at <unknown>:0"]; } subgraph cluster40181 { label="WholeStageCodegen (1)"; 17959 [labelType="html" label="MapPartitionsRDD [17959] run at <unknown>:0"]; } subgraph cluster40203 { label="WholeStageCodegen (1)"; 17967 [labelType="html" label="MapPartitionsRDD [17967] toJavaRDD at <unknown>:0"]; } subgraph cluster40202 { label="Filter"; 17968 [labelType="html" label="MapPartitionsRDD [17968] toJavaRDD at <unknown>:0"]; } subgraph cluster40201 { label="Project"; 17969 [labelType="html" label="MapPartitionsRDD [17969] toJavaRDD at <unknown>:0"]; } subgraph cluster40198 { label="WholeStageCodegen (2)"; 17970 [labelType="html" label="MapPartitionsRDD [17970] toJavaRDD at <unknown>:0"]; } subgraph cluster40197 { label="Project"; 17971 [labelType="html" label="MapPartitionsRDD [17971] toJavaRDD at <unknown>:0"]; } subgraph cluster40196 { label="DeserializeToObject"; 17972 [labelType="html" label="MapPartitionsRDD [17972] toJavaRDD at <unknown>:0"]; } subgraph cluster40195 { label="MapPartitions"; 17973 [labelType="html" label="MapPartitionsRDD [17973] toJavaRDD at <unknown>:0"]; } subgraph cluster40205 { label="mapPartitions"; 17975 [labelType="html" label="MapPartitionsRDD [17975] toJavaRDD at <unknown>:0"]; } } 17956->17957; 17957->17958; 17958->17959; 17959->17960; 17960->17967; 17967->17968; 17968->17969; 17969->17970; 17970->17971; 17971->17972; 17972->17973; 17973->17974; 17974->17975; 17975->17976; }

Event Timeline

Enable zooming