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

digraph G { subgraph clusterstage_103 { label="Stage 103"; 1075 [labelType="html" label="SQLExecutionRDD [1075] run at <unknown>:0"]; 1089 [labelType="html" label="SQLExecutionRDD [1089] toJavaRDD at <unknown>:0"]; 1091 [labelType="html" label="PythonRDD [1091] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster2402 { label="MicroBatchScan"; 1071 [labelType="html" label="DataSourceRDD [1071] run at <unknown>:0"]; 1072 [labelType="html" label="MapPartitionsRDD [1072] run at <unknown>:0"]; } subgraph cluster2401 { label="Project"; 1073 [labelType="html" label="MapPartitionsRDD [1073] run at <unknown>:0"]; } subgraph cluster2397 { label="WholeStageCodegen (1)"; 1074 [labelType="html" label="MapPartitionsRDD [1074] run at <unknown>:0"]; } subgraph cluster2419 { label="WholeStageCodegen (1)"; 1082 [labelType="html" label="MapPartitionsRDD [1082] toJavaRDD at <unknown>:0"]; } subgraph cluster2418 { label="Filter"; 1083 [labelType="html" label="MapPartitionsRDD [1083] toJavaRDD at <unknown>:0"]; } subgraph cluster2417 { label="Project"; 1084 [labelType="html" label="MapPartitionsRDD [1084] toJavaRDD at <unknown>:0"]; } subgraph cluster2414 { label="WholeStageCodegen (2)"; 1085 [labelType="html" label="MapPartitionsRDD [1085] toJavaRDD at <unknown>:0"]; } subgraph cluster2413 { label="Project"; 1086 [labelType="html" label="MapPartitionsRDD [1086] toJavaRDD at <unknown>:0"]; } subgraph cluster2412 { label="DeserializeToObject"; 1087 [labelType="html" label="MapPartitionsRDD [1087] toJavaRDD at <unknown>:0"]; } subgraph cluster2411 { label="MapPartitions"; 1088 [labelType="html" label="MapPartitionsRDD [1088] toJavaRDD at <unknown>:0"]; } subgraph cluster2421 { label="mapPartitions"; 1090 [labelType="html" label="MapPartitionsRDD [1090] toJavaRDD at <unknown>:0"]; } } 1071->1072; 1072->1073; 1073->1074; 1074->1075; 1075->1082; 1082->1083; 1083->1084; 1084->1085; 1085->1086; 1086->1087; 1087->1088; 1088->1089; 1089->1090; 1090->1091; }

Event Timeline

Enable zooming