|
141
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 99
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 99
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:09:31
|
5 s
|
[141]
|
|
139
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 98
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 98
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:08:32
|
5 s
|
[139]
|
|
137
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 97
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 97
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:07:31
|
5 s
|
[137]
|
|
134
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 96
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 96
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:06:31
|
2 s
|
[134]
|
|
132
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 95
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 95
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:05:31
|
3 s
|
[132]
|
|
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]
|
|
129
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 93
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 93
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:03:32
|
2 s
|
[128]
|
|
127
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 92
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 92
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:02:32
|
6 s
|
[127]
|
|
125
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 91
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 91
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:01:32
|
6 s
|
[125]
|
|
122
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 90
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 90
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:00:31
|
3 s
|
[122]
|
|
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]
|
|
118
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 88
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 88
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:58:31
|
2 s
|
[118]
|
|
117
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 87
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 87
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:57:31
|
6 s
|
[117]
|
|
114
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 86
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 86
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:56:31
|
2 s
|
[114]
|
|
113
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 85
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 85
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:55:31
|
6 s
|
[113]
|
|
111
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 84
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 84
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:54:31
|
2 s
|
[110]
|
|
109
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 83
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 83
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:53:31
|
2 s
|
[108]
|
|
107
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 82
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 82
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:52:32
|
6 s
|
[107]
|
|
104
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 81
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 81
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:51:32
|
6 s
|
[105]
|
|
103
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 80
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 80
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:50:31
|
5 s
|
[103]
|
|
101
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 79
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 79
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:49:32
|
6 s
|
[101]
|
|
98
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 78
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 78
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:48:32
|
6 s
|
[99]
|
|
96
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 77
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 77
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:47:32
|
3 s
|
[96]
|
|
94
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 76
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 76
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:46:31
|
2 s
|
[94]
|
|
93
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 75
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 75
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:45:32
|
6 s
|
[93]
|
|
90
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 74
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 74
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:44:32
|
3 s
|
[90]
|
|
88
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 73
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 73
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:43:31
|
2 s
|
[88]
|
|
86
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 72
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 72
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:42:31
|
6 s
|
[87]
|
|
84
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 71
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 71
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:41:31
|
2 s
|
[84]
|
|
83
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 70
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 70
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:40:32
|
6 s
|
[83]
|
|
80
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 69
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 69
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:39:31
|
3 s
|
[80]
|
|
79
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 68
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 68
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:38:32
|
6 s
|
[79]
|
|
76
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 67
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 67
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:37:31
|
8 s
|
[77]
|
|
74
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 66
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 66
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:36:32
|
2 s
|
[74]
|
|
72
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 65
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 65
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:35:32
|
2 s
|
[72]
|
|
71
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 64
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 64
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:34:32
|
6 s
|
[71]
|
|
69
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 63
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 63
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:33:31
|
8 s
|
[69]
|
|
66
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 62
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 62
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:32:31
|
2 s
|
[66]
|
|
65
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 61
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 61
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:31:32
|
5 s
|
[65]
|
|
62
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 60
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 60
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:30:31
|
6 s
|
[63]
|
|
60
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 59
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 59
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:29:31
|
6 s
|
[61]
|
|
59
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 58
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 58
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:28:32
|
6 s
|
[59]
|
|
57
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 57
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 57
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:27:32
|
8 s
|
[57]
|
|
55
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 56
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 56
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:26:32
|
6 s
|
[55]
|
|
52
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 55
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 55
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:25:31
|
3 s
|
[52]
|
|
50
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 54
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 54
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:24:31
|
6 s
|
[51]
|
|
49
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 53
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 53
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:23:32
|
6 s
|
[49]
|
|
47
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 52
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 52
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:22:32
|
5 s
|
[47]
|
|
44
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 51
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 51
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:21:31
|
6 s
|
[45]
|
|
42
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 50
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 50
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:20:32
|
6 s
|
[43]
|
|
41
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 49
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 49
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:19:32
|
6 s
|
[41]
|
|
39
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 48
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 48
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:18:32
|
6 s
|
[39]
|
|
37
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 47
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 47
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:17:32
|
7 s
|
[37]
|
|
862
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 460
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 460
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/18 00:10:31
|
2 s
|
[862]
|
|
34
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 46
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 46
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:16:32
|
7 s
|
[35]
|
|
861
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 459
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 459
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/18 00:09:32
|
5 s
|
[861]
|
|
859
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 458
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 458
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/18 00:08:32
|
6 s
|
[859]
|
|
857
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 457
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 457
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/18 00:07:32
|
5 s
|
[857]
|
|
854
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 456
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 456
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/18 00:06:31
|
2 s
|
[854]
|
|
853
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 455
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 455
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/18 00:05:31
|
5 s
|
[853]
|
|
851
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 454
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 454
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/18 00:04:31
|
5 s
|
[851]
|
|
849
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 453
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 453
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/18 00:03:32
|
5 s
|
[849]
|
|
846
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 452
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 452
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/18 00:02:31
|
2 s
|
[846]
|
|
844
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 451
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 451
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/18 00:01:32
|
2 s
|
[844]
|
|
843
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 450
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 450
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/18 00:00:32
|
6 s
|
[843]
|
|
32
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 45
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 45
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:15:32
|
3 s
|
[32]
|
|
840
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 449
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 449
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 23:59:31
|
2 s
|
[840]
|
|
838
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 448
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 448
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 23:58:31
|
2 s
|
[838]
|
|
837
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 447
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 447
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 23:57:32
|
5 s
|
[837]
|
|
834
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 446
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 446
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 23:56:31
|
2 s
|
[834]
|
|
833
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 445
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 445
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 23:55:31
|
5 s
|
[833]
|
|
831
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 444
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 444
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 23:54:31
|
2 s
|
[830]
|
|
829
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 443
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 443
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 23:53:32
|
5 s
|
[829]
|
|
827
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 442
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 442
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 23:52:31
|
2 s
|
[826]
|
|
824
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 441
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 441
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 23:51:31
|
2 s
|
[824]
|
|
822
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 440
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 440
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 23:50:31
|
3 s
|
[822]
|
|
30
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 44
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 44
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:14:31
|
6 s
|
[31]
|
|
821
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 439
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 439
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 23:49:32
|
2 s
|
[820]
|
|
818
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 438
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 438
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 23:48:31
|
2 s
|
[818]
|
|
816
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 437
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 437
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 23:47:31
|
2 s
|
[816]
|
|
814
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 436
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 436
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 23:46:31
|
2 s
|
[814]
|
|
812
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 435
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 435
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 23:45:32
|
2 s
|
[812]
|
|
811
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 434
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 434
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 23:44:32
|
5 s
|
[811]
|
|
808
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 433
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 433
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 23:43:31
|
2 s
|
[808]
|
|
807
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 432
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 432
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 23:42:32
|
5 s
|
[807]
|
|
805
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 431
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 431
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 23:41:31
|
2 s
|
[804]
|
|
802
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 430
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 430
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 23:40:31
|
2 s
|
[802]
|
|
28
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 43
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 43
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:13:31
|
2 s
|
[28]
|
|
800
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 429
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 429
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 23:39:32
|
2 s
|
[800]
|
|
798
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 428
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 428
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 23:38:32
|
2 s
|
[798]
|
|
797
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 427
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 427
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 23:37:32
|
7 s
|
[797]
|
|
795
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 426
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 426
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 23:36:31
|
2 s
|
[794]
|
|
792
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 425
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 425
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 23:35:32
|
2 s
|
[792]
|
|
791
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 424
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 424
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 23:34:31
|
2 s
|
[790]
|
|
788
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 423
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 423
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 23:33:31
|
2 s
|
[788]
|
|
787
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 422
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 422
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 23:32:31
|
5 s
|
[787]
|
|
785
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 421
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 421
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 23:31:32
|
5 s
|
[785]
|
|
783
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 420
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 420
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 23:30:32
|
5 s
|
[783]
|
|
27
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 42
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 42
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:12:32
|
6 s
|
[27]
|
|
780
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 419
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 419
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 23:29:32
|
2 s
|
[780]
|