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

digraph G { subgraph clusterstage_1038 { label="Stage 1038"; 10904 [labelType="html" label="SQLExecutionRDD [10904] run at <unknown>:0"]; 10918 [labelType="html" label="SQLExecutionRDD [10918] toJavaRDD at <unknown>:0"]; 10920 [labelType="html" label="PythonRDD [10920] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster24394 { label="MicroBatchScan"; 10900 [labelType="html" label="DataSourceRDD [10900] run at <unknown>:0"]; 10901 [labelType="html" label="MapPartitionsRDD [10901] run at <unknown>:0"]; } subgraph cluster24393 { label="Project"; 10902 [labelType="html" label="MapPartitionsRDD [10902] run at <unknown>:0"]; } subgraph cluster24389 { label="WholeStageCodegen (1)"; 10903 [labelType="html" label="MapPartitionsRDD [10903] run at <unknown>:0"]; } subgraph cluster24411 { label="WholeStageCodegen (1)"; 10911 [labelType="html" label="MapPartitionsRDD [10911] toJavaRDD at <unknown>:0"]; } subgraph cluster24410 { label="Filter"; 10912 [labelType="html" label="MapPartitionsRDD [10912] toJavaRDD at <unknown>:0"]; } subgraph cluster24409 { label="Project"; 10913 [labelType="html" label="MapPartitionsRDD [10913] toJavaRDD at <unknown>:0"]; } subgraph cluster24406 { label="WholeStageCodegen (2)"; 10914 [labelType="html" label="MapPartitionsRDD [10914] toJavaRDD at <unknown>:0"]; } subgraph cluster24405 { label="Project"; 10915 [labelType="html" label="MapPartitionsRDD [10915] toJavaRDD at <unknown>:0"]; } subgraph cluster24404 { label="DeserializeToObject"; 10916 [labelType="html" label="MapPartitionsRDD [10916] toJavaRDD at <unknown>:0"]; } subgraph cluster24403 { label="MapPartitions"; 10917 [labelType="html" label="MapPartitionsRDD [10917] toJavaRDD at <unknown>:0"]; } subgraph cluster24413 { label="mapPartitions"; 10919 [labelType="html" label="MapPartitionsRDD [10919] toJavaRDD at <unknown>:0"]; } } 10900->10901; 10901->10902; 10902->10903; 10903->10904; 10904->10911; 10911->10912; 10912->10913; 10913->10914; 10914->10915; 10915->10916; 10916->10917; 10917->10918; 10918->10919; 10919->10920; }

Event Timeline

Enable zooming