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

digraph G { subgraph clusterstage_623 { label="Stage 623"; 6557 [labelType="html" label="SQLExecutionRDD [6557] run at <unknown>:0"]; 6565 [labelType="html" label="SQLExecutionRDD [6565] toJavaRDD at <unknown>:0"]; 6567 [labelType="html" label="PythonRDD [6567] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster14665 { label="MicroBatchScan"; 6553 [labelType="html" label="DataSourceRDD [6553] run at <unknown>:0"]; 6554 [labelType="html" label="MapPartitionsRDD [6554] run at <unknown>:0"]; } subgraph cluster14664 { label="Project"; 6555 [labelType="html" label="MapPartitionsRDD [6555] run at <unknown>:0"]; } subgraph cluster14660 { label="WholeStageCodegen (1)"; 6556 [labelType="html" label="MapPartitionsRDD [6556] run at <unknown>:0"]; } subgraph cluster14674 { label="WholeStageCodegen (1)"; 6558 [labelType="html" label="MapPartitionsRDD [6558] toJavaRDD at <unknown>:0"]; } subgraph cluster14673 { label="Filter"; 6559 [labelType="html" label="MapPartitionsRDD [6559] toJavaRDD at <unknown>:0"]; } subgraph cluster14672 { label="Project"; 6560 [labelType="html" label="MapPartitionsRDD [6560] toJavaRDD at <unknown>:0"]; } subgraph cluster14669 { label="WholeStageCodegen (2)"; 6561 [labelType="html" label="MapPartitionsRDD [6561] toJavaRDD at <unknown>:0"]; } subgraph cluster14668 { label="Project"; 6562 [labelType="html" label="MapPartitionsRDD [6562] toJavaRDD at <unknown>:0"]; } subgraph cluster14667 { label="DeserializeToObject"; 6563 [labelType="html" label="MapPartitionsRDD [6563] toJavaRDD at <unknown>:0"]; } subgraph cluster14666 { label="MapPartitions"; 6564 [labelType="html" label="MapPartitionsRDD [6564] toJavaRDD at <unknown>:0"]; } subgraph cluster14676 { label="mapPartitions"; 6566 [labelType="html" label="MapPartitionsRDD [6566] toJavaRDD at <unknown>:0"]; } } 6553->6554; 6554->6555; 6555->6556; 6556->6557; 6557->6558; 6558->6559; 6559->6560; 6560->6561; 6561->6562; 6562->6563; 6563->6564; 6564->6565; 6565->6566; 6566->6567; }

Event Timeline

Enable zooming