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

digraph G { subgraph clusterstage_353 { label="Stage 353"; 3700 [labelType="html" label="SQLExecutionRDD [3700] run at <unknown>:0"]; 3714 [labelType="html" label="SQLExecutionRDD [3714] toJavaRDD at <unknown>:0"]; 3716 [labelType="html" label="PythonRDD [3716] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster8277 { label="MicroBatchScan"; 3696 [labelType="html" label="DataSourceRDD [3696] run at <unknown>:0"]; 3697 [labelType="html" label="MapPartitionsRDD [3697] run at <unknown>:0"]; } subgraph cluster8276 { label="Project"; 3698 [labelType="html" label="MapPartitionsRDD [3698] run at <unknown>:0"]; } subgraph cluster8272 { label="WholeStageCodegen (1)"; 3699 [labelType="html" label="MapPartitionsRDD [3699] run at <unknown>:0"]; } subgraph cluster8294 { label="WholeStageCodegen (1)"; 3707 [labelType="html" label="MapPartitionsRDD [3707] toJavaRDD at <unknown>:0"]; } subgraph cluster8293 { label="Filter"; 3708 [labelType="html" label="MapPartitionsRDD [3708] toJavaRDD at <unknown>:0"]; } subgraph cluster8292 { label="Project"; 3709 [labelType="html" label="MapPartitionsRDD [3709] toJavaRDD at <unknown>:0"]; } subgraph cluster8289 { label="WholeStageCodegen (2)"; 3710 [labelType="html" label="MapPartitionsRDD [3710] toJavaRDD at <unknown>:0"]; } subgraph cluster8288 { label="Project"; 3711 [labelType="html" label="MapPartitionsRDD [3711] toJavaRDD at <unknown>:0"]; } subgraph cluster8287 { label="DeserializeToObject"; 3712 [labelType="html" label="MapPartitionsRDD [3712] toJavaRDD at <unknown>:0"]; } subgraph cluster8286 { label="MapPartitions"; 3713 [labelType="html" label="MapPartitionsRDD [3713] toJavaRDD at <unknown>:0"]; } subgraph cluster8296 { label="mapPartitions"; 3715 [labelType="html" label="MapPartitionsRDD [3715] toJavaRDD at <unknown>:0"]; } } 3696->3697; 3697->3698; 3698->3699; 3699->3700; 3700->3707; 3707->3708; 3708->3709; 3709->3710; 3710->3711; 3711->3712; 3712->3713; 3713->3714; 3714->3715; 3715->3716; }

Event Timeline

Enable zooming