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

digraph G { subgraph clusterstage_314 { label="Stage 314"; 3301 [labelType="html" label="SQLExecutionRDD [3301] run at <unknown>:0"]; 3309 [labelType="html" label="SQLExecutionRDD [3309] toJavaRDD at <unknown>:0"]; 3311 [labelType="html" label="PythonRDD [3311] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster7384 { label="MicroBatchScan"; 3297 [labelType="html" label="DataSourceRDD [3297] run at <unknown>:0"]; 3298 [labelType="html" label="MapPartitionsRDD [3298] run at <unknown>:0"]; } subgraph cluster7383 { label="Project"; 3299 [labelType="html" label="MapPartitionsRDD [3299] run at <unknown>:0"]; } subgraph cluster7379 { label="WholeStageCodegen (1)"; 3300 [labelType="html" label="MapPartitionsRDD [3300] run at <unknown>:0"]; } subgraph cluster7393 { label="WholeStageCodegen (1)"; 3302 [labelType="html" label="MapPartitionsRDD [3302] toJavaRDD at <unknown>:0"]; } subgraph cluster7392 { label="Filter"; 3303 [labelType="html" label="MapPartitionsRDD [3303] toJavaRDD at <unknown>:0"]; } subgraph cluster7391 { label="Project"; 3304 [labelType="html" label="MapPartitionsRDD [3304] toJavaRDD at <unknown>:0"]; } subgraph cluster7388 { label="WholeStageCodegen (2)"; 3305 [labelType="html" label="MapPartitionsRDD [3305] toJavaRDD at <unknown>:0"]; } subgraph cluster7387 { label="Project"; 3306 [labelType="html" label="MapPartitionsRDD [3306] toJavaRDD at <unknown>:0"]; } subgraph cluster7386 { label="DeserializeToObject"; 3307 [labelType="html" label="MapPartitionsRDD [3307] toJavaRDD at <unknown>:0"]; } subgraph cluster7385 { label="MapPartitions"; 3308 [labelType="html" label="MapPartitionsRDD [3308] toJavaRDD at <unknown>:0"]; } subgraph cluster7395 { label="mapPartitions"; 3310 [labelType="html" label="MapPartitionsRDD [3310] toJavaRDD at <unknown>:0"]; } } 3297->3298; 3298->3299; 3299->3300; 3300->3301; 3301->3302; 3302->3303; 3303->3304; 3304->3305; 3305->3306; 3306->3307; 3307->3308; 3308->3309; 3309->3310; 3310->3311; }

Event Timeline

Enable zooming