|
78192
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36740
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36740
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:17
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78193
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36740
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36740
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:17
|
0.6 s
|
[39096]
|
|
|
78190
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36739
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36739
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:16
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78191
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36739
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36739
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:16
|
0.6 s
|
[39095]
|
|
|
78188
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36738
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36738
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:15
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78189
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36738
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36738
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:15
|
0.6 s
|
[39094]
|
|
|
78186
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36737
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36737
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:15
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78187
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36737
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36737
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:15
|
0.6 s
|
[39093]
|
|
|
78184
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36736
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36736
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:14
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78185
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36736
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36736
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:14
|
0.6 s
|
[39092]
|
|
|
78182
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36735
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36735
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:13
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78183
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36735
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36735
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:13
|
0.6 s
|
[39091]
|
|
|
78180
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36734
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36734
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:12
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78181
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36734
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36734
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:12
|
0.6 s
|
[39090]
|
|
|
78178
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36733
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36733
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:12
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78179
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36733
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36733
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:12
|
0.6 s
|
[39089]
|
|
|
78176
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36732
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36732
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:11
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78177
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36732
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36732
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:11
|
0.6 s
|
[39088]
|
|
|
78174
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36731
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36731
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:10
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78175
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36731
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36731
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:10
|
0.6 s
|
[39087]
|
|
|
78172
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36730
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36730
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:10
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78173
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36730
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36730
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:10
|
0.6 s
|
[39086]
|
|
|
78170
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36729
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36729
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:09
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78171
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36729
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36729
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:09
|
0.6 s
|
[39085]
|
|
|
78168
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36728
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36728
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:08
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78169
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36728
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36728
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:08
|
0.6 s
|
[39084]
|
|
|
78166
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36727
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36727
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:07
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78167
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36727
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36727
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:07
|
0.6 s
|
[39083]
|
|
|
78164
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36726
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36726
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:07
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78165
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36726
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36726
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:07
|
0.6 s
|
[39082]
|
|
|
78162
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36725
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36725
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:06
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78163
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36725
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36725
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:06
|
0.6 s
|
[39081]
|
|
|
78160
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36724
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36724
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:05
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78161
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36724
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36724
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:05
|
0.6 s
|
[39080]
|
|
|
78158
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36723
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36723
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:05
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78159
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36723
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36723
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:05
|
0.6 s
|
[39079]
|
|
|
78156
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36722
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36722
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:04
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78157
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36722
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36722
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:04
|
0.6 s
|
[39078]
|
|
|
78154
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36721
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36721
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:03
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78155
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36721
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36721
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:03
|
0.6 s
|
[39077]
|
|
|
78152
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36720
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36720
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:03
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78153
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36720
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36720
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:03
|
0.6 s
|
[39076]
|
|
|
78150
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36719
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36719
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:02
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78151
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36719
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36719
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:02
|
0.6 s
|
[39075]
|
|
|
78148
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36718
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36718
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:01
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78149
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36718
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36718
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:01
|
0.6 s
|
[39074]
|
|
|
78146
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36717
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36717
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:00
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78147
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36717
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36717
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:00
|
0.6 s
|
[39073]
|
|
|
78144
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36716
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36716
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:00
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78145
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36716
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36716
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:46:00
|
0.6 s
|
[39072]
|
|
|
78142
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36715
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36715
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:59
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78143
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36715
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36715
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:59
|
0.6 s
|
[39071]
|
|
|
78140
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2355
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2355
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:58
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78141
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2355
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2355
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:58
|
0.6 s
|
[39070]
|
|
|
78138
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36714
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36714
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:58
|
1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78139
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36714
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36714
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:58
|
1 s
|
[39069]
|
|
|
78136
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2354
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2354
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:57
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78137
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2354
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2354
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:57
|
0.6 s
|
[39068]
|
|
|
78134
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36713
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36713
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:57
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78135
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36713
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36713
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:57
|
0.6 s
|
[39067]
|
|
|
78132
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36712
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36712
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:56
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78133
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36712
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36712
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:56
|
0.6 s
|
[39066]
|
|
|
78130
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36711
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36711
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:56
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78131
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36711
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36711
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:56
|
0.6 s
|
[39065]
|
|
|
78128
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36710
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36710
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:55
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78129
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36710
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36710
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:55
|
0.6 s
|
[39064]
|
|
|
78126
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36709
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36709
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:54
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78127
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36709
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36709
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:54
|
0.6 s
|
[39063]
|
|
|
78124
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36708
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36708
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:53
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78125
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36708
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36708
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:53
|
0.6 s
|
[39062]
|
|
|
78122
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36707
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36707
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:53
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78123
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36707
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36707
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:53
|
0.6 s
|
[39061]
|
|
|
78120
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36706
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36706
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:52
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78121
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36706
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36706
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:52
|
0.6 s
|
[39060]
|
|
|
78118
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36705
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36705
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:51
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78119
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36705
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36705
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:51
|
0.6 s
|
[39059]
|
|
|
78116
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36704
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36704
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:51
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78117
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36704
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36704
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:51
|
0.6 s
|
[39058]
|
|
|
78114
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36703
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36703
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:50
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78115
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36703
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36703
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:50
|
0.6 s
|
[39057]
|
|
|
78112
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36702
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36702
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:49
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78113
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36702
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36702
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:49
|
0.6 s
|
[39056]
|
|
|
78110
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36701
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36701
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:48
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78111
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36701
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36701
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:48
|
0.6 s
|
[39055]
|
|
|
78108
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36700
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36700
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:48
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78109
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36700
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36700
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:48
|
0.6 s
|
[39054]
|
|
|
78106
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36699
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36699
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:47
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78107
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36699
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36699
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:47
|
0.6 s
|
[39053]
|
|
|
78104
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36698
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36698
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:46
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78105
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36698
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36698
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:46
|
0.6 s
|
[39052]
|
|
|
78102
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36697
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36697
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:46
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78103
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36697
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36697
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:46
|
0.6 s
|
[39051]
|
|
|
78100
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36696
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36696
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:45
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78101
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36696
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36696
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:45
|
0.6 s
|
[39050]
|
|
|
78098
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36695
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36695
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:44
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78099
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36695
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36695
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:44
|
0.6 s
|
[39049]
|
|
|
78096
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36694
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36694
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:43
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78097
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36694
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36694
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:43
|
0.6 s
|
[39048]
|
|
|
78094
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36693
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36693
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:43
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78095
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36693
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36693
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:43
|
0.6 s
|
[39047]
|
|
|
78092
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36692
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36692
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:42
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78093
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36692
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36692
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:42
|
0.6 s
|
[39046]
|
|
|
78090
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36691
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36691
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:41
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78091
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36691
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36691
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:41
|
0.6 s
|
[39045]
|
|
|
78088
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36690
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36690
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:41
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78089
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36690
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36690
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:41
|
0.6 s
|
[39044]
|
|
|
78086
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36689
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36689
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:40
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78087
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36689
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36689
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:40
|
0.6 s
|
[39043]
|
|
|
78084
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36688
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36688
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:39
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78085
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36688
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36688
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:39
|
0.6 s
|
[39042]
|
|
|
78082
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2353
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2353
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:38
|
0.8 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78083
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2353
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2353
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:38
|
0.7 s
|
[39041]
|
|
|
78080
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36687
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36687
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:38
|
1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78081
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36687
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36687
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:38
|
1 s
|
[39040]
|
|
|
78078
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2352
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2352
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:37
|
0.8 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78079
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2352
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2352
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:37
|
0.8 s
|
[39039]
|
|
|
78076
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36686
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36686
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:37
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78077
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36686
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36686
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:37
|
0.6 s
|
[39038]
|
|
|
78074
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36685
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36685
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:36
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78075
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36685
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36685
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:36
|
0.6 s
|
[39037]
|
|
|
78072
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36684
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36684
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:36
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78073
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36684
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36684
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:36
|
0.6 s
|
[39036]
|
|
|
78070
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36683
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36683
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:35
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78071
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36683
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36683
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:35
|
0.6 s
|
[39035]
|
|
|
78068
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36682
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36682
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:34
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78069
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36682
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36682
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:34
|
0.6 s
|
[39034]
|
|
|
78066
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36681
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36681
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:34
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78067
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36681
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36681
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:34
|
0.6 s
|
[39033]
|
|
|
78064
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36680
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36680
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:33
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78065
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36680
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36680
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:33
|
0.6 s
|
[39032]
|
|
|
78062
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36679
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36679
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:32
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78063
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36679
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36679
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:32
|
0.6 s
|
[39031]
|
|
|
78060
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36678
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36678
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:32
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78061
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36678
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36678
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:32
|
0.6 s
|
[39030]
|
|
|
78058
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36677
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36677
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:31
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78059
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36677
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36677
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:31
|
0.6 s
|
[39029]
|
|
|
78056
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36676
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36676
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:30
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78057
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36676
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36676
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:30
|
0.6 s
|
[39028]
|
|
|
78054
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36675
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36675
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:29
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78055
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36675
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36675
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:29
|
0.6 s
|
[39027]
|
|
|
78052
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36674
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36674
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:29
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78053
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36674
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36674
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:29
|
0.7 s
|
[39026]
|
|
|
78050
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36673
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36673
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:28
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78051
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36673
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36673
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:28
|
0.6 s
|
[39025]
|
|
|
78048
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36672
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36672
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:27
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78049
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36672
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36672
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:27
|
0.6 s
|
[39024]
|
|
|
78046
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36671
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36671
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:26
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78047
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36671
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36671
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:26
|
0.6 s
|
[39023]
|
|
|
78044
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36670
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36670
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:26
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78045
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36670
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36670
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:26
|
0.6 s
|
[39022]
|
|
|
78042
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36669
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36669
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:25
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78043
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36669
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36669
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:25
|
0.6 s
|
[39021]
|
|
|
78040
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36668
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36668
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:24
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78041
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36668
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36668
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:24
|
0.6 s
|
[39020]
|
|
|
78038
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36667
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36667
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:23
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78039
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36667
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36667
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:24
|
0.6 s
|
[39019]
|
|
|
78036
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36666
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36666
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:23
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78037
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36666
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36666
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:23
|
0.6 s
|
[39018]
|
|
|
78034
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36665
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36665
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:22
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78035
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36665
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36665
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:22
|
0.6 s
|
[39017]
|
|
|
78032
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36664
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36664
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:21
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78033
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36664
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36664
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:21
|
0.6 s
|
[39016]
|
|
|
78030
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36663
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36663
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:21
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78031
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36663
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36663
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:21
|
0.6 s
|
[39015]
|
|
|
78028
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36662
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36662
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:20
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78029
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36662
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36662
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:20
|
0.7 s
|
[39014]
|
|
|
78026
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36661
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36661
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:19
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78027
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36661
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36661
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:19
|
0.6 s
|
[39013]
|
|
|
78024
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36660
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36660
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:18
|
1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78025
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36660
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36660
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:18
|
1 s
|
[39012]
|
|
|
78022
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2351
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2351
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:17
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78023
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2351
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 2351
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:17
|
0.7 s
|
[39011]
|
|
|
78020
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36659
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36659
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:17
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78021
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36659
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36659
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:17
|
0.6 s
|
[39010]
|
|
|
78018
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36658
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36658
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:16
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78019
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36658
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36658
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:16
|
0.6 s
|
[39009]
|
|
|
78016
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36657
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36657
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:16
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78017
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36657
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36657
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:16
|
0.7 s
|
[39008]
|
|
|
78014
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36656
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36656
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:15
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78015
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36656
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36656
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:15
|
0.6 s
|
[39007]
|
|
|
78012
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36655
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36655
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:14
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78013
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36655
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36655
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:14
|
0.6 s
|
[39006]
|
|
|
78010
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36654
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36654
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:13
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78011
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36654
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36654
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:13
|
0.6 s
|
[39005]
|
|
|
78008
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36653
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36653
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:13
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78009
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36653
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36653
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:13
|
0.7 s
|
[39004]
|
|
|
78006
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36652
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36652
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:12
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78007
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36652
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36652
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:12
|
0.6 s
|
[39003]
|
|
|
78004
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36651
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36651
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:11
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78005
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36651
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36651
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:11
|
0.6 s
|
[39002]
|
|
|
78002
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36650
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36650
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:10
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78003
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36650
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36650
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:10
|
0.7 s
|
[39001]
|
|
|
78000
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36649
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36649
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:09
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
78001
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36649
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36649
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:10
|
0.7 s
|
[39000]
|
|
|
77998
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36648
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36648
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:09
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
77999
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36648
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36648
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:09
|
0.7 s
|
[38999]
|
|
|
77996
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36647
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36647
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:08
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
77997
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36647
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36647
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:08
|
0.7 s
|
[38998]
|
|
|
77994
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36646
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36646
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:07
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
77995
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36646
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 36646
org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:137)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:75)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:52)
java.base/java.lang.reflect.Method.invoke(Method.java:580)
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:184)
py4j.ClientServerConnection.run(ClientServerConnection.java:108)
java.base/java.lang.Thread.run(Thread.java:1583)
|
2026/03/02 00:45:07
|
0.7 s
|
[38997]
|
|