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

digraph G { subgraph clusterstage_87 { label="Stage 87"; 907 [labelType="html" label="SQLExecutionRDD [907] run at <unknown>:0"]; 921 [labelType="html" label="SQLExecutionRDD [921] toJavaRDD at <unknown>:0"]; 923 [labelType="html" label="PythonRDD [923] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2026 { label="MicroBatchScan"; 903 [labelType="html" label="DataSourceRDD [903] run at <unknown>:0"]; 904 [labelType="html" label="MapPartitionsRDD [904] run at <unknown>:0"]; } subgraph cluster2025 { label="Project"; 905 [labelType="html" label="MapPartitionsRDD [905] run at <unknown>:0"]; } subgraph cluster2021 { label="WholeStageCodegen (1)"; 906 [labelType="html" label="MapPartitionsRDD [906] run at <unknown>:0"]; } subgraph cluster2043 { label="WholeStageCodegen (1)"; 914 [labelType="html" label="MapPartitionsRDD [914] toJavaRDD at <unknown>:0"]; } subgraph cluster2042 { label="Filter"; 915 [labelType="html" label="MapPartitionsRDD [915] toJavaRDD at <unknown>:0"]; } subgraph cluster2041 { label="Project"; 916 [labelType="html" label="MapPartitionsRDD [916] toJavaRDD at <unknown>:0"]; } subgraph cluster2038 { label="WholeStageCodegen (2)"; 917 [labelType="html" label="MapPartitionsRDD [917] toJavaRDD at <unknown>:0"]; } subgraph cluster2037 { label="Project"; 918 [labelType="html" label="MapPartitionsRDD [918] toJavaRDD at <unknown>:0"]; } subgraph cluster2036 { label="DeserializeToObject"; 919 [labelType="html" label="MapPartitionsRDD [919] toJavaRDD at <unknown>:0"]; } subgraph cluster2035 { label="MapPartitions"; 920 [labelType="html" label="MapPartitionsRDD [920] toJavaRDD at <unknown>:0"]; } subgraph cluster2045 { label="mapPartitions"; 922 [labelType="html" label="MapPartitionsRDD [922] toJavaRDD at <unknown>:0"]; } } 903->904; 904->905; 905->906; 906->907; 907->914; 914->915; 915->916; 916->917; 917->918; 918->919; 919->920; 920->921; 921->922; 922->923; }

Event Timeline

Enable zooming