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

digraph G { subgraph clusterstage_569 { label="Stage 569"; 5974 [labelType="html" label="SQLExecutionRDD [5974] run at <unknown>:0"]; 5982 [labelType="html" label="SQLExecutionRDD [5982] toJavaRDD at <unknown>:0"]; 5984 [labelType="html" label="PythonRDD [5984] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster13361 { label="MicroBatchScan"; 5970 [labelType="html" label="DataSourceRDD [5970] run at <unknown>:0"]; 5971 [labelType="html" label="MapPartitionsRDD [5971] run at <unknown>:0"]; } subgraph cluster13360 { label="Project"; 5972 [labelType="html" label="MapPartitionsRDD [5972] run at <unknown>:0"]; } subgraph cluster13356 { label="WholeStageCodegen (1)"; 5973 [labelType="html" label="MapPartitionsRDD [5973] run at <unknown>:0"]; } subgraph cluster13370 { label="WholeStageCodegen (1)"; 5975 [labelType="html" label="MapPartitionsRDD [5975] toJavaRDD at <unknown>:0"]; } subgraph cluster13369 { label="Filter"; 5976 [labelType="html" label="MapPartitionsRDD [5976] toJavaRDD at <unknown>:0"]; } subgraph cluster13368 { label="Project"; 5977 [labelType="html" label="MapPartitionsRDD [5977] toJavaRDD at <unknown>:0"]; } subgraph cluster13365 { label="WholeStageCodegen (2)"; 5978 [labelType="html" label="MapPartitionsRDD [5978] toJavaRDD at <unknown>:0"]; } subgraph cluster13364 { label="Project"; 5979 [labelType="html" label="MapPartitionsRDD [5979] toJavaRDD at <unknown>:0"]; } subgraph cluster13363 { label="DeserializeToObject"; 5980 [labelType="html" label="MapPartitionsRDD [5980] toJavaRDD at <unknown>:0"]; } subgraph cluster13362 { label="MapPartitions"; 5981 [labelType="html" label="MapPartitionsRDD [5981] toJavaRDD at <unknown>:0"]; } subgraph cluster13372 { label="mapPartitions"; 5983 [labelType="html" label="MapPartitionsRDD [5983] toJavaRDD at <unknown>:0"]; } } 5970->5971; 5971->5972; 5972->5973; 5973->5974; 5974->5975; 5975->5976; 5976->5977; 5977->5978; 5978->5979; 5979->5980; 5980->5981; 5981->5982; 5982->5983; 5983->5984; }

Event Timeline

Enable zooming