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

digraph G { subgraph clusterstage_1721 { label="Stage 1721"; 18086 [labelType="html" label="SQLExecutionRDD [18086] run at <unknown>:0"]; 18094 [labelType="html" label="SQLExecutionRDD [18094] toJavaRDD at <unknown>:0"]; 18096 [labelType="html" label="PythonRDD [18096] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster40468 { label="MicroBatchScan"; 18082 [labelType="html" label="DataSourceRDD [18082] run at <unknown>:0"]; 18083 [labelType="html" label="MapPartitionsRDD [18083] run at <unknown>:0"]; } subgraph cluster40467 { label="Project"; 18084 [labelType="html" label="MapPartitionsRDD [18084] run at <unknown>:0"]; } subgraph cluster40463 { label="WholeStageCodegen (1)"; 18085 [labelType="html" label="MapPartitionsRDD [18085] run at <unknown>:0"]; } subgraph cluster40477 { label="WholeStageCodegen (1)"; 18087 [labelType="html" label="MapPartitionsRDD [18087] toJavaRDD at <unknown>:0"]; } subgraph cluster40476 { label="Filter"; 18088 [labelType="html" label="MapPartitionsRDD [18088] toJavaRDD at <unknown>:0"]; } subgraph cluster40475 { label="Project"; 18089 [labelType="html" label="MapPartitionsRDD [18089] toJavaRDD at <unknown>:0"]; } subgraph cluster40472 { label="WholeStageCodegen (2)"; 18090 [labelType="html" label="MapPartitionsRDD [18090] toJavaRDD at <unknown>:0"]; } subgraph cluster40471 { label="Project"; 18091 [labelType="html" label="MapPartitionsRDD [18091] toJavaRDD at <unknown>:0"]; } subgraph cluster40470 { label="DeserializeToObject"; 18092 [labelType="html" label="MapPartitionsRDD [18092] toJavaRDD at <unknown>:0"]; } subgraph cluster40469 { label="MapPartitions"; 18093 [labelType="html" label="MapPartitionsRDD [18093] toJavaRDD at <unknown>:0"]; } subgraph cluster40479 { label="mapPartitions"; 18095 [labelType="html" label="MapPartitionsRDD [18095] toJavaRDD at <unknown>:0"]; } } 18082->18083; 18083->18084; 18084->18085; 18085->18086; 18086->18087; 18087->18088; 18088->18089; 18089->18090; 18090->18091; 18091->18092; 18092->18093; 18093->18094; 18094->18095; 18095->18096; }

Event Timeline

Enable zooming