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

digraph G { subgraph clusterstage_919 { label="Stage 919"; 9665 [labelType="html" label="SQLExecutionRDD [9665] run at <unknown>:0"]; 9673 [labelType="html" label="SQLExecutionRDD [9673] toJavaRDD at <unknown>:0"]; 9675 [labelType="html" label="PythonRDD [9675] call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617"]; subgraph cluster21621 { label="MicroBatchScan"; 9661 [labelType="html" label="DataSourceRDD [9661] run at <unknown>:0"]; 9662 [labelType="html" label="MapPartitionsRDD [9662] run at <unknown>:0"]; } subgraph cluster21620 { label="Project"; 9663 [labelType="html" label="MapPartitionsRDD [9663] run at <unknown>:0"]; } subgraph cluster21616 { label="WholeStageCodegen (1)"; 9664 [labelType="html" label="MapPartitionsRDD [9664] run at <unknown>:0"]; } subgraph cluster21630 { label="WholeStageCodegen (1)"; 9666 [labelType="html" label="MapPartitionsRDD [9666] toJavaRDD at <unknown>:0"]; } subgraph cluster21629 { label="Filter"; 9667 [labelType="html" label="MapPartitionsRDD [9667] toJavaRDD at <unknown>:0"]; } subgraph cluster21628 { label="Project"; 9668 [labelType="html" label="MapPartitionsRDD [9668] toJavaRDD at <unknown>:0"]; } subgraph cluster21625 { label="WholeStageCodegen (2)"; 9669 [labelType="html" label="MapPartitionsRDD [9669] toJavaRDD at <unknown>:0"]; } subgraph cluster21624 { label="Project"; 9670 [labelType="html" label="MapPartitionsRDD [9670] toJavaRDD at <unknown>:0"]; } subgraph cluster21623 { label="DeserializeToObject"; 9671 [labelType="html" label="MapPartitionsRDD [9671] toJavaRDD at <unknown>:0"]; } subgraph cluster21622 { label="MapPartitions"; 9672 [labelType="html" label="MapPartitionsRDD [9672] toJavaRDD at <unknown>:0"]; } subgraph cluster21632 { label="mapPartitions"; 9674 [labelType="html" label="MapPartitionsRDD [9674] toJavaRDD at <unknown>:0"]; } } 9661->9662; 9662->9663; 9663->9664; 9664->9665; 9665->9666; 9666->9667; 9667->9668; 9668->9669; 9669->9670; 9670->9671; 9671->9672; 9672->9673; 9673->9674; 9674->9675; }

Event Timeline

Enable zooming