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

digraph G { subgraph clusterstage_844 { label="Stage 844"; 8866 [labelType="html" label="SQLExecutionRDD [8866] run at <unknown>:0"]; 8874 [labelType="html" label="SQLExecutionRDD [8874] toJavaRDD at <unknown>:0"]; 8876 [labelType="html" label="PythonRDD [8876] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster19839 { label="MicroBatchScan"; 8862 [labelType="html" label="DataSourceRDD [8862] run at <unknown>:0"]; 8863 [labelType="html" label="MapPartitionsRDD [8863] run at <unknown>:0"]; } subgraph cluster19838 { label="Project"; 8864 [labelType="html" label="MapPartitionsRDD [8864] run at <unknown>:0"]; } subgraph cluster19834 { label="WholeStageCodegen (1)"; 8865 [labelType="html" label="MapPartitionsRDD [8865] run at <unknown>:0"]; } subgraph cluster19848 { label="WholeStageCodegen (1)"; 8867 [labelType="html" label="MapPartitionsRDD [8867] toJavaRDD at <unknown>:0"]; } subgraph cluster19847 { label="Filter"; 8868 [labelType="html" label="MapPartitionsRDD [8868] toJavaRDD at <unknown>:0"]; } subgraph cluster19846 { label="Project"; 8869 [labelType="html" label="MapPartitionsRDD [8869] toJavaRDD at <unknown>:0"]; } subgraph cluster19843 { label="WholeStageCodegen (2)"; 8870 [labelType="html" label="MapPartitionsRDD [8870] toJavaRDD at <unknown>:0"]; } subgraph cluster19842 { label="Project"; 8871 [labelType="html" label="MapPartitionsRDD [8871] toJavaRDD at <unknown>:0"]; } subgraph cluster19841 { label="DeserializeToObject"; 8872 [labelType="html" label="MapPartitionsRDD [8872] toJavaRDD at <unknown>:0"]; } subgraph cluster19840 { label="MapPartitions"; 8873 [labelType="html" label="MapPartitionsRDD [8873] toJavaRDD at <unknown>:0"]; } subgraph cluster19850 { label="mapPartitions"; 8875 [labelType="html" label="MapPartitionsRDD [8875] toJavaRDD at <unknown>:0"]; } } 8862->8863; 8863->8864; 8864->8865; 8865->8866; 8866->8867; 8867->8868; 8868->8869; 8869->8870; 8870->8871; 8871->8872; 8872->8873; 8873->8874; 8874->8875; 8875->8876; }

Event Timeline

Enable zooming