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

digraph G { subgraph clusterstage_740 { label="Stage 740"; 7774 [labelType="html" label="SQLExecutionRDD [7774] run at <unknown>:0"]; 7782 [labelType="html" label="SQLExecutionRDD [7782] toJavaRDD at <unknown>:0"]; 7784 [labelType="html" label="PythonRDD [7784] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster17395 { label="MicroBatchScan"; 7770 [labelType="html" label="DataSourceRDD [7770] run at <unknown>:0"]; 7771 [labelType="html" label="MapPartitionsRDD [7771] run at <unknown>:0"]; } subgraph cluster17394 { label="Project"; 7772 [labelType="html" label="MapPartitionsRDD [7772] run at <unknown>:0"]; } subgraph cluster17390 { label="WholeStageCodegen (1)"; 7773 [labelType="html" label="MapPartitionsRDD [7773] run at <unknown>:0"]; } subgraph cluster17404 { label="WholeStageCodegen (1)"; 7775 [labelType="html" label="MapPartitionsRDD [7775] toJavaRDD at <unknown>:0"]; } subgraph cluster17403 { label="Filter"; 7776 [labelType="html" label="MapPartitionsRDD [7776] toJavaRDD at <unknown>:0"]; } subgraph cluster17402 { label="Project"; 7777 [labelType="html" label="MapPartitionsRDD [7777] toJavaRDD at <unknown>:0"]; } subgraph cluster17399 { label="WholeStageCodegen (2)"; 7778 [labelType="html" label="MapPartitionsRDD [7778] toJavaRDD at <unknown>:0"]; } subgraph cluster17398 { label="Project"; 7779 [labelType="html" label="MapPartitionsRDD [7779] toJavaRDD at <unknown>:0"]; } subgraph cluster17397 { label="DeserializeToObject"; 7780 [labelType="html" label="MapPartitionsRDD [7780] toJavaRDD at <unknown>:0"]; } subgraph cluster17396 { label="MapPartitions"; 7781 [labelType="html" label="MapPartitionsRDD [7781] toJavaRDD at <unknown>:0"]; } subgraph cluster17406 { label="mapPartitions"; 7783 [labelType="html" label="MapPartitionsRDD [7783] toJavaRDD at <unknown>:0"]; } } 7770->7771; 7771->7772; 7772->7773; 7773->7774; 7774->7775; 7775->7776; 7776->7777; 7777->7778; 7778->7779; 7779->7780; 7780->7781; 7781->7782; 7782->7783; 7783->7784; }

Event Timeline

Enable zooming