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

digraph G { subgraph clusterstage_959 { label="Stage 959"; 10085 [labelType="html" label="SQLExecutionRDD [10085] run at <unknown>:0"]; 10093 [labelType="html" label="SQLExecutionRDD [10093] toJavaRDD at <unknown>:0"]; 10095 [labelType="html" label="PythonRDD [10095] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22561 { label="MicroBatchScan"; 10081 [labelType="html" label="DataSourceRDD [10081] run at <unknown>:0"]; 10082 [labelType="html" label="MapPartitionsRDD [10082] run at <unknown>:0"]; } subgraph cluster22560 { label="Project"; 10083 [labelType="html" label="MapPartitionsRDD [10083] run at <unknown>:0"]; } subgraph cluster22556 { label="WholeStageCodegen (1)"; 10084 [labelType="html" label="MapPartitionsRDD [10084] run at <unknown>:0"]; } subgraph cluster22570 { label="WholeStageCodegen (1)"; 10086 [labelType="html" label="MapPartitionsRDD [10086] toJavaRDD at <unknown>:0"]; } subgraph cluster22569 { label="Filter"; 10087 [labelType="html" label="MapPartitionsRDD [10087] toJavaRDD at <unknown>:0"]; } subgraph cluster22568 { label="Project"; 10088 [labelType="html" label="MapPartitionsRDD [10088] toJavaRDD at <unknown>:0"]; } subgraph cluster22565 { label="WholeStageCodegen (2)"; 10089 [labelType="html" label="MapPartitionsRDD [10089] toJavaRDD at <unknown>:0"]; } subgraph cluster22564 { label="Project"; 10090 [labelType="html" label="MapPartitionsRDD [10090] toJavaRDD at <unknown>:0"]; } subgraph cluster22563 { label="DeserializeToObject"; 10091 [labelType="html" label="MapPartitionsRDD [10091] toJavaRDD at <unknown>:0"]; } subgraph cluster22562 { label="MapPartitions"; 10092 [labelType="html" label="MapPartitionsRDD [10092] toJavaRDD at <unknown>:0"]; } subgraph cluster22572 { label="mapPartitions"; 10094 [labelType="html" label="MapPartitionsRDD [10094] toJavaRDD at <unknown>:0"]; } } 10081->10082; 10082->10083; 10083->10084; 10084->10085; 10085->10086; 10086->10087; 10087->10088; 10088->10089; 10089->10090; 10090->10091; 10091->10092; 10092->10093; 10093->10094; 10094->10095; }

Event Timeline

Enable zooming