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

digraph G { subgraph clusterstage_715 { label="Stage 715"; 7523 [labelType="html" label="SQLExecutionRDD [7523] run at <unknown>:0"]; 7531 [labelType="html" label="SQLExecutionRDD [7531] toJavaRDD at <unknown>:0"]; 7533 [labelType="html" label="PythonRDD [7533] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster16827 { label="MicroBatchScan"; 7519 [labelType="html" label="DataSourceRDD [7519] run at <unknown>:0"]; 7520 [labelType="html" label="MapPartitionsRDD [7520] run at <unknown>:0"]; } subgraph cluster16826 { label="Project"; 7521 [labelType="html" label="MapPartitionsRDD [7521] run at <unknown>:0"]; } subgraph cluster16822 { label="WholeStageCodegen (1)"; 7522 [labelType="html" label="MapPartitionsRDD [7522] run at <unknown>:0"]; } subgraph cluster16836 { label="WholeStageCodegen (1)"; 7524 [labelType="html" label="MapPartitionsRDD [7524] toJavaRDD at <unknown>:0"]; } subgraph cluster16835 { label="Filter"; 7525 [labelType="html" label="MapPartitionsRDD [7525] toJavaRDD at <unknown>:0"]; } subgraph cluster16834 { label="Project"; 7526 [labelType="html" label="MapPartitionsRDD [7526] toJavaRDD at <unknown>:0"]; } subgraph cluster16831 { label="WholeStageCodegen (2)"; 7527 [labelType="html" label="MapPartitionsRDD [7527] toJavaRDD at <unknown>:0"]; } subgraph cluster16830 { label="Project"; 7528 [labelType="html" label="MapPartitionsRDD [7528] toJavaRDD at <unknown>:0"]; } subgraph cluster16829 { label="DeserializeToObject"; 7529 [labelType="html" label="MapPartitionsRDD [7529] toJavaRDD at <unknown>:0"]; } subgraph cluster16828 { label="MapPartitions"; 7530 [labelType="html" label="MapPartitionsRDD [7530] toJavaRDD at <unknown>:0"]; } subgraph cluster16838 { label="mapPartitions"; 7532 [labelType="html" label="MapPartitionsRDD [7532] toJavaRDD at <unknown>:0"]; } } 7519->7520; 7520->7521; 7521->7522; 7522->7523; 7523->7524; 7524->7525; 7525->7526; 7526->7527; 7527->7528; 7528->7529; 7529->7530; 7530->7531; 7531->7532; 7532->7533; }

Event Timeline

Enable zooming