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

digraph G { subgraph clusterstage_1015 { label="Stage 1015"; 10673 [labelType="html" label="SQLExecutionRDD [10673] run at <unknown>:0"]; 10681 [labelType="html" label="SQLExecutionRDD [10681] toJavaRDD at <unknown>:0"]; 10683 [labelType="html" label="PythonRDD [10683] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster23877 { label="MicroBatchScan"; 10669 [labelType="html" label="DataSourceRDD [10669] run at <unknown>:0"]; 10670 [labelType="html" label="MapPartitionsRDD [10670] run at <unknown>:0"]; } subgraph cluster23876 { label="Project"; 10671 [labelType="html" label="MapPartitionsRDD [10671] run at <unknown>:0"]; } subgraph cluster23872 { label="WholeStageCodegen (1)"; 10672 [labelType="html" label="MapPartitionsRDD [10672] run at <unknown>:0"]; } subgraph cluster23886 { label="WholeStageCodegen (1)"; 10674 [labelType="html" label="MapPartitionsRDD [10674] toJavaRDD at <unknown>:0"]; } subgraph cluster23885 { label="Filter"; 10675 [labelType="html" label="MapPartitionsRDD [10675] toJavaRDD at <unknown>:0"]; } subgraph cluster23884 { label="Project"; 10676 [labelType="html" label="MapPartitionsRDD [10676] toJavaRDD at <unknown>:0"]; } subgraph cluster23881 { label="WholeStageCodegen (2)"; 10677 [labelType="html" label="MapPartitionsRDD [10677] toJavaRDD at <unknown>:0"]; } subgraph cluster23880 { label="Project"; 10678 [labelType="html" label="MapPartitionsRDD [10678] toJavaRDD at <unknown>:0"]; } subgraph cluster23879 { label="DeserializeToObject"; 10679 [labelType="html" label="MapPartitionsRDD [10679] toJavaRDD at <unknown>:0"]; } subgraph cluster23878 { label="MapPartitions"; 10680 [labelType="html" label="MapPartitionsRDD [10680] toJavaRDD at <unknown>:0"]; } subgraph cluster23888 { label="mapPartitions"; 10682 [labelType="html" label="MapPartitionsRDD [10682] toJavaRDD at <unknown>:0"]; } } 10669->10670; 10670->10671; 10671->10672; 10672->10673; 10673->10674; 10674->10675; 10675->10676; 10676->10677; 10677->10678; 10678->10679; 10679->10680; 10680->10681; 10681->10682; 10682->10683; }

Event Timeline

Enable zooming