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

digraph G { subgraph clusterstage_808 { label="Stage 808"; 8488 [labelType="html" label="SQLExecutionRDD [8488] run at <unknown>:0"]; 8496 [labelType="html" label="SQLExecutionRDD [8496] toJavaRDD at <unknown>:0"]; 8498 [labelType="html" label="PythonRDD [8498] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster18993 { label="MicroBatchScan"; 8484 [labelType="html" label="DataSourceRDD [8484] run at <unknown>:0"]; 8485 [labelType="html" label="MapPartitionsRDD [8485] run at <unknown>:0"]; } subgraph cluster18992 { label="Project"; 8486 [labelType="html" label="MapPartitionsRDD [8486] run at <unknown>:0"]; } subgraph cluster18988 { label="WholeStageCodegen (1)"; 8487 [labelType="html" label="MapPartitionsRDD [8487] run at <unknown>:0"]; } subgraph cluster19002 { label="WholeStageCodegen (1)"; 8489 [labelType="html" label="MapPartitionsRDD [8489] toJavaRDD at <unknown>:0"]; } subgraph cluster19001 { label="Filter"; 8490 [labelType="html" label="MapPartitionsRDD [8490] toJavaRDD at <unknown>:0"]; } subgraph cluster19000 { label="Project"; 8491 [labelType="html" label="MapPartitionsRDD [8491] toJavaRDD at <unknown>:0"]; } subgraph cluster18997 { label="WholeStageCodegen (2)"; 8492 [labelType="html" label="MapPartitionsRDD [8492] toJavaRDD at <unknown>:0"]; } subgraph cluster18996 { label="Project"; 8493 [labelType="html" label="MapPartitionsRDD [8493] toJavaRDD at <unknown>:0"]; } subgraph cluster18995 { label="DeserializeToObject"; 8494 [labelType="html" label="MapPartitionsRDD [8494] toJavaRDD at <unknown>:0"]; } subgraph cluster18994 { label="MapPartitions"; 8495 [labelType="html" label="MapPartitionsRDD [8495] toJavaRDD at <unknown>:0"]; } subgraph cluster19004 { label="mapPartitions"; 8497 [labelType="html" label="MapPartitionsRDD [8497] toJavaRDD at <unknown>:0"]; } } 8484->8485; 8485->8486; 8486->8487; 8487->8488; 8488->8489; 8489->8490; 8490->8491; 8491->8492; 8492->8493; 8493->8494; 8494->8495; 8495->8496; 8496->8497; 8497->8498; }

Event Timeline

Enable zooming