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

digraph G { subgraph clusterstage_1019 { label="Stage 1019"; 10715 [labelType="html" label="SQLExecutionRDD [10715] run at <unknown>:0"]; 10723 [labelType="html" label="SQLExecutionRDD [10723] toJavaRDD at <unknown>:0"]; 10725 [labelType="html" label="PythonRDD [10725] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23971 { label="MicroBatchScan"; 10711 [labelType="html" label="DataSourceRDD [10711] run at <unknown>:0"]; 10712 [labelType="html" label="MapPartitionsRDD [10712] run at <unknown>:0"]; } subgraph cluster23970 { label="Project"; 10713 [labelType="html" label="MapPartitionsRDD [10713] run at <unknown>:0"]; } subgraph cluster23966 { label="WholeStageCodegen (1)"; 10714 [labelType="html" label="MapPartitionsRDD [10714] run at <unknown>:0"]; } subgraph cluster23980 { label="WholeStageCodegen (1)"; 10716 [labelType="html" label="MapPartitionsRDD [10716] toJavaRDD at <unknown>:0"]; } subgraph cluster23979 { label="Filter"; 10717 [labelType="html" label="MapPartitionsRDD [10717] toJavaRDD at <unknown>:0"]; } subgraph cluster23978 { label="Project"; 10718 [labelType="html" label="MapPartitionsRDD [10718] toJavaRDD at <unknown>:0"]; } subgraph cluster23975 { label="WholeStageCodegen (2)"; 10719 [labelType="html" label="MapPartitionsRDD [10719] toJavaRDD at <unknown>:0"]; } subgraph cluster23974 { label="Project"; 10720 [labelType="html" label="MapPartitionsRDD [10720] toJavaRDD at <unknown>:0"]; } subgraph cluster23973 { label="DeserializeToObject"; 10721 [labelType="html" label="MapPartitionsRDD [10721] toJavaRDD at <unknown>:0"]; } subgraph cluster23972 { label="MapPartitions"; 10722 [labelType="html" label="MapPartitionsRDD [10722] toJavaRDD at <unknown>:0"]; } subgraph cluster23982 { label="mapPartitions"; 10724 [labelType="html" label="MapPartitionsRDD [10724] toJavaRDD at <unknown>:0"]; } } 10711->10712; 10712->10713; 10713->10714; 10714->10715; 10715->10716; 10716->10717; 10717->10718; 10718->10719; 10719->10720; 10720->10721; 10721->10722; 10722->10723; 10723->10724; 10724->10725; }

Event Timeline

Enable zooming