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

digraph G { subgraph clusterstage_1206 { label="Stage 1206"; 12668 [labelType="html" label="SQLExecutionRDD [12668] run at <unknown>:0"]; 12682 [labelType="html" label="SQLExecutionRDD [12682] toJavaRDD at <unknown>:0"]; 12684 [labelType="html" label="PythonRDD [12684] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster28342 { label="MicroBatchScan"; 12664 [labelType="html" label="DataSourceRDD [12664] run at <unknown>:0"]; 12665 [labelType="html" label="MapPartitionsRDD [12665] run at <unknown>:0"]; } subgraph cluster28341 { label="Project"; 12666 [labelType="html" label="MapPartitionsRDD [12666] run at <unknown>:0"]; } subgraph cluster28337 { label="WholeStageCodegen (1)"; 12667 [labelType="html" label="MapPartitionsRDD [12667] run at <unknown>:0"]; } subgraph cluster28359 { label="WholeStageCodegen (1)"; 12675 [labelType="html" label="MapPartitionsRDD [12675] toJavaRDD at <unknown>:0"]; } subgraph cluster28358 { label="Filter"; 12676 [labelType="html" label="MapPartitionsRDD [12676] toJavaRDD at <unknown>:0"]; } subgraph cluster28357 { label="Project"; 12677 [labelType="html" label="MapPartitionsRDD [12677] toJavaRDD at <unknown>:0"]; } subgraph cluster28354 { label="WholeStageCodegen (2)"; 12678 [labelType="html" label="MapPartitionsRDD [12678] toJavaRDD at <unknown>:0"]; } subgraph cluster28353 { label="Project"; 12679 [labelType="html" label="MapPartitionsRDD [12679] toJavaRDD at <unknown>:0"]; } subgraph cluster28352 { label="DeserializeToObject"; 12680 [labelType="html" label="MapPartitionsRDD [12680] toJavaRDD at <unknown>:0"]; } subgraph cluster28351 { label="MapPartitions"; 12681 [labelType="html" label="MapPartitionsRDD [12681] toJavaRDD at <unknown>:0"]; } subgraph cluster28361 { label="mapPartitions"; 12683 [labelType="html" label="MapPartitionsRDD [12683] toJavaRDD at <unknown>:0"]; } } 12664->12665; 12665->12666; 12666->12667; 12667->12668; 12668->12675; 12675->12676; 12676->12677; 12677->12678; 12678->12679; 12679->12680; 12680->12681; 12681->12682; 12682->12683; 12683->12684; }

Event Timeline

Enable zooming