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

digraph G { subgraph clusterstage_1491 { label="Stage 1491"; 15655 [labelType="html" label="SQLExecutionRDD [15655] run at <unknown>:0"]; 15663 [labelType="html" label="SQLExecutionRDD [15663] toJavaRDD at <unknown>:0"]; 15665 [labelType="html" label="PythonRDD [15665] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35028 { label="MicroBatchScan"; 15651 [labelType="html" label="DataSourceRDD [15651] run at <unknown>:0"]; 15652 [labelType="html" label="MapPartitionsRDD [15652] run at <unknown>:0"]; } subgraph cluster35027 { label="Project"; 15653 [labelType="html" label="MapPartitionsRDD [15653] run at <unknown>:0"]; } subgraph cluster35023 { label="WholeStageCodegen (1)"; 15654 [labelType="html" label="MapPartitionsRDD [15654] run at <unknown>:0"]; } subgraph cluster35037 { label="WholeStageCodegen (1)"; 15656 [labelType="html" label="MapPartitionsRDD [15656] toJavaRDD at <unknown>:0"]; } subgraph cluster35036 { label="Filter"; 15657 [labelType="html" label="MapPartitionsRDD [15657] toJavaRDD at <unknown>:0"]; } subgraph cluster35035 { label="Project"; 15658 [labelType="html" label="MapPartitionsRDD [15658] toJavaRDD at <unknown>:0"]; } subgraph cluster35032 { label="WholeStageCodegen (2)"; 15659 [labelType="html" label="MapPartitionsRDD [15659] toJavaRDD at <unknown>:0"]; } subgraph cluster35031 { label="Project"; 15660 [labelType="html" label="MapPartitionsRDD [15660] toJavaRDD at <unknown>:0"]; } subgraph cluster35030 { label="DeserializeToObject"; 15661 [labelType="html" label="MapPartitionsRDD [15661] toJavaRDD at <unknown>:0"]; } subgraph cluster35029 { label="MapPartitions"; 15662 [labelType="html" label="MapPartitionsRDD [15662] toJavaRDD at <unknown>:0"]; } subgraph cluster35039 { label="mapPartitions"; 15664 [labelType="html" label="MapPartitionsRDD [15664] toJavaRDD at <unknown>:0"]; } } 15651->15652; 15652->15653; 15653->15654; 15654->15655; 15655->15656; 15656->15657; 15657->15658; 15658->15659; 15659->15660; 15660->15661; 15661->15662; 15662->15663; 15663->15664; 15664->15665; }

Event Timeline

Enable zooming