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

digraph G { subgraph clusterstage_1492 { label="Stage 1492"; 15670 [labelType="html" label="SQLExecutionRDD [15670] run at <unknown>:0"]; 15678 [labelType="html" label="SQLExecutionRDD [15678] toJavaRDD at <unknown>:0"]; 15680 [labelType="html" label="PythonRDD [15680] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster35067 { label="MicroBatchScan"; 15666 [labelType="html" label="DataSourceRDD [15666] run at <unknown>:0"]; 15667 [labelType="html" label="MapPartitionsRDD [15667] run at <unknown>:0"]; } subgraph cluster35066 { label="Project"; 15668 [labelType="html" label="MapPartitionsRDD [15668] run at <unknown>:0"]; } subgraph cluster35062 { label="WholeStageCodegen (1)"; 15669 [labelType="html" label="MapPartitionsRDD [15669] run at <unknown>:0"]; } subgraph cluster35076 { label="WholeStageCodegen (1)"; 15671 [labelType="html" label="MapPartitionsRDD [15671] toJavaRDD at <unknown>:0"]; } subgraph cluster35075 { label="Filter"; 15672 [labelType="html" label="MapPartitionsRDD [15672] toJavaRDD at <unknown>:0"]; } subgraph cluster35074 { label="Project"; 15673 [labelType="html" label="MapPartitionsRDD [15673] toJavaRDD at <unknown>:0"]; } subgraph cluster35071 { label="WholeStageCodegen (2)"; 15674 [labelType="html" label="MapPartitionsRDD [15674] toJavaRDD at <unknown>:0"]; } subgraph cluster35070 { label="Project"; 15675 [labelType="html" label="MapPartitionsRDD [15675] toJavaRDD at <unknown>:0"]; } subgraph cluster35069 { label="DeserializeToObject"; 15676 [labelType="html" label="MapPartitionsRDD [15676] toJavaRDD at <unknown>:0"]; } subgraph cluster35068 { label="MapPartitions"; 15677 [labelType="html" label="MapPartitionsRDD [15677] toJavaRDD at <unknown>:0"]; } subgraph cluster35078 { label="mapPartitions"; 15679 [labelType="html" label="MapPartitionsRDD [15679] toJavaRDD at <unknown>:0"]; } } 15666->15667; 15667->15668; 15668->15669; 15669->15670; 15670->15671; 15671->15672; 15672->15673; 15673->15674; 15674->15675; 15675->15676; 15676->15677; 15677->15678; 15678->15679; 15679->15680; }

Event Timeline

Enable zooming