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

digraph G { subgraph clusterstage_282 { label="Stage 282"; 2965 [labelType="html" label="SQLExecutionRDD [2965] run at <unknown>:0"]; 2973 [labelType="html" label="SQLExecutionRDD [2973] toJavaRDD at <unknown>:0"]; 2975 [labelType="html" label="PythonRDD [2975] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster6632 { label="MicroBatchScan"; 2961 [labelType="html" label="DataSourceRDD [2961] run at <unknown>:0"]; 2962 [labelType="html" label="MapPartitionsRDD [2962] run at <unknown>:0"]; } subgraph cluster6631 { label="Project"; 2963 [labelType="html" label="MapPartitionsRDD [2963] run at <unknown>:0"]; } subgraph cluster6627 { label="WholeStageCodegen (1)"; 2964 [labelType="html" label="MapPartitionsRDD [2964] run at <unknown>:0"]; } subgraph cluster6641 { label="WholeStageCodegen (1)"; 2966 [labelType="html" label="MapPartitionsRDD [2966] toJavaRDD at <unknown>:0"]; } subgraph cluster6640 { label="Filter"; 2967 [labelType="html" label="MapPartitionsRDD [2967] toJavaRDD at <unknown>:0"]; } subgraph cluster6639 { label="Project"; 2968 [labelType="html" label="MapPartitionsRDD [2968] toJavaRDD at <unknown>:0"]; } subgraph cluster6636 { label="WholeStageCodegen (2)"; 2969 [labelType="html" label="MapPartitionsRDD [2969] toJavaRDD at <unknown>:0"]; } subgraph cluster6635 { label="Project"; 2970 [labelType="html" label="MapPartitionsRDD [2970] toJavaRDD at <unknown>:0"]; } subgraph cluster6634 { label="DeserializeToObject"; 2971 [labelType="html" label="MapPartitionsRDD [2971] toJavaRDD at <unknown>:0"]; } subgraph cluster6633 { label="MapPartitions"; 2972 [labelType="html" label="MapPartitionsRDD [2972] toJavaRDD at <unknown>:0"]; } subgraph cluster6643 { label="mapPartitions"; 2974 [labelType="html" label="MapPartitionsRDD [2974] toJavaRDD at <unknown>:0"]; } } 2961->2962; 2962->2963; 2963->2964; 2964->2965; 2965->2966; 2966->2967; 2967->2968; 2968->2969; 2969->2970; 2970->2971; 2971->2972; 2972->2973; 2973->2974; 2974->2975; }

Event Timeline

Enable zooming