|
2
|
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 0
+details
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 20:52:22
|
15 s
|
[2][12][15][18][22][26][28][31][34][37][39][43][44][45][46][47]
|
|
5
|
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 1
+details
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 22:03:00
|
3 s
|
[80][81][82][83][84][85][86][87][88][89][90][91][92][93][94][95]
|
|
9
|
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 2
+details
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 2
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 22:30:00
|
3 s
|
[144][145][146][147][148][149][150][151][152][153][154][155][156][157][158][159]
|
|
14
|
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 3
+details
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 3
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 23:24:00
|
2 s
|
[224][225][226][227][228][229][230][231][232][233][234][235][236][237][238][239]
|
|
19
|
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 4
+details
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 4
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 23:51:00
|
2 s
|
[304][305][306][307][308][309][310][311][312][313][314][315][316][317][318][319]
|
|
22
|
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 5
+details
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 5
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 00:18:00
|
3 s
|
[352][354][355][356][357][358][360][361][363][365][367][370][371][374][375][377]
|
|
25
|
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 6
+details
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 6
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 01:12:00
|
2 s
|
[400][401][402][403][404][405][406][407][408][409][410][411][412][413][414][415]
|
|
29
|
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 7
+details
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 7
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 01:39:00
|
2 s
|
[464][465][466][467][468][469][470][471][472][473][474][475][476][477][478][479]
|
|
37
|
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 8
+details
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 8
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 03:00:00
|
2 s
|
[592][593][594][595][596][597][598][599][600][601][602][603][604][605][606][607]
|
|
40
|
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 9
+details
KEYWORD
id = 8396cfc3-897b-483f-8adb-ceaff1764efe
runId = 002eaeaa-2f81-4fa0-b52a-f16273d64d29
batch = 9
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 04:21:00
|
2 s
|
[640][641][642][643][644][645][646][647][648][649][650][651][652][653][654][655]
|
|
0
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 0
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 20:52:21
|
14 s
|
[1][4][6][8][10][13][16][19][21][24][27][30][33][36][40][42]
|
|
3
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 1
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 21:55:00
|
4 s
|
[48][49][50][51][52][53][54][55][56][57][58][59][60][61][62][63]
|
|
31
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 10
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 10
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 01:45:00
|
3 s
|
[496][497][498][499][500][501][502][503][504][505][506][507][508][509][510][511]
|
|
33
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 11
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 11
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 02:08:00
|
2 s
|
[528][529][530][531][532][533][534][535][536][537][538][539][540][541][542][543]
|
|
36
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 12
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 12
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 02:54:00
|
3 s
|
[576][577][578][579][580][581][582][583][584][585][586][587][588][589][590][591]
|
|
39
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 13
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 13
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 03:17:00
|
2 s
|
[624][625][626][627][628][629][630][631][632][633][634][635][636][637][638][639]
|
|
41
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 14
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 14
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 04:26:00
|
3 s
|
[656][657][658][659][660][661][662][663][664][665][666][667][668][669][670][671]
|
|
7
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 2
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 2
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 22:18:00
|
3 s
|
[112][113][114][115][116][117][118][119][120][121][122][123][124][125][126][127]
|
|
11
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 3
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 3
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 22:41:00
|
3 s
|
[176][177][178][179][180][181][182][183][184][185][186][187][188][189][190][191]
|
|
12
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 4
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 4
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 23:04:00
|
3 s
|
[192][193][194][195][196][197][198][199][200][201][202][203][204][205][206][207]
|
|
15
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 5
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 5
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 23:27:00
|
2 s
|
[240][241][242][243][244][245][246][247][248][249][250][251][252][253][254][255]
|
|
17
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 6
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 6
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 23:50:00
|
4 s
|
[272][274][275][276][277][279][281][283][285][287][289][291][293][295][297][299]
|
|
21
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 7
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 7
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 00:13:00
|
3 s
|
[336][337][338][339][340][341][342][343][344][345][346][347][348][349][350][351]
|
|
24
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 8
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 8
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 00:36:00
|
2 s
|
[384][385][386][387][388][389][390][391][392][393][394][395][396][397][398][399]
|
|
27
|
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 9
+details
REFERRAL
id = 82ac66eb-6ed1-4aa2-ae76-7d5f8c9746ad
runId = 184404a1-7672-47f3-81a6-842372b55bc2
batch = 9
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 01:22:00
|
3 s
|
[432][433][434][435][436][437][438][439][440][441][442][443][444][445][446][447]
|
|
1
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 0
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 0
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 20:52:21
|
14 s
|
[0][3][5][7][9][11][14][17][20][23][25][29][32][35][38][41]
|
|
4
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 1
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 1
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 21:58:00
|
3 s
|
[64][65][66][67][68][69][70][71][72][73][74][75][76][77][78][79]
|
|
26
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 10
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 10
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 01:14:00
|
3 s
|
[416][417][418][419][420][421][422][423][424][425][426][427][428][429][430][431]
|
|
28
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 11
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 11
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 01:28:00
|
3 s
|
[448][449][450][451][452][453][454][455][456][457][458][459][460][461][462][463]
|
|
30
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 12
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 12
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 01:42:00
|
3 s
|
[480][481][482][483][484][485][486][487][488][489][490][491][492][493][494][495]
|
|
32
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 13
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 13
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 01:56:00
|
2 s
|
[512][513][514][515][516][517][518][519][520][521][522][523][524][525][526][527]
|
|
34
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 14
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 14
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 02:38:00
|
3 s
|
[544][545][546][547][548][549][550][551][552][553][554][555][556][557][558][559]
|
|
35
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 15
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 15
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 02:52:00
|
3 s
|
[560][561][562][563][564][565][566][567][568][569][570][571][572][573][574][575]
|
|
38
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 16
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 16
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 03:06:00
|
2 s
|
[608][609][610][611][612][613][614][615][616][617][618][619][620][621][622][623]
|
|
42
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 17
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 17
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 04:30:00
|
3 s
|
[672][673][674][675][676][677][678][679][680][681][682][683][684][685][686][687]
|
|
6
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 2
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 2
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 22:12:00
|
3 s
|
[96][97][98][99][100][101][102][103][104][105][106][107][108][109][110][111]
|
|
8
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 3
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 3
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 22:26:00
|
3 s
|
[128][129][130][131][132][133][134][135][136][137][138][139][140][141][142][143]
|
|
10
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 4
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 4
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 22:40:00
|
2 s
|
[160][161][162][163][164][165][166][167][168][169][170][171][172][173][174][175]
|
|
13
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 5
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 5
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 23:08:00
|
3 s
|
[208][209][210][211][212][213][214][215][216][217][218][219][220][221][222][223]
|
|
16
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 6
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 6
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 23:36:00
|
3 s
|
[256][257][258][259][260][261][262][263][264][265][266][267][268][269][270][271]
|
|
18
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 7
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 7
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/05 23:50:00
|
4 s
|
[273][278][280][282][284][286][288][290][292][294][296][298][300][301][302][303]
|
|
20
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 8
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 8
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 00:04:00
|
3 s
|
[320][321][322][323][324][325][326][327][328][329][330][331][332][333][334][335]
|
|
23
|
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 9
+details
TITLE
id = 63b70049-502b-4ae4-afcb-c8d670270bc1
runId = 15e97575-99c6-4e2b-b852-d71d45c67470
batch = 9
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
java.base/java.lang.reflect.Method.invoke(Unknown Source)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Unknown Source)
|
2025/12/06 00:18:00
|
4 s
|
[353][359][362][364][366][368][369][372][373][376][378][379][380][381][382][383]
|