processing-stream-kafka-raw-to-minio - Details for Stage 254 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 4
Input Size / Records: 0.0 B / 398
Associated Job Ids: 254

digraph G { subgraph clusterstage_254 { label="Stage 254"; 2671 [labelType="html" label="SQLExecutionRDD [2671] run at <unknown>:0"]; 2679 [labelType="html" label="SQLExecutionRDD [2679] toJavaRDD at <unknown>:0"]; 2681 [labelType="html" label="PythonRDD [2681] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster5974 { label="MicroBatchScan"; 2667 [labelType="html" label="DataSourceRDD [2667] run at <unknown>:0"]; 2668 [labelType="html" label="MapPartitionsRDD [2668] run at <unknown>:0"]; } subgraph cluster5973 { label="Project"; 2669 [labelType="html" label="MapPartitionsRDD [2669] run at <unknown>:0"]; } subgraph cluster5969 { label="WholeStageCodegen (1)"; 2670 [labelType="html" label="MapPartitionsRDD [2670] run at <unknown>:0"]; } subgraph cluster5983 { label="WholeStageCodegen (1)"; 2672 [labelType="html" label="MapPartitionsRDD [2672] toJavaRDD at <unknown>:0"]; } subgraph cluster5982 { label="Filter"; 2673 [labelType="html" label="MapPartitionsRDD [2673] toJavaRDD at <unknown>:0"]; } subgraph cluster5981 { label="Project"; 2674 [labelType="html" label="MapPartitionsRDD [2674] toJavaRDD at <unknown>:0"]; } subgraph cluster5978 { label="WholeStageCodegen (2)"; 2675 [labelType="html" label="MapPartitionsRDD [2675] toJavaRDD at <unknown>:0"]; } subgraph cluster5977 { label="Project"; 2676 [labelType="html" label="MapPartitionsRDD [2676] toJavaRDD at <unknown>:0"]; } subgraph cluster5976 { label="DeserializeToObject"; 2677 [labelType="html" label="MapPartitionsRDD [2677] toJavaRDD at <unknown>:0"]; } subgraph cluster5975 { label="MapPartitions"; 2678 [labelType="html" label="MapPartitionsRDD [2678] toJavaRDD at <unknown>:0"]; } subgraph cluster5985 { label="mapPartitions"; 2680 [labelType="html" label="MapPartitionsRDD [2680] toJavaRDD at <unknown>:0"]; } } 2667->2668; 2668->2669; 2669->2670; 2670->2671; 2671->2672; 2672->2673; 2673->2674; 2674->2675; 2675->2676; 2676->2677; 2677->2678; 2678->2679; 2679->2680; 2680->2681; }

Event Timeline

Enable zooming