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

digraph G { subgraph clusterstage_348 { label="Stage 348"; 3658 [labelType="html" label="SQLExecutionRDD [3658] run at <unknown>:0"]; 3666 [labelType="html" label="SQLExecutionRDD [3666] toJavaRDD at <unknown>:0"]; 3668 [labelType="html" label="PythonRDD [3668] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster8183 { label="MicroBatchScan"; 3654 [labelType="html" label="DataSourceRDD [3654] run at <unknown>:0"]; 3655 [labelType="html" label="MapPartitionsRDD [3655] run at <unknown>:0"]; } subgraph cluster8182 { label="Project"; 3656 [labelType="html" label="MapPartitionsRDD [3656] run at <unknown>:0"]; } subgraph cluster8178 { label="WholeStageCodegen (1)"; 3657 [labelType="html" label="MapPartitionsRDD [3657] run at <unknown>:0"]; } subgraph cluster8192 { label="WholeStageCodegen (1)"; 3659 [labelType="html" label="MapPartitionsRDD [3659] toJavaRDD at <unknown>:0"]; } subgraph cluster8191 { label="Filter"; 3660 [labelType="html" label="MapPartitionsRDD [3660] toJavaRDD at <unknown>:0"]; } subgraph cluster8190 { label="Project"; 3661 [labelType="html" label="MapPartitionsRDD [3661] toJavaRDD at <unknown>:0"]; } subgraph cluster8187 { label="WholeStageCodegen (2)"; 3662 [labelType="html" label="MapPartitionsRDD [3662] toJavaRDD at <unknown>:0"]; } subgraph cluster8186 { label="Project"; 3663 [labelType="html" label="MapPartitionsRDD [3663] toJavaRDD at <unknown>:0"]; } subgraph cluster8185 { label="DeserializeToObject"; 3664 [labelType="html" label="MapPartitionsRDD [3664] toJavaRDD at <unknown>:0"]; } subgraph cluster8184 { label="MapPartitions"; 3665 [labelType="html" label="MapPartitionsRDD [3665] toJavaRDD at <unknown>:0"]; } subgraph cluster8194 { label="mapPartitions"; 3667 [labelType="html" label="MapPartitionsRDD [3667] toJavaRDD at <unknown>:0"]; } } 3654->3655; 3655->3656; 3656->3657; 3657->3658; 3658->3659; 3659->3660; 3660->3661; 3661->3662; 3662->3663; 3663->3664; 3664->3665; 3665->3666; 3666->3667; 3667->3668; }

Event Timeline

Enable zooming