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

digraph G { subgraph clusterstage_1816 { label="Stage 1816"; 19072 [labelType="html" label="SQLExecutionRDD [19072] run at <unknown>:0"]; 19080 [labelType="html" label="SQLExecutionRDD [19080] toJavaRDD at <unknown>:0"]; 19082 [labelType="html" label="PythonRDD [19082] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster42681 { label="MicroBatchScan"; 19068 [labelType="html" label="DataSourceRDD [19068] run at <unknown>:0"]; 19069 [labelType="html" label="MapPartitionsRDD [19069] run at <unknown>:0"]; } subgraph cluster42680 { label="Project"; 19070 [labelType="html" label="MapPartitionsRDD [19070] run at <unknown>:0"]; } subgraph cluster42676 { label="WholeStageCodegen (1)"; 19071 [labelType="html" label="MapPartitionsRDD [19071] run at <unknown>:0"]; } subgraph cluster42690 { label="WholeStageCodegen (1)"; 19073 [labelType="html" label="MapPartitionsRDD [19073] toJavaRDD at <unknown>:0"]; } subgraph cluster42689 { label="Filter"; 19074 [labelType="html" label="MapPartitionsRDD [19074] toJavaRDD at <unknown>:0"]; } subgraph cluster42688 { label="Project"; 19075 [labelType="html" label="MapPartitionsRDD [19075] toJavaRDD at <unknown>:0"]; } subgraph cluster42685 { label="WholeStageCodegen (2)"; 19076 [labelType="html" label="MapPartitionsRDD [19076] toJavaRDD at <unknown>:0"]; } subgraph cluster42684 { label="Project"; 19077 [labelType="html" label="MapPartitionsRDD [19077] toJavaRDD at <unknown>:0"]; } subgraph cluster42683 { label="DeserializeToObject"; 19078 [labelType="html" label="MapPartitionsRDD [19078] toJavaRDD at <unknown>:0"]; } subgraph cluster42682 { label="MapPartitions"; 19079 [labelType="html" label="MapPartitionsRDD [19079] toJavaRDD at <unknown>:0"]; } subgraph cluster42692 { label="mapPartitions"; 19081 [labelType="html" label="MapPartitionsRDD [19081] toJavaRDD at <unknown>:0"]; } } 19068->19069; 19069->19070; 19070->19071; 19071->19072; 19072->19073; 19073->19074; 19074->19075; 19075->19076; 19076->19077; 19077->19078; 19078->19079; 19079->19080; 19080->19081; 19081->19082; }

Event Timeline

Enable zooming