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

digraph G { subgraph clusterstage_1320 { label="Stage 1320"; 13864 [labelType="html" label="SQLExecutionRDD [13864] run at <unknown>:0"]; 13872 [labelType="html" label="SQLExecutionRDD [13872] toJavaRDD at <unknown>:0"]; 13874 [labelType="html" label="PythonRDD [13874] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster31025 { label="MicroBatchScan"; 13860 [labelType="html" label="DataSourceRDD [13860] run at <unknown>:0"]; 13861 [labelType="html" label="MapPartitionsRDD [13861] run at <unknown>:0"]; } subgraph cluster31024 { label="Project"; 13862 [labelType="html" label="MapPartitionsRDD [13862] run at <unknown>:0"]; } subgraph cluster31020 { label="WholeStageCodegen (1)"; 13863 [labelType="html" label="MapPartitionsRDD [13863] run at <unknown>:0"]; } subgraph cluster31034 { label="WholeStageCodegen (1)"; 13865 [labelType="html" label="MapPartitionsRDD [13865] toJavaRDD at <unknown>:0"]; } subgraph cluster31033 { label="Filter"; 13866 [labelType="html" label="MapPartitionsRDD [13866] toJavaRDD at <unknown>:0"]; } subgraph cluster31032 { label="Project"; 13867 [labelType="html" label="MapPartitionsRDD [13867] toJavaRDD at <unknown>:0"]; } subgraph cluster31029 { label="WholeStageCodegen (2)"; 13868 [labelType="html" label="MapPartitionsRDD [13868] toJavaRDD at <unknown>:0"]; } subgraph cluster31028 { label="Project"; 13869 [labelType="html" label="MapPartitionsRDD [13869] toJavaRDD at <unknown>:0"]; } subgraph cluster31027 { label="DeserializeToObject"; 13870 [labelType="html" label="MapPartitionsRDD [13870] toJavaRDD at <unknown>:0"]; } subgraph cluster31026 { label="MapPartitions"; 13871 [labelType="html" label="MapPartitionsRDD [13871] toJavaRDD at <unknown>:0"]; } subgraph cluster31036 { label="mapPartitions"; 13873 [labelType="html" label="MapPartitionsRDD [13873] toJavaRDD at <unknown>:0"]; } } 13860->13861; 13861->13862; 13862->13863; 13863->13864; 13864->13865; 13865->13866; 13866->13867; 13867->13868; 13868->13869; 13869->13870; 13870->13871; 13871->13872; 13872->13873; 13873->13874; }

Event Timeline

Enable zooming