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

digraph G { subgraph clusterstage_444 { label="Stage 444"; 4673 [labelType="html" label="SQLExecutionRDD [4673] run at <unknown>:0"]; 4681 [labelType="html" label="SQLExecutionRDD [4681] toJavaRDD at <unknown>:0"]; 4683 [labelType="html" label="PythonRDD [4683] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster10443 { label="MicroBatchScan"; 4669 [labelType="html" label="DataSourceRDD [4669] run at <unknown>:0"]; 4670 [labelType="html" label="MapPartitionsRDD [4670] run at <unknown>:0"]; } subgraph cluster10442 { label="Project"; 4671 [labelType="html" label="MapPartitionsRDD [4671] run at <unknown>:0"]; } subgraph cluster10438 { label="WholeStageCodegen (1)"; 4672 [labelType="html" label="MapPartitionsRDD [4672] run at <unknown>:0"]; } subgraph cluster10452 { label="WholeStageCodegen (1)"; 4674 [labelType="html" label="MapPartitionsRDD [4674] toJavaRDD at <unknown>:0"]; } subgraph cluster10451 { label="Filter"; 4675 [labelType="html" label="MapPartitionsRDD [4675] toJavaRDD at <unknown>:0"]; } subgraph cluster10450 { label="Project"; 4676 [labelType="html" label="MapPartitionsRDD [4676] toJavaRDD at <unknown>:0"]; } subgraph cluster10447 { label="WholeStageCodegen (2)"; 4677 [labelType="html" label="MapPartitionsRDD [4677] toJavaRDD at <unknown>:0"]; } subgraph cluster10446 { label="Project"; 4678 [labelType="html" label="MapPartitionsRDD [4678] toJavaRDD at <unknown>:0"]; } subgraph cluster10445 { label="DeserializeToObject"; 4679 [labelType="html" label="MapPartitionsRDD [4679] toJavaRDD at <unknown>:0"]; } subgraph cluster10444 { label="MapPartitions"; 4680 [labelType="html" label="MapPartitionsRDD [4680] toJavaRDD at <unknown>:0"]; } subgraph cluster10454 { label="mapPartitions"; 4682 [labelType="html" label="MapPartitionsRDD [4682] toJavaRDD at <unknown>:0"]; } } 4669->4670; 4670->4671; 4671->4672; 4672->4673; 4673->4674; 4674->4675; 4675->4676; 4676->4677; 4677->4678; 4678->4679; 4679->4680; 4680->4681; 4681->4682; 4682->4683; }

Event Timeline

Enable zooming