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

digraph G { subgraph clusterstage_951 { label="Stage 951"; 10001 [labelType="html" label="SQLExecutionRDD [10001] run at <unknown>:0"]; 10009 [labelType="html" label="SQLExecutionRDD [10009] toJavaRDD at <unknown>:0"]; 10011 [labelType="html" label="PythonRDD [10011] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster22373 { label="MicroBatchScan"; 9997 [labelType="html" label="DataSourceRDD [9997] run at <unknown>:0"]; 9998 [labelType="html" label="MapPartitionsRDD [9998] run at <unknown>:0"]; } subgraph cluster22372 { label="Project"; 9999 [labelType="html" label="MapPartitionsRDD [9999] run at <unknown>:0"]; } subgraph cluster22368 { label="WholeStageCodegen (1)"; 10000 [labelType="html" label="MapPartitionsRDD [10000] run at <unknown>:0"]; } subgraph cluster22382 { label="WholeStageCodegen (1)"; 10002 [labelType="html" label="MapPartitionsRDD [10002] toJavaRDD at <unknown>:0"]; } subgraph cluster22381 { label="Filter"; 10003 [labelType="html" label="MapPartitionsRDD [10003] toJavaRDD at <unknown>:0"]; } subgraph cluster22380 { label="Project"; 10004 [labelType="html" label="MapPartitionsRDD [10004] toJavaRDD at <unknown>:0"]; } subgraph cluster22377 { label="WholeStageCodegen (2)"; 10005 [labelType="html" label="MapPartitionsRDD [10005] toJavaRDD at <unknown>:0"]; } subgraph cluster22376 { label="Project"; 10006 [labelType="html" label="MapPartitionsRDD [10006] toJavaRDD at <unknown>:0"]; } subgraph cluster22375 { label="DeserializeToObject"; 10007 [labelType="html" label="MapPartitionsRDD [10007] toJavaRDD at <unknown>:0"]; } subgraph cluster22374 { label="MapPartitions"; 10008 [labelType="html" label="MapPartitionsRDD [10008] toJavaRDD at <unknown>:0"]; } subgraph cluster22384 { label="mapPartitions"; 10010 [labelType="html" label="MapPartitionsRDD [10010] toJavaRDD at <unknown>:0"]; } } 9997->9998; 9998->9999; 9999->10000; 10000->10001; 10001->10002; 10002->10003; 10003->10004; 10004->10005; 10005->10006; 10006->10007; 10007->10008; 10008->10009; 10009->10010; 10010->10011; }

Event Timeline

Enable zooming