|
142
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 100
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 100
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:10:31
|
6 s
|
[142]
|
|
145
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 101
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 101
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:11:32
|
8 s
|
[145]
|
|
146
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 102
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 102
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:12:32
|
6 s
|
[146]
|
|
149
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 103
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 103
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:13:31
|
7 s
|
[149]
|
|
150
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 104
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 104
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:14:32
|
6 s
|
[150]
|
|
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]
|
|
154
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 106
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 106
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:16:32
|
6 s
|
[154]
|
|
156
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 107
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 107
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:17:31
|
6 s
|
[156]
|
|
158
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 108
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 108
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:18:32
|
6 s
|
[158]
|
|
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]
|
|
163
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 110
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 110
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:20:32
|
8 s
|
[163]
|
|
165
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 111
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 111
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:21:31
|
7 s
|
[165]
|
|
166
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 112
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 112
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:22:31
|
6 s
|
[166]
|
|
168
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 113
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 113
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:23:31
|
6 s
|
[168]
|
|
170
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 114
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 114
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:24:32
|
6 s
|
[170]
|
|
173
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 115
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 115
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:25:32
|
8 s
|
[173]
|
|
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]
|
|
177
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 117
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 117
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:27:31
|
7 s
|
[176]
|
|
179
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 118
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 118
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:28:31
|
7 s
|
[179]
|
|
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]
|
|
182
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 120
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 120
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:30:31
|
5 s
|
[182]
|
|
184
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 121
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 121
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:31:31
|
6 s
|
[184]
|
|
186
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 122
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 122
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:32:31
|
7 s
|
[187]
|
|
189
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 123
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 123
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:33:31
|
7 s
|
[189]
|
|
190
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 124
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 124
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:34:31
|
6 s
|
[190]
|
|
192
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 125
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 125
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:35:31
|
6 s
|
[192]
|
|
195
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 126
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 126
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:36:31
|
7 s
|
[195]
|
|
197
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 127
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 127
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:37:31
|
8 s
|
[197]
|
|
199
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 128
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 128
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:38:32
|
8 s
|
[199]
|
|
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]
|
|
202
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 130
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 130
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:40:31
|
6 s
|
[202]
|
|
205
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 131
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 131
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:41:31
|
7 s
|
[205]
|
|
206
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 132
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 132
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:42:31
|
6 s
|
[206]
|
|
209
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 133
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 133
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:43:32
|
8 s
|
[209]
|
|
211
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 134
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 134
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:44:32
|
7 s
|
[211]
|
|
212
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 135
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 135
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:45:31
|
6 s
|
[212]
|
|
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]
|
|
216
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 137
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 137
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:47:31
|
6 s
|
[216]
|
|
218
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 138
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 138
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:48:31
|
6 s
|
[218]
|
|
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]
|
|
222
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 140
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 140
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:50:31
|
6 s
|
[222]
|
|
225
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 141
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 141
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:51:32
|
8 s
|
[225]
|
|
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]
|
|
228
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 143
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 143
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:53:32
|
6 s
|
[228]
|
|
230
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 144
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 144
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:54:31
|
7 s
|
[231]
|
|
233
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 145
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 145
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 18:55:32
|
7 s
|
[233]
|
|
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]
|
|
236
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 147
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 147
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:57:31
|
6 s
|
[236]
|
|
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]
|
|
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]
|
|
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]
|
|
244
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 151
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 151
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:01:32
|
8 s
|
[245]
|
|
246
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 152
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 152
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:02:31
|
5 s
|
[246]
|
|
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]
|
|
250
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 154
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 154
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:04:31
|
7 s
|
[250]
|
|
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]
|
|
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]
|
|
257
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 157
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 157
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:07:31
|
6 s
|
[256]
|
|
258
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 158
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 158
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:08:31
|
6 s
|
[258]
|
|
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]
|
|
263
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 160
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 160
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:10:32
|
7 s
|
[263]
|
|
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]
|
|
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]
|
|
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]
|
|
271
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 164
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 164
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:14:31
|
7 s
|
[271]
|
|
272
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 165
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 165
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:15:32
|
8 s
|
[273]
|
|
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]
|
|
277
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 167
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 167
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:17:31
|
7 s
|
[277]
|
|
278
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 168
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 168
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:18:31
|
6 s
|
[278]
|
|
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]
|
|
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]
|
|
285
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 171
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 171
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:21:32
|
8 s
|
[285]
|
|
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]
|
|
288
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 173
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 173
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:23:32
|
7 s
|
[288]
|
|
291
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 174
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 174
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:24:32
|
6 s
|
[290]
|
|
293
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 175
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 175
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:25:32
|
8 s
|
[293]
|
|
294
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 176
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 176
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:26:32
|
5 s
|
[294]
|
|
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]
|
|
298
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 178
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 178
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:28:31
|
6 s
|
[298]
|
|
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]
|
|
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]
|
|
304
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 181
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 181
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:31:31
|
5 s
|
[304]
|
|
306
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 182
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 182
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:32:32
|
7 s
|
[306]
|
|
308
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 183
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 183
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:33:31
|
6 s
|
[308]
|
|
310
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 184
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 184
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:34:31
|
6 s
|
[310]
|
|
312
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 185
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 185
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:35:31
|
6 s
|
[312]
|
|
315
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 186
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 186
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:36:31
|
7 s
|
[315]
|
|
317
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 187
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 187
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:37:31
|
7 s
|
[317]
|
|
318
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 188
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 188
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:38:31
|
6 s
|
[318]
|
|
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]
|
|
323
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 190
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 190
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:40:31
|
7 s
|
[323]
|
|
325
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 191
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 191
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:41:31
|
7 s
|
[325]
|
|
326
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 192
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 192
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:42:31
|
6 s
|
[326]
|
|
328
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 193
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 193
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:43:31
|
6 s
|
[328]
|
|
331
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 194
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 194
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
py4j.ClientServerConnection.waitForCommands(ClientServerConnection.java:182)
py4j.ClientServerConnection.run(ClientServerConnection.java:106)
java.base/java.lang.Thread.run(Thread.java:840)
|
2026/06/17 19:44:32
|
7 s
|
[331]
|
|
332
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 195
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 195
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:45:31
|
6 s
|
[332]
|
|
334
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 196
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 196
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:46:32
|
6 s
|
[334]
|
|
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]
|
|
338
|
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 198
+details
kafka_raw_to_minio
id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f
runId = e4e223f8-9cc1-454a-87d1-d3e31030f282
batch = 198
org.apache.spark.sql.streaming.DataStreamWriter.start(DataStreamWriter.scala:251)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:569)
py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
py4j.Gateway.invoke(Gateway.java:282)
py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
py4j.commands.CallCommand.execute(CallCommand.java:79)
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:48:31
|
6 s
|
[338]
|
|
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]
|