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

digraph G { subgraph clusterstage_571 { label="Stage 571"; 5989 [labelType="html" label="SQLExecutionRDD [5989] run at <unknown>:0"]; 6003 [labelType="html" label="SQLExecutionRDD [6003] toJavaRDD at <unknown>:0"]; 6005 [labelType="html" label="PythonRDD [6005] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster13400 { label="MicroBatchScan"; 5985 [labelType="html" label="DataSourceRDD [5985] run at <unknown>:0"]; 5986 [labelType="html" label="MapPartitionsRDD [5986] run at <unknown>:0"]; } subgraph cluster13399 { label="Project"; 5987 [labelType="html" label="MapPartitionsRDD [5987] run at <unknown>:0"]; } subgraph cluster13395 { label="WholeStageCodegen (1)"; 5988 [labelType="html" label="MapPartitionsRDD [5988] run at <unknown>:0"]; } subgraph cluster13417 { label="WholeStageCodegen (1)"; 5996 [labelType="html" label="MapPartitionsRDD [5996] toJavaRDD at <unknown>:0"]; } subgraph cluster13416 { label="Filter"; 5997 [labelType="html" label="MapPartitionsRDD [5997] toJavaRDD at <unknown>:0"]; } subgraph cluster13415 { label="Project"; 5998 [labelType="html" label="MapPartitionsRDD [5998] toJavaRDD at <unknown>:0"]; } subgraph cluster13412 { label="WholeStageCodegen (2)"; 5999 [labelType="html" label="MapPartitionsRDD [5999] toJavaRDD at <unknown>:0"]; } subgraph cluster13411 { label="Project"; 6000 [labelType="html" label="MapPartitionsRDD [6000] toJavaRDD at <unknown>:0"]; } subgraph cluster13410 { label="DeserializeToObject"; 6001 [labelType="html" label="MapPartitionsRDD [6001] toJavaRDD at <unknown>:0"]; } subgraph cluster13409 { label="MapPartitions"; 6002 [labelType="html" label="MapPartitionsRDD [6002] toJavaRDD at <unknown>:0"]; } subgraph cluster13419 { label="mapPartitions"; 6004 [labelType="html" label="MapPartitionsRDD [6004] toJavaRDD at <unknown>:0"]; } } 5985->5986; 5986->5987; 5987->5988; 5988->5989; 5989->5996; 5996->5997; 5997->5998; 5998->5999; 5999->6000; 6000->6001; 6001->6002; 6002->6003; 6003->6004; 6004->6005; }

Event Timeline

Enable zooming