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

digraph G { subgraph clusterstage_1435 { label="Stage 1435"; 15083 [labelType="html" label="SQLExecutionRDD [15083] run at <unknown>:0"]; 15091 [labelType="html" label="SQLExecutionRDD [15091] toJavaRDD at <unknown>:0"]; 15093 [labelType="html" label="PythonRDD [15093] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster33747 { label="MicroBatchScan"; 15079 [labelType="html" label="DataSourceRDD [15079] run at <unknown>:0"]; 15080 [labelType="html" label="MapPartitionsRDD [15080] run at <unknown>:0"]; } subgraph cluster33746 { label="Project"; 15081 [labelType="html" label="MapPartitionsRDD [15081] run at <unknown>:0"]; } subgraph cluster33742 { label="WholeStageCodegen (1)"; 15082 [labelType="html" label="MapPartitionsRDD [15082] run at <unknown>:0"]; } subgraph cluster33756 { label="WholeStageCodegen (1)"; 15084 [labelType="html" label="MapPartitionsRDD [15084] toJavaRDD at <unknown>:0"]; } subgraph cluster33755 { label="Filter"; 15085 [labelType="html" label="MapPartitionsRDD [15085] toJavaRDD at <unknown>:0"]; } subgraph cluster33754 { label="Project"; 15086 [labelType="html" label="MapPartitionsRDD [15086] toJavaRDD at <unknown>:0"]; } subgraph cluster33751 { label="WholeStageCodegen (2)"; 15087 [labelType="html" label="MapPartitionsRDD [15087] toJavaRDD at <unknown>:0"]; } subgraph cluster33750 { label="Project"; 15088 [labelType="html" label="MapPartitionsRDD [15088] toJavaRDD at <unknown>:0"]; } subgraph cluster33749 { label="DeserializeToObject"; 15089 [labelType="html" label="MapPartitionsRDD [15089] toJavaRDD at <unknown>:0"]; } subgraph cluster33748 { label="MapPartitions"; 15090 [labelType="html" label="MapPartitionsRDD [15090] toJavaRDD at <unknown>:0"]; } subgraph cluster33758 { label="mapPartitions"; 15092 [labelType="html" label="MapPartitionsRDD [15092] toJavaRDD at <unknown>:0"]; } } 15079->15080; 15080->15081; 15081->15082; 15082->15083; 15083->15084; 15084->15085; 15085->15086; 15086->15087; 15087->15088; 15088->15089; 15089->15090; 15090->15091; 15091->15092; 15092->15093; }

Event Timeline

Enable zooming