|
61672
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28949
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28949
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/01 23:09:18
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61673
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28949
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28949
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/01 23:09:18
|
0.6 s
|
[30836]
|
|
|
61670
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28948
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28948
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/01 23:09:17
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61671
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28948
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28948
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/01 23:09:17
|
0.6 s
|
[30835]
|
|
|
61668
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28947
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28947
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/01 23:09:17
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61669
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28947
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28947
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/01 23:09:17
|
0.6 s
|
[30834]
|
|
|
61666
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28946
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28946
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/01 23:09:16
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61667
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28946
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28946
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/01 23:09:16
|
0.6 s
|
[30833]
|
|
|
61664
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28945
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28945
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/01 23:09:15
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61665
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28945
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28945
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/01 23:09:15
|
0.6 s
|
[30832]
|
|
|
61662
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1886
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1886
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/01 23:09:14
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61663
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1886
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1886
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/01 23:09:14
|
0.7 s
|
[30831]
|
|
|
61660
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28944
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28944
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/01 23:09:14
|
1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61661
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28944
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28944
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/01 23:09:14
|
1 s
|
[30830]
|
|
|
61658
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1885
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1885
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/01 23:09:14
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61659
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1885
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1885
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/01 23:09:14
|
0.6 s
|
[30829]
|
|
|
61656
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28943
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28943
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/01 23:09:13
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61657
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28943
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28943
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/01 23:09:13
|
0.7 s
|
[30828]
|
|
|
61654
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28942
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28942
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/01 23:09:12
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61655
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28942
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28942
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/01 23:09:12
|
0.6 s
|
[30827]
|
|
|
61652
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28941
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28941
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/01 23:09:11
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61653
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28941
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28941
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/01 23:09:11
|
0.6 s
|
[30826]
|
|
|
61650
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28940
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28940
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/01 23:09:11
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61651
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28940
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28940
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/01 23:09:11
|
0.6 s
|
[30825]
|
|
|
61648
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28939
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28939
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/01 23:09:10
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61649
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28939
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28939
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/01 23:09:10
|
0.6 s
|
[30824]
|
|
|
61646
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28938
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28938
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/01 23:09:09
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61647
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28938
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28938
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/01 23:09:09
|
0.6 s
|
[30823]
|
|
|
61644
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28937
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28937
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/01 23:09:09
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61645
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28937
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28937
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/01 23:09:09
|
0.6 s
|
[30822]
|
|
|
61642
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28936
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28936
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/01 23:09:08
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61643
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28936
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28936
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/01 23:09:08
|
0.7 s
|
[30821]
|
|
|
61640
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28935
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28935
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/01 23:09:07
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61641
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28935
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28935
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/01 23:09:07
|
0.7 s
|
[30820]
|
|
|
61638
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28934
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28934
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/01 23:09:06
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61639
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28934
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28934
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/01 23:09:06
|
0.6 s
|
[30819]
|
|
|
61636
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28933
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28933
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/01 23:09:05
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61637
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28933
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28933
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/01 23:09:05
|
0.7 s
|
[30818]
|
|
|
61634
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28932
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28932
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/01 23:09:05
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61635
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28932
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28932
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/01 23:09:05
|
0.6 s
|
[30817]
|
|
|
61632
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28931
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28931
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/01 23:09:04
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61633
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28931
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28931
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/01 23:09:04
|
0.6 s
|
[30816]
|
|
|
61630
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28930
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28930
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/01 23:09:03
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61631
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28930
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28930
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/01 23:09:03
|
0.7 s
|
[30815]
|
|
|
61628
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28929
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28929
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/01 23:09:02
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61629
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28929
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28929
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/01 23:09:02
|
0.6 s
|
[30814]
|
|
|
61626
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28928
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28928
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/01 23:09:02
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61627
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28928
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28928
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/01 23:09:02
|
0.6 s
|
[30813]
|
|
|
61624
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28927
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28927
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/01 23:09:01
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61625
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28927
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28927
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/01 23:09:01
|
0.6 s
|
[30812]
|
|
|
61622
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28926
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28926
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/01 23:09:00
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61623
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28926
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28926
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/01 23:09:00
|
0.6 s
|
[30811]
|
|
|
61620
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28925
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28925
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/01 23:08:59
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61621
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28925
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28925
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/01 23:08:59
|
0.6 s
|
[30810]
|
|
|
61618
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28924
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28924
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/01 23:08:59
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61619
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28924
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28924
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/01 23:08:59
|
0.6 s
|
[30809]
|
|
|
61616
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28923
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28923
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/01 23:08:58
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61617
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28923
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28923
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/01 23:08:58
|
0.7 s
|
[30808]
|
|
|
61614
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28922
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28922
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/01 23:08:57
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61615
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28922
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28922
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/01 23:08:57
|
0.6 s
|
[30807]
|
|
|
61612
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28921
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28921
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/01 23:08:56
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61613
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28921
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28921
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/01 23:08:56
|
0.6 s
|
[30806]
|
|
|
61610
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28920
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28920
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/01 23:08:56
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61611
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28920
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28920
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/01 23:08:56
|
0.6 s
|
[30805]
|
|
|
61608
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28919
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28919
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/01 23:08:55
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61609
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28919
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28919
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/01 23:08:55
|
0.6 s
|
[30804]
|
|
|
61606
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1884
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1884
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/01 23:08:54
|
0.5 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61607
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1884
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1884
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/01 23:08:54
|
0.5 s
|
[30803]
|
|
|
61604
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28918
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28918
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/01 23:08:54
|
1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61605
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28918
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28918
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/01 23:08:54
|
1 s
|
[30802]
|
|
|
61602
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1883
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1883
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/01 23:08:53
|
1.0 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61603
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1883
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1883
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/01 23:08:53
|
1.0 s
|
[30801]
|
|
|
61600
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28917
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28917
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/01 23:08:53
|
0.8 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61601
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28917
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28917
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/01 23:08:53
|
0.8 s
|
[30800]
|
|
|
61598
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28916
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28916
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/01 23:08:52
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61599
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28916
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28916
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/01 23:08:52
|
0.6 s
|
[30799]
|
|
|
61596
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28915
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28915
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/01 23:08:51
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61597
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28915
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28915
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/01 23:08:51
|
0.7 s
|
[30798]
|
|
|
61594
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28914
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28914
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/01 23:08:50
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61595
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28914
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28914
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/01 23:08:50
|
0.6 s
|
[30797]
|
|
|
61592
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28913
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28913
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/01 23:08:50
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61593
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28913
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28913
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/01 23:08:50
|
0.6 s
|
[30796]
|
|
|
61590
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28912
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28912
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/01 23:08:49
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61591
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28912
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28912
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/01 23:08:49
|
0.7 s
|
[30795]
|
|
|
61588
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28911
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28911
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/01 23:08:48
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61589
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28911
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28911
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/01 23:08:48
|
0.6 s
|
[30794]
|
|
|
61586
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28910
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28910
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/01 23:08:47
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61587
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28910
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28910
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/01 23:08:47
|
0.6 s
|
[30793]
|
|
|
61584
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28909
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28909
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/01 23:08:47
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61585
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28909
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28909
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/01 23:08:47
|
0.6 s
|
[30792]
|
|
|
61582
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28908
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28908
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/01 23:08:46
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61583
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28908
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28908
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/01 23:08:46
|
0.6 s
|
[30791]
|
|
|
61580
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28907
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28907
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/01 23:08:45
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61581
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28907
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28907
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/01 23:08:45
|
0.6 s
|
[30790]
|
|
|
61578
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28906
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28906
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/01 23:08:45
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61579
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28906
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28906
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/01 23:08:45
|
0.6 s
|
[30789]
|
|
|
61576
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28905
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28905
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/01 23:08:44
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61577
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28905
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28905
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/01 23:08:44
|
0.7 s
|
[30788]
|
|
|
61574
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28904
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28904
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/01 23:08:43
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61575
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28904
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28904
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/01 23:08:43
|
0.7 s
|
[30787]
|
|
|
61572
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28903
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28903
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/01 23:08:42
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61573
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28903
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28903
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/01 23:08:42
|
0.6 s
|
[30786]
|
|
|
61570
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28902
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28902
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/01 23:08:41
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61571
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28902
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28902
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/01 23:08:41
|
0.6 s
|
[30785]
|
|
|
61568
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28901
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28901
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/01 23:08:41
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61569
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28901
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28901
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/01 23:08:41
|
0.6 s
|
[30784]
|
|
|
61566
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28900
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28900
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/01 23:08:40
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61567
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28900
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28900
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/01 23:08:40
|
0.6 s
|
[30783]
|
|
|
61564
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28899
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28899
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/01 23:08:39
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61565
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28899
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28899
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/01 23:08:39
|
0.6 s
|
[30782]
|
|
|
61562
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28898
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28898
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/01 23:08:39
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61563
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28898
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28898
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/01 23:08:39
|
0.6 s
|
[30781]
|
|
|
61560
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28897
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28897
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/01 23:08:38
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61561
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28897
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28897
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/01 23:08:38
|
0.6 s
|
[30780]
|
|
|
61558
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28896
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28896
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/01 23:08:37
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61559
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28896
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28896
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/01 23:08:37
|
0.6 s
|
[30779]
|
|
|
61556
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28895
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28895
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/01 23:08:37
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61557
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28895
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28895
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/01 23:08:37
|
0.6 s
|
[30778]
|
|
|
61554
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28894
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28894
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/01 23:08:36
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61555
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28894
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28894
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/01 23:08:36
|
0.6 s
|
[30777]
|
|
|
61552
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28893
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28893
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/01 23:08:35
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61553
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28893
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28893
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/01 23:08:35
|
0.6 s
|
[30776]
|
|
|
61550
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28892
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28892
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/01 23:08:34
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61551
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28892
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28892
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/01 23:08:34
|
0.6 s
|
[30775]
|
|
|
61548
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28891
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28891
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/01 23:08:33
|
1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61549
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28891
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28891
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/01 23:08:33
|
1 s
|
[30774]
|
|
|
61546
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1882
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1882
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/01 23:08:33
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61547
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1882
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1882
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/01 23:08:33
|
0.6 s
|
[30773]
|
|
|
61544
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28890
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28890
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/01 23:08:32
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61545
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28890
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28890
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/01 23:08:32
|
0.6 s
|
[30772]
|
|
|
61542
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28889
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28889
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/01 23:08:32
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61543
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28889
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28889
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/01 23:08:32
|
0.6 s
|
[30771]
|
|
|
61540
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28888
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28888
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/01 23:08:31
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61541
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28888
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28888
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/01 23:08:31
|
0.6 s
|
[30770]
|
|
|
61538
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28887
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28887
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/01 23:08:30
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61539
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28887
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28887
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/01 23:08:30
|
0.6 s
|
[30769]
|
|
|
61536
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28886
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28886
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/01 23:08:30
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61537
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28886
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28886
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/01 23:08:30
|
0.6 s
|
[30768]
|
|
|
61534
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28885
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28885
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/01 23:08:29
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61535
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28885
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28885
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/01 23:08:29
|
0.6 s
|
[30767]
|
|
|
61532
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28884
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28884
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/01 23:08:28
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61533
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28884
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28884
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/01 23:08:28
|
0.6 s
|
[30766]
|
|
|
61530
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28883
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28883
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/01 23:08:28
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61531
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28883
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28883
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/01 23:08:28
|
0.6 s
|
[30765]
|
|
|
61528
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28882
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28882
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/01 23:08:27
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61529
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28882
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28882
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/01 23:08:27
|
0.6 s
|
[30764]
|
|
|
61526
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28881
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28881
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/01 23:08:26
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61527
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28881
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28881
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/01 23:08:26
|
0.6 s
|
[30763]
|
|
|
61524
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28880
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28880
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/01 23:08:25
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61525
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28880
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28880
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/01 23:08:25
|
0.6 s
|
[30762]
|
|
|
61522
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28879
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28879
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/01 23:08:25
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61523
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28879
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28879
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/01 23:08:25
|
0.6 s
|
[30761]
|
|
|
61520
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28878
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28878
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/01 23:08:24
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61521
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28878
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28878
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/01 23:08:24
|
0.6 s
|
[30760]
|
|
|
61518
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28877
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28877
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/01 23:08:23
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61519
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28877
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28877
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/01 23:08:23
|
0.6 s
|
[30759]
|
|
|
61516
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28876
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28876
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/01 23:08:23
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61517
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28876
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28876
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/01 23:08:23
|
0.6 s
|
[30758]
|
|
|
61514
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28875
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28875
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/01 23:08:22
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61515
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28875
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28875
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/01 23:08:22
|
0.6 s
|
[30757]
|
|
|
61512
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28874
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28874
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/01 23:08:21
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61513
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28874
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28874
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/01 23:08:21
|
0.6 s
|
[30756]
|
|
|
61510
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28873
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28873
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/01 23:08:20
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61511
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28873
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28873
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/01 23:08:20
|
0.6 s
|
[30755]
|
|
|
61508
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28872
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28872
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/01 23:08:20
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61509
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28872
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28872
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/01 23:08:20
|
0.6 s
|
[30754]
|
|
|
61506
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28871
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28871
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/01 23:08:19
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61507
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28871
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28871
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/01 23:08:19
|
0.6 s
|
[30753]
|
|
|
61504
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28870
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28870
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/01 23:08:18
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61505
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28870
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28870
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/01 23:08:18
|
0.6 s
|
[30752]
|
|
|
61502
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28869
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28869
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/01 23:08:18
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61503
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28869
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28869
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/01 23:08:18
|
0.6 s
|
[30751]
|
|
|
61500
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28868
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28868
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/01 23:08:17
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61501
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28868
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28868
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/01 23:08:17
|
0.6 s
|
[30750]
|
|
|
61498
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28867
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28867
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/01 23:08:16
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61499
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28867
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28867
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/01 23:08:16
|
0.6 s
|
[30749]
|
|
|
61496
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28866
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28866
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/01 23:08:15
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61497
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28866
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28866
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/01 23:08:15
|
0.6 s
|
[30748]
|
|
|
61494
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28865
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28865
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/01 23:08:15
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61495
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28865
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28865
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/01 23:08:15
|
0.6 s
|
[30747]
|
|
|
61492
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1881
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1881
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/01 23:08:14
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61493
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1881
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1881
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/01 23:08:14
|
0.7 s
|
[30746]
|
|
|
61490
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28864
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28864
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/01 23:08:13
|
1 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61491
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28864
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28864
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/01 23:08:13
|
1 s
|
[30745]
|
|
|
61488
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1880
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1880
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/01 23:08:13
|
0.8 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61489
|
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1880
+details
id = 8264c2ad-9deb-4ed0-b65f-37a32324a952
runId = ffd1549b-01c7-44e5-a8e4-080b7c74c8f9
batch = 1880
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/01 23:08:13
|
0.7 s
|
[30744]
|
|
|
61486
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28863
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28863
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/01 23:08:13
|
0.7 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61487
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28863
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28863
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/01 23:08:13
|
0.6 s
|
[30743]
|
|
|
61484
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28862
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28862
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/01 23:08:12
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61485
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28862
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28862
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/01 23:08:12
|
0.6 s
|
[30742]
|
|
|
61482
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28861
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28861
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/01 23:08:11
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61483
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28861
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28861
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/01 23:08:11
|
0.6 s
|
[30741]
|
|
|
61480
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28860
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28860
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/01 23:08:11
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61481
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28860
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28860
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/01 23:08:11
|
0.6 s
|
[30740]
|
|
|
61478
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28859
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28859
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/01 23:08:10
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61479
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28859
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28859
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/01 23:08:10
|
0.6 s
|
[30739]
|
|
|
61476
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28858
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28858
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/01 23:08:09
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61477
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28858
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28858
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/01 23:08:09
|
0.6 s
|
[30738]
|
|
|
61474
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28857
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28857
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/01 23:08:08
|
0.6 s
|
|
+details
|
|
|
| ID | Description | Submitted | Duration | Job IDs |
|
61475
|
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28857
+details
id = aa00c8aa-3286-4b91-a33a-2c229795c6e7
runId = 257ce27f-ade7-4e8a-9d0c-6a7974122e19
batch = 28857
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/01 23:08:08
|
0.6 s
|
[30737]
|
|