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

digraph G { subgraph clusterstage_865 { label="Stage 865"; 9082 [labelType="html" label="SQLExecutionRDD [9082] run at <unknown>:0"]; 9090 [labelType="html" label="SQLExecutionRDD [9090] toJavaRDD at <unknown>:0"]; 9092 [labelType="html" label="PythonRDD [9092] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster20317 { label="MicroBatchScan"; 9078 [labelType="html" label="DataSourceRDD [9078] run at <unknown>:0"]; 9079 [labelType="html" label="MapPartitionsRDD [9079] run at <unknown>:0"]; } subgraph cluster20316 { label="Project"; 9080 [labelType="html" label="MapPartitionsRDD [9080] run at <unknown>:0"]; } subgraph cluster20312 { label="WholeStageCodegen (1)"; 9081 [labelType="html" label="MapPartitionsRDD [9081] run at <unknown>:0"]; } subgraph cluster20326 { label="WholeStageCodegen (1)"; 9083 [labelType="html" label="MapPartitionsRDD [9083] toJavaRDD at <unknown>:0"]; } subgraph cluster20325 { label="Filter"; 9084 [labelType="html" label="MapPartitionsRDD [9084] toJavaRDD at <unknown>:0"]; } subgraph cluster20324 { label="Project"; 9085 [labelType="html" label="MapPartitionsRDD [9085] toJavaRDD at <unknown>:0"]; } subgraph cluster20321 { label="WholeStageCodegen (2)"; 9086 [labelType="html" label="MapPartitionsRDD [9086] toJavaRDD at <unknown>:0"]; } subgraph cluster20320 { label="Project"; 9087 [labelType="html" label="MapPartitionsRDD [9087] toJavaRDD at <unknown>:0"]; } subgraph cluster20319 { label="DeserializeToObject"; 9088 [labelType="html" label="MapPartitionsRDD [9088] toJavaRDD at <unknown>:0"]; } subgraph cluster20318 { label="MapPartitions"; 9089 [labelType="html" label="MapPartitionsRDD [9089] toJavaRDD at <unknown>:0"]; } subgraph cluster20328 { label="mapPartitions"; 9091 [labelType="html" label="MapPartitionsRDD [9091] toJavaRDD at <unknown>:0"]; } } 9078->9079; 9079->9080; 9080->9081; 9081->9082; 9082->9083; 9083->9084; 9084->9085; 9085->9086; 9086->9087; 9087->9088; 9088->9089; 9089->9090; 9090->9091; 9091->9092; }

Event Timeline

Enable zooming