rzvde-g8-kirsanov-dmitry - Details for Job 49

Status: SUCCEEDED
Submitted: 2026/04/08 09:00:06
Duration: 0.2 s
Associated SQL Query: 30
Completed Stages: 1
Skipped Stages: 1

Enable zooming

digraph G { subgraph clusterstage_88 { label="Stage 88 (skipped)"; subgraph cluster511 { label="Scan csv "; 208 [labelType="html" label="FileScanRDD [208] showString at NativeMethodAccessorImpl.java:0"]; 209 [labelType="html" label="MapPartitionsRDD [209] showString at NativeMethodAccessorImpl.java:0"]; } subgraph cluster508 { label="WholeStageCodegen (1)"; 210 [labelType="html" label="MapPartitionsRDD [210] showString at NativeMethodAccessorImpl.java:0"]; } subgraph cluster507 { label="Exchange"; 211 [labelType="html" label="MapPartitionsRDD [211] showString at NativeMethodAccessorImpl.java:0"]; } } 208->209; 209->210; 210->211; }

digraph G { subgraph clusterstage_89 { label="Stage 89"; subgraph cluster519 { label="AQEShuffleRead"; 212 [labelType="html" label="ShuffledRowRDD [212] [Unordered] showString at NativeMethodAccessorImpl.java:0"]; } subgraph cluster516 { label="WholeStageCodegen (2)"; 213 [labelType="html" label="MapPartitionsRDD [213] [Unordered] showString at NativeMethodAccessorImpl.java:0"]; } subgraph cluster515 { label="Window"; 214 [labelType="html" label="MapPartitionsRDD [214] [Unordered] showString at NativeMethodAccessorImpl.java:0"]; } subgraph cluster512 { label="WholeStageCodegen (3)"; 215 [labelType="html" label="MapPartitionsRDD [215] [Unordered] showString at NativeMethodAccessorImpl.java:0"]; } subgraph cluster520 { label="mapPartitionsInternal"; 216 [labelType="html" label="MapPartitionsRDD [216] [Unordered] showString at NativeMethodAccessorImpl.java:0"]; } subgraph cluster521 { label="takeOrdered"; 217 [labelType="html" label="MapPartitionsRDD [217] [Unordered] showString at NativeMethodAccessorImpl.java:0"]; } } 212->213; 213->214; 214->215; 215->216; 216->217; }

211,212

Completed Stages (1)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
89	showString at NativeMethodAccessorImpl.java:0 +details org.apache.spark.sql.Dataset.showString(Dataset.scala:315) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.base/java.lang.reflect.Method.invoke(Method.java:568) py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244) py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374) py4j.Gateway.invoke(Gateway.java:282) py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132) py4j.commands.CallCommand.execute(CallCommand.java:79) py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182) py4j.ClientServerConnection.run(ClientServerConnection.java:106) java.base/java.lang.Thread.run(Thread.java:840)	2026/04/08 09:00:06	0.2 s	2/2			2.3 MiB

Stage Id ▾

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

showString at NativeMethodAccessorImpl.java:0 +details

org.apache.spark.sql.Dataset.showString(Dataset.scala:315)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:568)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)

2026/04/08 09:00:06

0.2 s

2/2

2.3 MiB

Page:

Skipped Stages (1)

Page:

Stage Id ▾	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
88	showString at NativeMethodAccessorImpl.java:0 +details org.apache.spark.sql.Dataset.showString(Dataset.scala:315) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.base/java.lang.reflect.Method.invoke(Method.java:568) py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244) py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374) py4j.Gateway.invoke(Gateway.java:282) py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132) py4j.commands.CallCommand.execute(CallCommand.java:79) py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182) py4j.ClientServerConnection.run(ClientServerConnection.java:106) java.base/java.lang.Thread.run(Thread.java:840)	Unknown	Unknown	0/2

Stage Id ▾

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

showString at NativeMethodAccessorImpl.java:0 +details

org.apache.spark.sql.Dataset.showString(Dataset.scala:315)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:568)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)

Unknown

0/2

Page: