processing-stream-kafka-raw-to-minio - Details for Stage 544 (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: 544

digraph G { subgraph clusterstage_544 { label="Stage 544"; 5716 [labelType="html" label="SQLExecutionRDD [5716] run at <unknown>:0"]; 5724 [labelType="html" label="SQLExecutionRDD [5724] toJavaRDD at <unknown>:0"]; 5726 [labelType="html" label="PythonRDD [5726] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster12789 { label="MicroBatchScan"; 5712 [labelType="html" label="DataSourceRDD [5712] run at <unknown>:0"]; 5713 [labelType="html" label="MapPartitionsRDD [5713] run at <unknown>:0"]; } subgraph cluster12788 { label="Project"; 5714 [labelType="html" label="MapPartitionsRDD [5714] run at <unknown>:0"]; } subgraph cluster12784 { label="WholeStageCodegen (1)"; 5715 [labelType="html" label="MapPartitionsRDD [5715] run at <unknown>:0"]; } subgraph cluster12798 { label="WholeStageCodegen (1)"; 5717 [labelType="html" label="MapPartitionsRDD [5717] toJavaRDD at <unknown>:0"]; } subgraph cluster12797 { label="Filter"; 5718 [labelType="html" label="MapPartitionsRDD [5718] toJavaRDD at <unknown>:0"]; } subgraph cluster12796 { label="Project"; 5719 [labelType="html" label="MapPartitionsRDD [5719] toJavaRDD at <unknown>:0"]; } subgraph cluster12793 { label="WholeStageCodegen (2)"; 5720 [labelType="html" label="MapPartitionsRDD [5720] toJavaRDD at <unknown>:0"]; } subgraph cluster12792 { label="Project"; 5721 [labelType="html" label="MapPartitionsRDD [5721] toJavaRDD at <unknown>:0"]; } subgraph cluster12791 { label="DeserializeToObject"; 5722 [labelType="html" label="MapPartitionsRDD [5722] toJavaRDD at <unknown>:0"]; } subgraph cluster12790 { label="MapPartitions"; 5723 [labelType="html" label="MapPartitionsRDD [5723] toJavaRDD at <unknown>:0"]; } subgraph cluster12800 { label="mapPartitions"; 5725 [labelType="html" label="MapPartitionsRDD [5725] toJavaRDD at <unknown>:0"]; } } 5712->5713; 5713->5714; 5714->5715; 5715->5716; 5716->5717; 5717->5718; 5718->5719; 5719->5720; 5720->5721; 5721->5722; 5722->5723; 5723->5724; 5724->5725; 5725->5726; }

Event Timeline

Enable zooming