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

digraph G { subgraph clusterstage_729 { label="Stage 729"; 7670 [labelType="html" label="SQLExecutionRDD [7670] run at <unknown>:0"]; 7678 [labelType="html" label="SQLExecutionRDD [7678] toJavaRDD at <unknown>:0"]; 7680 [labelType="html" label="PythonRDD [7680] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster17156 { label="MicroBatchScan"; 7666 [labelType="html" label="DataSourceRDD [7666] run at <unknown>:0"]; 7667 [labelType="html" label="MapPartitionsRDD [7667] run at <unknown>:0"]; } subgraph cluster17155 { label="Project"; 7668 [labelType="html" label="MapPartitionsRDD [7668] run at <unknown>:0"]; } subgraph cluster17151 { label="WholeStageCodegen (1)"; 7669 [labelType="html" label="MapPartitionsRDD [7669] run at <unknown>:0"]; } subgraph cluster17165 { label="WholeStageCodegen (1)"; 7671 [labelType="html" label="MapPartitionsRDD [7671] toJavaRDD at <unknown>:0"]; } subgraph cluster17164 { label="Filter"; 7672 [labelType="html" label="MapPartitionsRDD [7672] toJavaRDD at <unknown>:0"]; } subgraph cluster17163 { label="Project"; 7673 [labelType="html" label="MapPartitionsRDD [7673] toJavaRDD at <unknown>:0"]; } subgraph cluster17160 { label="WholeStageCodegen (2)"; 7674 [labelType="html" label="MapPartitionsRDD [7674] toJavaRDD at <unknown>:0"]; } subgraph cluster17159 { label="Project"; 7675 [labelType="html" label="MapPartitionsRDD [7675] toJavaRDD at <unknown>:0"]; } subgraph cluster17158 { label="DeserializeToObject"; 7676 [labelType="html" label="MapPartitionsRDD [7676] toJavaRDD at <unknown>:0"]; } subgraph cluster17157 { label="MapPartitions"; 7677 [labelType="html" label="MapPartitionsRDD [7677] toJavaRDD at <unknown>:0"]; } subgraph cluster17167 { label="mapPartitions"; 7679 [labelType="html" label="MapPartitionsRDD [7679] toJavaRDD at <unknown>:0"]; } } 7666->7667; 7667->7668; 7668->7669; 7669->7670; 7670->7671; 7671->7672; 7672->7673; 7673->7674; 7674->7675; 7675->7676; 7676->7677; 7677->7678; 7678->7679; 7679->7680; }

Event Timeline

Enable zooming