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

digraph G { subgraph clusterstage_1682 { label="Stage 1682"; 17666 [labelType="html" label="SQLExecutionRDD [17666] run at <unknown>:0"]; 17680 [labelType="html" label="SQLExecutionRDD [17680] toJavaRDD at <unknown>:0"]; 17682 [labelType="html" label="PythonRDD [17682] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster39528 { label="MicroBatchScan"; 17662 [labelType="html" label="DataSourceRDD [17662] run at <unknown>:0"]; 17663 [labelType="html" label="MapPartitionsRDD [17663] run at <unknown>:0"]; } subgraph cluster39527 { label="Project"; 17664 [labelType="html" label="MapPartitionsRDD [17664] run at <unknown>:0"]; } subgraph cluster39523 { label="WholeStageCodegen (1)"; 17665 [labelType="html" label="MapPartitionsRDD [17665] run at <unknown>:0"]; } subgraph cluster39545 { label="WholeStageCodegen (1)"; 17673 [labelType="html" label="MapPartitionsRDD [17673] toJavaRDD at <unknown>:0"]; } subgraph cluster39544 { label="Filter"; 17674 [labelType="html" label="MapPartitionsRDD [17674] toJavaRDD at <unknown>:0"]; } subgraph cluster39543 { label="Project"; 17675 [labelType="html" label="MapPartitionsRDD [17675] toJavaRDD at <unknown>:0"]; } subgraph cluster39540 { label="WholeStageCodegen (2)"; 17676 [labelType="html" label="MapPartitionsRDD [17676] toJavaRDD at <unknown>:0"]; } subgraph cluster39539 { label="Project"; 17677 [labelType="html" label="MapPartitionsRDD [17677] toJavaRDD at <unknown>:0"]; } subgraph cluster39538 { label="DeserializeToObject"; 17678 [labelType="html" label="MapPartitionsRDD [17678] toJavaRDD at <unknown>:0"]; } subgraph cluster39537 { label="MapPartitions"; 17679 [labelType="html" label="MapPartitionsRDD [17679] toJavaRDD at <unknown>:0"]; } subgraph cluster39547 { label="mapPartitions"; 17681 [labelType="html" label="MapPartitionsRDD [17681] toJavaRDD at <unknown>:0"]; } } 17662->17663; 17663->17664; 17664->17665; 17665->17666; 17666->17673; 17673->17674; 17674->17675; 17675->17676; 17676->17677; 17677->17678; 17678->17679; 17679->17680; 17680->17681; 17681->17682; }

Event Timeline

Enable zooming