|
1
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 29
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 29
org.apache.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:01:09
|
45 s
|
[1]
|
|
0
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 29
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 29
org.apache.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:01:09
|
43 s
|
[0]
|
|
241
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 149
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 149
org.apache.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:59:31
|
14 s
|
[241]
|
|
781
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 419
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
13 s
|
[781]
|
|
281
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 169
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 169
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:19:31
|
13 s
|
[281]
|
|
621
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 339
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 339
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 22:09:32
|
13 s
|
[621]
|
|
801
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 429
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
13 s
|
[801]
|
|
561
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 309
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 309
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:39:32
|
13 s
|
[561]
|
|
521
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 289
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 289
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:19:31
|
13 s
|
[521]
|
|
301
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 179
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 179
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:29:31
|
13 s
|
[301]
|
|
260
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 159
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 159
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:09:31
|
13 s
|
[260]
|
|
201
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 129
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 129
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:39:31
|
12 s
|
[201]
|
|
721
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 389
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 389
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 22:59:31
|
12 s
|
[721]
|
|
661
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 359
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 359
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 22:29:32
|
12 s
|
[661]
|
|
841
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 449
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
12 s
|
[841]
|
|
381
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 219
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 219
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 20:09:32
|
12 s
|
[381]
|
|
501
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 279
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 279
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:09:31
|
12 s
|
[501]
|
|
321
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 189
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 189
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:39:32
|
12 s
|
[321]
|
|
481
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 269
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 269
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 20:59:31
|
12 s
|
[481]
|
|
81
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 69
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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:32
|
12 s
|
[81]
|
|
820
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 439
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
12 s
|
[821]
|
|
641
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 349
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 349
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 22:19:32
|
12 s
|
[641]
|
|
421
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 239
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 239
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 20:29:32
|
12 s
|
[421]
|
|
741
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 399
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 399
org.apache.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:09:31
|
11 s
|
[741]
|
|
160
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 109
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 109
org.apache.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:19:31
|
11 s
|
[160]
|
|
580
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 319
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 319
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:49:31
|
11 s
|
[581]
|
|
701
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 379
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 379
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 22:49:31
|
11 s
|
[700]
|
|
681
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 369
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 369
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 22:39:32
|
11 s
|
[681]
|
|
340
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 199
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 199
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:49:31
|
11 s
|
[341]
|
|
121
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 89
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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:32
|
10 s
|
[121]
|
|
180
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 119
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 119
org.apache.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:29:31
|
10 s
|
[180]
|
|
21
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 39
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 39
org.apache.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:09:32
|
10 s
|
[21]
|
|
220
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 139
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 139
org.apache.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:49:31
|
10 s
|
[220]
|
|
401
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 229
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 229
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 20:19:32
|
10 s
|
[400]
|
|
760
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 409
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 409
org.apache.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:19:31
|
10 s
|
[760]
|
|
360
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 209
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 209
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:59:31
|
10 s
|
[360]
|
|
600
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 329
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 329
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:59:31
|
10 s
|
[600]
|
|
253
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 155
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 155
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:05:31
|
10 s
|
[253]
|
|
540
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 299
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 299
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:29:31
|
10 s
|
[540]
|
|
53
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 55
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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:32
|
10 s
|
[53]
|
|
275
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 166
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 166
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:16:31
|
10 s
|
[275]
|
|
440
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 249
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 249
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 20:39:31
|
10 s
|
[440]
|
|
722
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 390
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 390
org.apache.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:00:32
|
10 s
|
[723]
|
|
268
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 163
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 163
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:13:32
|
9 s
|
[269]
|
|
567
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 312
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 312
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:42:32
|
9 s
|
[567]
|
|
227
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 142
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 142
org.apache.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:52:31
|
9 s
|
[227]
|
|
33
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 45
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
9 s
|
[33]
|
|
282
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 170
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 170
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:20:31
|
9 s
|
[283]
|
|
174
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 116
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 116
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:26:31
|
9 s
|
[175]
|
|
255
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 156
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 156
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:06:31
|
9 s
|
[255]
|
|
460
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 259
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 259
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 20:49:31
|
9 s
|
[460]
|
|
578
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 318
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 318
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:48:31
|
9 s
|
[579]
|
|
61
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 59
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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:32
|
9 s
|
[60]
|
|
100
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 79
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
9 s
|
[100]
|
|
583
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 320
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 320
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:50:31
|
9 s
|
[583]
|
|
823
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 440
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
9 s
|
[823]
|
|
642
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 350
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 350
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 22:20:32
|
9 s
|
[643]
|
|
40
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 49
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
9 s
|
[40]
|
|
419
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 238
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 238
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 20:28:32
|
9 s
|
[419]
|
|
97
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 77
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
9 s
|
[97]
|
|
249
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 153
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 153
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:03:31
|
9 s
|
[249]
|
|
267
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 162
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 162
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:12:31
|
9 s
|
[267]
|
|
91
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 74
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
9 s
|
[91]
|
|
234
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 146
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 146
org.apache.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:56:31
|
9 s
|
[235]
|
|
297
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 177
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 177
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:27:31
|
9 s
|
[297]
|
|
24
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 41
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 41
org.apache.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:11:32
|
8 s
|
[24]
|
|
85
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 71
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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:32
|
8 s
|
[85]
|
|
763
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 410
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 410
org.apache.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:20:32
|
8 s
|
[763]
|
|
287
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 172
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 172
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:22:31
|
8 s
|
[287]
|
|
25
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 41
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 41
org.apache.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:11:32
|
8 s
|
[25]
|
|
239
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 148
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 148
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:58:32
|
8 s
|
[239]
|
|
628
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 343
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 343
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 22:13:32
|
8 s
|
[629]
|
|
510
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 284
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 284
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:14:31
|
8 s
|
[511]
|
|
676
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 367
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 367
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 22:37:31
|
8 s
|
[677]
|
|
358
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 208
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 208
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:58:31
|
8 s
|
[359]
|
|
584
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 321
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 321
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:51:31
|
8 s
|
[585]
|
|
667
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 362
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 362
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 22:32:32
|
8 s
|
[667]
|
|
686
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 372
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 372
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 22:42:32
|
8 s
|
[687]
|
|
140
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 99
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
8 s
|
[140]
|
|
264
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 161
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 161
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:11:32
|
8 s
|
[265]
|
|
684
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 371
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 371
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 22:41:31
|
8 s
|
[685]
|
|
336
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 197
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 197
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:47:31
|
8 s
|
[337]
|
|
153
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 105
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 105
org.apache.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:15:31
|
8 s
|
[153]
|
|
747
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 402
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 402
org.apache.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:12:31
|
8 s
|
[747]
|
|
588
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 323
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 323
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:53:31
|
8 s
|
[589]
|
|
215
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 136
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 136
org.apache.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:46:31
|
8 s
|
[215]
|
|
95
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 76
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
8 s
|
[95]
|
|
764
|
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 411
+details
kafka_to_clickhouse
id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8
runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e
batch = 411
org.apache.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:21:32
|
8 s
|
[765]
|
|
303
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 180
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 180
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:30:31
|
8 s
|
[303]
|
|
369
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 213
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 213
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 20:03:31
|
8 s
|
[369]
|
|
766
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 412
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 412
org.apache.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:22:31
|
8 s
|
[767]
|
|
432
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 245
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 245
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 20:35:32
|
8 s
|
[433]
|
|
133
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 95
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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:32
|
8 s
|
[133]
|
|
75
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 66
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
8 s
|
[75]
|
|
123
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 90
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
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
|
8 s
|
[123]
|
|
533
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 295
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 295
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:25:32
|
8 s
|
[533]
|
|
538
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 298
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 298
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:28:31
|
8 s
|
[539]
|
|
557
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 307
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 307
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 21:37:32
|
8 s
|
[557]
|
|
243
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 150
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 150
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:00:32
|
8 s
|
[243]
|
|
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]
|