|
53
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 5
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 5
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:42
|
0.1 s
|
|
|
52
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 4
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 4
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:42
|
6 ms
|
|
|
50
|
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 3
+details
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 3
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:37
|
5 s
|
|
|
49
|
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 2
+details
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 2
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:37
|
4 ms
|
|
|
47
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 5
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 5
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:36
|
7 s
|
|
|
46
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 4
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 4
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:36
|
6 s
|
[18]
|
|
45
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 4
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 4
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:36
|
6 s
|
|
|
44
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 4
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 4
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:36
|
3 ms
|
|
|
43
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 3
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 3
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:36
|
8 ms
|
|
|
41
|
id = c83c618e-eac9-481d-8e45-2bde0d82701f
runId = 7e18f44d-be9b-4945-b3a4-eccf8dfc2985
batch = 1
+details
id = c83c618e-eac9-481d-8e45-2bde0d82701f
runId = 7e18f44d-be9b-4945-b3a4-eccf8dfc2985
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:30
|
12 s
|
|
|
40
|
id = c83c618e-eac9-481d-8e45-2bde0d82701f
runId = 7e18f44d-be9b-4945-b3a4-eccf8dfc2985
batch = 0
+details
id = c83c618e-eac9-481d-8e45-2bde0d82701f
runId = 7e18f44d-be9b-4945-b3a4-eccf8dfc2985
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:30
|
2 ms
|
|
|
39
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 4
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 4
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:29
|
7 s
|
[16]
|
|
38
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 4
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 4
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:29
|
7 s
|
|
|
37
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 3
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 3
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:29
|
4 ms
|
|
|
35
|
id = 1d4720dc-f006-4c8d-9b7d-1716a481681b
runId = 61e1d4d7-e682-42ec-879a-83a32ac478c6
batch = 1
+details
id = 1d4720dc-f006-4c8d-9b7d-1716a481681b
runId = 61e1d4d7-e682-42ec-879a-83a32ac478c6
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:23
|
19 s
|
|
|
34
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 3
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 3
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:23
|
13 s
|
[14]
|
|
33
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 3
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 3
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:23
|
13 s
|
|
|
32
|
id = 1d4720dc-f006-4c8d-9b7d-1716a481681b
runId = 61e1d4d7-e682-42ec-879a-83a32ac478c6
batch = 0
+details
id = 1d4720dc-f006-4c8d-9b7d-1716a481681b
runId = 61e1d4d7-e682-42ec-879a-83a32ac478c6
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:23
|
2 ms
|
|
|
31
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 3
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 3
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:23
|
6 s
|
[13]
|
|
30
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 3
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 3
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:23
|
6 s
|
|
|
29
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 2
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 2
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:23
|
9 ms
|
|
|
28
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 2
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 2
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:23
|
4 ms
|
|
|
27
|
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 2
+details
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 2
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:16
|
21 s
|
[12]
|
|
26
|
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 2
+details
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 2
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:16
|
21 s
|
|
|
25
|
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 1
+details
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:16
|
23 ms
|
|
|
24
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 2
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 2
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:02
|
21 s
|
[10]
|
|
23
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 2
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 2
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:02
|
21 s
|
|
|
22
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 2
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 2
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:02
|
21 s
|
[9]
|
|
21
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 2
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 2
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:02
|
21 s
|
|
|
20
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 1
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:01
|
42 ms
|
|
|
19
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 1
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:33:01
|
51 ms
|
|
|
18
|
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 1
+details
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:53
|
23 s
|
[7]
|
|
17
|
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 1
+details
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:53
|
23 s
|
|
|
16
|
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 0
+details
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:53
|
2 ms
|
|
|
15
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 1
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:44
|
17 s
|
[6]
|
|
14
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 1
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:44
|
17 s
|
|
|
13
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 1
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:44
|
17 s
|
[5]
|
|
12
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 1
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:44
|
17 s
|
|
|
11
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 0
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:44
|
3 ms
|
|
|
10
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 0
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:44
|
7 ms
|
|
|
9
|
id = 1d4720dc-f006-4c8d-9b7d-1716a481681b
runId = 61e1d4d7-e682-42ec-879a-83a32ac478c6
batch = 0
+details
id = 1d4720dc-f006-4c8d-9b7d-1716a481681b
runId = 61e1d4d7-e682-42ec-879a-83a32ac478c6
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:43
|
40 s
|
[3][8]
|
|
8
|
id = 1d4720dc-f006-4c8d-9b7d-1716a481681b
runId = 61e1d4d7-e682-42ec-879a-83a32ac478c6
batch = 0
+details
id = 1d4720dc-f006-4c8d-9b7d-1716a481681b
runId = 61e1d4d7-e682-42ec-879a-83a32ac478c6
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:43
|
40 s
|
|
|
7
|
id = c83c618e-eac9-481d-8e45-2bde0d82701f
runId = 7e18f44d-be9b-4945-b3a4-eccf8dfc2985
batch = 0
+details
id = c83c618e-eac9-481d-8e45-2bde0d82701f
runId = 7e18f44d-be9b-4945-b3a4-eccf8dfc2985
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:43
|
47 s
|
[4][11]
|
|
6
|
id = c83c618e-eac9-481d-8e45-2bde0d82701f
runId = 7e18f44d-be9b-4945-b3a4-eccf8dfc2985
batch = 0
+details
id = c83c618e-eac9-481d-8e45-2bde0d82701f
runId = 7e18f44d-be9b-4945-b3a4-eccf8dfc2985
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:43
|
47 s
|
|
|
5
|
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 0
+details
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:42
|
11 s
|
[2]
|
|
4
|
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 0
+details
id = 3cd2ce6a-cda3-4e07-9f6b-31eb0ac00a91
runId = 2ad6ec75-02a9-40e4-8f05-f0dd3dbf4b8d
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:42
|
11 s
|
|
|
3
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 0
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:42
|
2 s
|
[1]
|
|
2
|
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 0
+details
id = 6d310293-f49d-4343-b52b-3f61ba8ae650
runId = b3b45c2a-3f06-4af5-bb04-4a0b5738f4eb
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:42
|
2 s
|
|
|
1
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 0
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:42
|
2 s
|
[0]
|
|
0
|
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 0
+details
id = e770d7d5-3aa5-482b-96be-61954634dcc2
runId = 38b31eb8-a42d-42bb-95a5-70896e42c853
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:366)
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.lang.reflect.Method.invoke(Method.java:498)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.GatewayConnection.run(GatewayConnection.java:238)
java.lang.Thread.run(Thread.java:750)
|
2024/12/27 14:32:42
|
2 s
|
|
