|
486
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 272
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 272
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:02:31
|
2 s
|
[486]
|
|
397
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 227
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 227
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:17:31
|
2 s
|
[396]
|
|
505
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 281
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 281
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:11:31
|
2 s
|
[504]
|
|
420
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 239
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 239
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:29:31
|
2 s
|
[420]
|
|
316
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 187
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 187
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:37:31
|
2 s
|
[316]
|
|
265
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 161
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 161
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:11:32
|
2 s
|
[264]
|
|
463
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 260
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 260
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:50:32
|
2 s
|
[462]
|
|
485
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 271
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 271
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:01:31
|
2 s
|
[484]
|
|
581
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 319
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 319
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:49:31
|
2 s
|
[580]
|
|
284
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 171
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 171
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:21:32
|
2 s
|
[284]
|
|
424
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 241
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 241
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:31:32
|
2 s
|
[424]
|
|
376
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 217
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 217
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:07:31
|
2 s
|
[376]
|
|
431
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 244
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 244
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:34:32
|
2 s
|
[430]
|
|
608
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 333
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 333
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 22:03:32
|
2 s
|
[608]
|
|
550
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 304
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 304
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:34:32
|
2 s
|
[550]
|
|
590
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 324
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 324
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:54:31
|
2 s
|
[590]
|
|
341
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 199
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 199
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:49:31
|
2 s
|
[340]
|
|
516
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 287
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 287
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:17:31
|
2 s
|
[516]
|
|
175
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 116
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 116
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:26:31
|
2 s
|
[174]
|
|
231
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 144
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 144
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:54:31
|
2 s
|
[230]
|
|
370
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 214
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 214
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:04:31
|
2 s
|
[370]
|
|
337
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 197
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 197
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:47:32
|
2 s
|
[336]
|
|
302
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 180
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 180
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:30:31
|
2 s
|
[302]
|
|
464
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 261
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 261
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:51:31
|
2 s
|
[464]
|
|
530
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 294
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 294
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:24:31
|
2 s
|
[530]
|
|
224
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 141
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 141
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:51:32
|
2 s
|
[224]
|
|
394
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 226
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 226
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:16:31
|
2 s
|
[394]
|
|
544
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 301
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 301
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:31:31
|
2 s
|
[544]
|
|
555
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 306
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 306
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:36:32
|
2 s
|
[554]
|
|
144
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 101
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 101
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:11:32
|
2 s
|
[144]
|
|
587
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 322
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 322
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:52:32
|
2 s
|
[586]
|
|
597
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 327
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 327
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:57:32
|
2 s
|
[596]
|
|
416
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 237
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 237
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:27:32
|
2 s
|
[416]
|
|
500
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 279
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 279
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:09:31
|
2 s
|
[500]
|
|
404
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 231
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 231
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:21:31
|
2 s
|
[404]
|
|
594
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 326
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 326
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:56:31
|
2 s
|
[594]
|
|
232
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 145
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 145
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:55:32
|
2 s
|
[232]
|
|
532
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 295
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 295
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:25:32
|
2 s
|
[532]
|
|
536
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 297
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 297
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:27:31
|
2 s
|
[536]
|
|
238
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 148
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 148
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:58:31
|
2 s
|
[238]
|
|
478
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 268
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 268
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:58:32
|
2 s
|
[478]
|
|
629
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 343
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 343
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 22:13:32
|
2 s
|
[628]
|
|
350
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 204
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 204
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:54:31
|
2 s
|
[350]
|
|
210
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 134
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 134
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:44:31
|
2 s
|
[210]
|
|
556
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 307
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 307
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:37:32
|
2 s
|
[556]
|
|
368
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 213
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 213
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:03:31
|
2 s
|
[368]
|
|
494
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 276
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 276
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:06:31
|
2 s
|
[494]
|
|
292
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 175
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 175
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:25:31
|
2 s
|
[292]
|
|
300
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 179
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 179
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:29:31
|
2 s
|
[300]
|
|
346
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 202
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 202
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:52:31
|
2 s
|
[346]
|
|
172
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 115
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 115
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:25:31
|
2 s
|
[172]
|
|
344
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 201
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 201
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:51:31
|
2 s
|
[344]
|
|
418
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 238
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 238
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:28:32
|
2 s
|
[418]
|
|
434
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 246
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 246
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:36:31
|
2 s
|
[434]
|
|
245
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 151
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 151
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:01:32
|
2 s
|
[244]
|
|
324
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 191
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 191
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:41:31
|
2 s
|
[324]
|
|
200
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 129
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 129
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:39:31
|
2 s
|
[200]
|
|
349
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 203
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 203
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:53:32
|
2 s
|
[348]
|
|
602
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 330
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 330
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 22:00:31
|
2 s
|
[602]
|
|
120
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 89
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 89
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 17:59:31
|
2 s
|
[120]
|
|
514
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 286
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 286
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:16:31
|
2 s
|
[514]
|
|
187
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 122
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 122
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:32:32
|
2 s
|
[186]
|
|
355
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 206
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 206
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:56:31
|
2 s
|
[354]
|
|
574
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 316
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 316
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:46:32
|
2 s
|
[574]
|
|
472
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 265
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 265
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:55:32
|
2 s
|
[472]
|
|
330
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 194
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 194
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:44:31
|
2 s
|
[330]
|
|
398
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 228
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 228
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:18:32
|
2 s
|
[398]
|
|
520
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 289
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 289
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:19:31
|
2 s
|
[520]
|
|
374
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 216
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 216
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:06:31
|
2 s
|
[374]
|
|
130
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 94
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 94
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:04:31
|
2 s
|
[130]
|
|
208
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 133
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 133
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:43:31
|
2 s
|
[208]
|
|
365
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 211
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 211
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:01:31
|
2 s
|
[364]
|
|
539
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 298
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 298
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:28:31
|
2 s
|
[538]
|
|
276
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 167
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 167
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:17:31
|
2 s
|
[276]
|
|
477
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 267
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 267
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:57:31
|
2 s
|
[476]
|
|
524
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 291
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 291
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:21:31
|
2 s
|
[524]
|
|
262
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 160
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 160
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:10:32
|
2 s
|
[262]
|
|
320
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 189
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 189
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:39:31
|
2 s
|
[320]
|
|
622
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 340
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 340
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 22:10:32
|
2 s
|
[622]
|
|
613
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 335
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 335
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 22:05:31
|
2 s
|
[612]
|
|
585
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 321
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 321
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:51:31
|
2 s
|
[584]
|
|
630
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 344
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 344
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 22:14:31
|
2 s
|
[630]
|
|
589
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 323
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 323
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:53:32
|
2 s
|
[588]
|
|
357
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 207
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 207
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:57:31
|
2 s
|
[356]
|
|
188
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 123
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 123
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:33:31
|
2 s
|
[188]
|
|
196
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 127
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 127
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:37:31
|
2 s
|
[196]
|
|
592
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 325
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 325
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:55:31
|
2 s
|
[592]
|
|
498
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 278
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 278
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:08:31
|
2 s
|
[498]
|
|
378
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 218
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 218
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:08:31
|
2 s
|
[378]
|
|
447
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 252
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 252
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:42:32
|
2 s
|
[446]
|
|
359
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 208
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 208
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:58:31
|
2 s
|
[358]
|
|
560
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 309
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 309
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:39:32
|
2 s
|
[560]
|
|
194
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 126
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 126
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:36:31
|
2 s
|
[194]
|
|
511
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 284
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 284
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:14:31
|
2 s
|
[510]
|
|
604
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 331
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 331
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 22:01:31
|
2 s
|
[604]
|
|
148
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 103
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 103
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 18:13:31
|
2 s
|
[148]
|
|
314
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 186
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 186
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 19:36:31
|
2 s
|
[314]
|
|
384
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 221
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 221
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:11:32
|
2 s
|
[384]
|
|
408
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 233
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 233
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 20:23:32
|
2 s
|
[408]
|
|
489
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 273
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 273
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(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.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(Thread.java:840)
|
2026/06/17 21:03:31
|
2 s
|
[488]
|