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

digraph G { subgraph clusterstage_1433 { label="Stage 1433"; 15062 [labelType="html" label="SQLExecutionRDD [15062] run at <unknown>:0"]; 15070 [labelType="html" label="SQLExecutionRDD [15070] toJavaRDD at <unknown>:0"]; 15072 [labelType="html" label="PythonRDD [15072] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33700 { label="MicroBatchScan"; 15058 [labelType="html" label="DataSourceRDD [15058] run at <unknown>:0"]; 15059 [labelType="html" label="MapPartitionsRDD [15059] run at <unknown>:0"]; } subgraph cluster33699 { label="Project"; 15060 [labelType="html" label="MapPartitionsRDD [15060] run at <unknown>:0"]; } subgraph cluster33695 { label="WholeStageCodegen (1)"; 15061 [labelType="html" label="MapPartitionsRDD [15061] run at <unknown>:0"]; } subgraph cluster33709 { label="WholeStageCodegen (1)"; 15063 [labelType="html" label="MapPartitionsRDD [15063] toJavaRDD at <unknown>:0"]; } subgraph cluster33708 { label="Filter"; 15064 [labelType="html" label="MapPartitionsRDD [15064] toJavaRDD at <unknown>:0"]; } subgraph cluster33707 { label="Project"; 15065 [labelType="html" label="MapPartitionsRDD [15065] toJavaRDD at <unknown>:0"]; } subgraph cluster33704 { label="WholeStageCodegen (2)"; 15066 [labelType="html" label="MapPartitionsRDD [15066] toJavaRDD at <unknown>:0"]; } subgraph cluster33703 { label="Project"; 15067 [labelType="html" label="MapPartitionsRDD [15067] toJavaRDD at <unknown>:0"]; } subgraph cluster33702 { label="DeserializeToObject"; 15068 [labelType="html" label="MapPartitionsRDD [15068] toJavaRDD at <unknown>:0"]; } subgraph cluster33701 { label="MapPartitions"; 15069 [labelType="html" label="MapPartitionsRDD [15069] toJavaRDD at <unknown>:0"]; } subgraph cluster33711 { label="mapPartitions"; 15071 [labelType="html" label="MapPartitionsRDD [15071] toJavaRDD at <unknown>:0"]; } } 15058->15059; 15059->15060; 15060->15061; 15061->15062; 15062->15063; 15063->15064; 15064->15065; 15065->15066; 15066->15067; 15067->15068; 15068->15069; 15069->15070; 15070->15071; 15071->15072; }

Event Timeline

Enable zooming