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

digraph G { subgraph clusterstage_720 { label="Stage 720"; 7564 [labelType="html" label="SQLExecutionRDD [7564] run at <unknown>:0"]; 7572 [labelType="html" label="SQLExecutionRDD [7572] toJavaRDD at <unknown>:0"]; 7574 [labelType="html" label="PythonRDD [7574] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster16925 { label="MicroBatchScan"; 7560 [labelType="html" label="DataSourceRDD [7560] run at <unknown>:0"]; 7561 [labelType="html" label="MapPartitionsRDD [7561] run at <unknown>:0"]; } subgraph cluster16924 { label="Project"; 7562 [labelType="html" label="MapPartitionsRDD [7562] run at <unknown>:0"]; } subgraph cluster16920 { label="WholeStageCodegen (1)"; 7563 [labelType="html" label="MapPartitionsRDD [7563] run at <unknown>:0"]; } subgraph cluster16934 { label="WholeStageCodegen (1)"; 7565 [labelType="html" label="MapPartitionsRDD [7565] toJavaRDD at <unknown>:0"]; } subgraph cluster16933 { label="Filter"; 7566 [labelType="html" label="MapPartitionsRDD [7566] toJavaRDD at <unknown>:0"]; } subgraph cluster16932 { label="Project"; 7567 [labelType="html" label="MapPartitionsRDD [7567] toJavaRDD at <unknown>:0"]; } subgraph cluster16929 { label="WholeStageCodegen (2)"; 7568 [labelType="html" label="MapPartitionsRDD [7568] toJavaRDD at <unknown>:0"]; } subgraph cluster16928 { label="Project"; 7569 [labelType="html" label="MapPartitionsRDD [7569] toJavaRDD at <unknown>:0"]; } subgraph cluster16927 { label="DeserializeToObject"; 7570 [labelType="html" label="MapPartitionsRDD [7570] toJavaRDD at <unknown>:0"]; } subgraph cluster16926 { label="MapPartitions"; 7571 [labelType="html" label="MapPartitionsRDD [7571] toJavaRDD at <unknown>:0"]; } subgraph cluster16936 { label="mapPartitions"; 7573 [labelType="html" label="MapPartitionsRDD [7573] toJavaRDD at <unknown>:0"]; } } 7560->7561; 7561->7562; 7562->7563; 7563->7564; 7564->7565; 7565->7566; 7566->7567; 7567->7568; 7568->7569; 7569->7570; 7570->7571; 7571->7572; 7572->7573; 7573->7574; }

Event Timeline

Enable zooming