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

digraph G { subgraph clusterstage_1109 { label="Stage 1109"; 11660 [labelType="html" label="SQLExecutionRDD [11660] run at <unknown>:0"]; 11668 [labelType="html" label="SQLExecutionRDD [11668] toJavaRDD at <unknown>:0"]; 11670 [labelType="html" label="PythonRDD [11670] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster26086 { label="MicroBatchScan"; 11656 [labelType="html" label="DataSourceRDD [11656] run at <unknown>:0"]; 11657 [labelType="html" label="MapPartitionsRDD [11657] run at <unknown>:0"]; } subgraph cluster26085 { label="Project"; 11658 [labelType="html" label="MapPartitionsRDD [11658] run at <unknown>:0"]; } subgraph cluster26081 { label="WholeStageCodegen (1)"; 11659 [labelType="html" label="MapPartitionsRDD [11659] run at <unknown>:0"]; } subgraph cluster26095 { label="WholeStageCodegen (1)"; 11661 [labelType="html" label="MapPartitionsRDD [11661] toJavaRDD at <unknown>:0"]; } subgraph cluster26094 { label="Filter"; 11662 [labelType="html" label="MapPartitionsRDD [11662] toJavaRDD at <unknown>:0"]; } subgraph cluster26093 { label="Project"; 11663 [labelType="html" label="MapPartitionsRDD [11663] toJavaRDD at <unknown>:0"]; } subgraph cluster26090 { label="WholeStageCodegen (2)"; 11664 [labelType="html" label="MapPartitionsRDD [11664] toJavaRDD at <unknown>:0"]; } subgraph cluster26089 { label="Project"; 11665 [labelType="html" label="MapPartitionsRDD [11665] toJavaRDD at <unknown>:0"]; } subgraph cluster26088 { label="DeserializeToObject"; 11666 [labelType="html" label="MapPartitionsRDD [11666] toJavaRDD at <unknown>:0"]; } subgraph cluster26087 { label="MapPartitions"; 11667 [labelType="html" label="MapPartitionsRDD [11667] toJavaRDD at <unknown>:0"]; } subgraph cluster26097 { label="mapPartitions"; 11669 [labelType="html" label="MapPartitionsRDD [11669] toJavaRDD at <unknown>:0"]; } } 11656->11657; 11657->11658; 11658->11659; 11659->11660; 11660->11661; 11661->11662; 11662->11663; 11663->11664; 11664->11665; 11665->11666; 11666->11667; 11667->11668; 11668->11669; 11669->11670; }

Event Timeline

Enable zooming