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

digraph G { subgraph clusterstage_462 { label="Stage 462"; 4855 [labelType="html" label="SQLExecutionRDD [4855] run at <unknown>:0"]; 4863 [labelType="html" label="SQLExecutionRDD [4863] toJavaRDD at <unknown>:0"]; 4865 [labelType="html" label="PythonRDD [4865] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster10862 { label="MicroBatchScan"; 4851 [labelType="html" label="DataSourceRDD [4851] run at <unknown>:0"]; 4852 [labelType="html" label="MapPartitionsRDD [4852] run at <unknown>:0"]; } subgraph cluster10861 { label="Project"; 4853 [labelType="html" label="MapPartitionsRDD [4853] run at <unknown>:0"]; } subgraph cluster10857 { label="WholeStageCodegen (1)"; 4854 [labelType="html" label="MapPartitionsRDD [4854] run at <unknown>:0"]; } subgraph cluster10871 { label="WholeStageCodegen (1)"; 4856 [labelType="html" label="MapPartitionsRDD [4856] toJavaRDD at <unknown>:0"]; } subgraph cluster10870 { label="Filter"; 4857 [labelType="html" label="MapPartitionsRDD [4857] toJavaRDD at <unknown>:0"]; } subgraph cluster10869 { label="Project"; 4858 [labelType="html" label="MapPartitionsRDD [4858] toJavaRDD at <unknown>:0"]; } subgraph cluster10866 { label="WholeStageCodegen (2)"; 4859 [labelType="html" label="MapPartitionsRDD [4859] toJavaRDD at <unknown>:0"]; } subgraph cluster10865 { label="Project"; 4860 [labelType="html" label="MapPartitionsRDD [4860] toJavaRDD at <unknown>:0"]; } subgraph cluster10864 { label="DeserializeToObject"; 4861 [labelType="html" label="MapPartitionsRDD [4861] toJavaRDD at <unknown>:0"]; } subgraph cluster10863 { label="MapPartitions"; 4862 [labelType="html" label="MapPartitionsRDD [4862] toJavaRDD at <unknown>:0"]; } subgraph cluster10873 { label="mapPartitions"; 4864 [labelType="html" label="MapPartitionsRDD [4864] toJavaRDD at <unknown>:0"]; } } 4851->4852; 4852->4853; 4853->4854; 4854->4855; 4855->4856; 4856->4857; 4857->4858; 4858->4859; 4859->4860; 4860->4861; 4861->4862; 4862->4863; 4863->4864; 4864->4865; }

Event Timeline

Enable zooming