|
0
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 0
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/07/01 07:07:44
|
1.7 min
|
[0][3][5][8][11][14][17][20][23][26][31][34][37][41][44][47]
|
|
1
|
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
batch = 0
+details
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
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)
|
2026/07/01 07:07:44
|
1.7 min
|
[1][4][7][10][13][16][18][22][25][28][29][33][36][39][43][46]
|
|
2
|
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
batch = 0
+details
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
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)
|
2026/07/01 07:07:44
|
1.7 min
|
[2][6][9][12][15][19][21][24][27][30][32][35][38][40][42][45]
|
|
3
|
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
batch = 1
+details
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
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)
|
2026/07/01 23:32:02
|
32 s
|
[48][49][50][51][52][53][54][55][56][57][58][59][60][61][62][63]
|
|
4
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 1
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/07/01 23:36:02
|
21 s
|
[64][65][66][67][68][69][70][71][72][73][74][75][76][77][78][79]
|
|
5
|
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
batch = 1
+details
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
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)
|
2026/07/01 23:42:01
|
18 s
|
[80][81][82][83][84][85][86][87][88][89][90][91][92][93][94][95]
|
|
6
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 2
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/07/01 23:59:02
|
15 s
|
[96][97][98][99][100][101][102][103][104][105][106][107][108][109][110][111]
|
|
7
|
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
batch = 2
+details
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
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)
|
2026/09/04 01:48:01
|
22 s
|
[112][113][114][115][116][117][118][119][120][121][122][123][124][125][126][127]
|
|
8
|
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
batch = 2
+details
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
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)
|
2026/09/04 01:54:01
|
21 s
|
[128][129][130][131][132][133][134][135][136][137][138][139][140][141][142][143]
|
|
9
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 3
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/09/04 01:55:01
|
19 s
|
[144][145][146][147][148][149][150][151][152][153][154][155][156][157][158][159]
|
|
10
|
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
batch = 3
+details
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
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)
|
2026/09/04 02:08:01
|
17 s
|
[160][161][162][163][164][165][166][167][168][169][170][171][172][173][174][175]
|
|
11
|
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
batch = 3
+details
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
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)
|
2026/09/04 02:15:01
|
14 s
|
[176][177][178][179][180][181][182][183][184][185][186][187][188][189][190][191]
|
|
12
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 4
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/09/04 02:18:01
|
15 s
|
[192][193][194][195][196][197][198][199][200][201][202][203][204][205][206][207]
|
|
13
|
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
batch = 4
+details
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
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)
|
2026/09/04 02:22:01
|
15 s
|
[208][209][210][211][212][213][214][215][216][217][218][219][220][221][222][223]
|
|
14
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 5
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/09/04 02:41:01
|
14 s
|
[224][225][226][227][228][229][230][231][232][233][234][235][236][237][238][239]
|
|
15
|
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
batch = 4
+details
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
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)
|
2026/09/04 02:42:00
|
14 s
|
[240][241][242][243][244][245][246][247][248][249][250][251][252][253][254][255]
|
|
16
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 6
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/09/04 03:04:01
|
11 s
|
[256][257][258][259][260][261][262][263][264][265][266][267][268][269][270][271]
|
|
17
|
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
batch = 5
+details
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
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)
|
2026/09/11 08:40:01
|
18 s
|
[272][273][274][275][276][277][278][279][280][281][282][283][284][285][286][287]
|
|
18
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 7
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/09/11 08:43:01
|
19 s
|
[288][289][290][291][292][293][294][295][296][297][298][299][300][301][302][303]
|
|
19
|
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
batch = 5
+details
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
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)
|
2026/09/11 08:51:01
|
16 s
|
[304][305][306][307][308][309][310][311][312][313][314][315][316][317][318][319]
|
|
20
|
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
batch = 6
+details
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
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)
|
2026/09/11 08:54:01
|
18 s
|
[320][321][322][323][324][325][326][327][328][329][330][331][332][333][334][335]
|
|
21
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 8
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/09/11 09:06:01
|
15 s
|
[336][337][338][339][340][341][342][343][344][345][346][347][348][349][350][351]
|
|
22
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 9
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/09/11 09:29:01
|
11 s
|
[352][353][354][355][356][357][358][359][360][361][362][363][364][365][366][367]
|
|
23
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 10
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/10/23 04:40:01
|
17 s
|
[368][369][370][371][372][373][374][375][376][377][378][379][380][381][382][383]
|
|
24
|
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
batch = 7
+details
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
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)
|
2026/10/23 04:42:01
|
15 s
|
[384][385][386][387][388][389][390][391][392][393][394][395][396][397][398][399]
|
|
25
|
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
batch = 6
+details
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
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)
|
2026/10/23 04:48:01
|
13 s
|
[400][401][402][403][404][405][406][407][408][409][410][411][412][413][414][415]
|
|
26
|
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
batch = 8
+details
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
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)
|
2026/10/23 04:56:01
|
14 s
|
[416][417][418][419][420][421][422][423][424][425][426][427][428][429][430][431]
|
|
27
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 11
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/10/23 05:03:01
|
15 s
|
[432][433][434][435][436][437][438][439][440][441][442][443][444][445][446][447]
|
|
28
|
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
batch = 7
+details
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
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)
|
2026/10/23 05:15:01
|
14 s
|
[448][449][450][451][452][453][454][455][456][457][458][459][460][461][462][463]
|
|
29
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 12
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/10/23 05:26:00
|
15 s
|
[464][465][466][467][468][469][470][471][472][473][474][475][476][477][478][479]
|
|
30
|
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
batch = 9
+details
TITLE
id = 0687b404-bd96-4d0d-86b3-3d30aeab4f1a
runId = 7eef1e77-0c6f-4fb3-bfb8-1d1179c92735
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)
|
2026/10/23 06:06:01
|
14 s
|
[480][481][482][483][484][485][486][487][488][489][490][491][492][493][494][495]
|
|
31
|
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
batch = 8
+details
KEYWORD
id = 2530aeed-c751-4342-b1a7-0bb4cc609064
runId = 96917854-57f8-44d4-be2a-deba481668ad
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)
|
2026/10/23 06:09:00
|
11 s
|
[496][497][498][499][500][501][502][503][504][505][506][507][508][509][510][511]
|
|
32
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 13
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/10/23 06:12:00
|
13 s
|
[512][513][514][515][516][517][518][519][520][521][522][523][524][525][526][527]
|
|
33
|
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
batch = 14
+details
REFERRAL
id = 844d91ec-b3ed-4d48-80ba-59fb76b066a7
runId = 906fc2c7-4e02-4dd8-b6bd-e1479cd0eeb1
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)
|
2026/10/23 06:35:00
|
11 s
|
[528][529][530][531][532][533][534][535][536][537][538][539][540][541][542][543]
|