Spark Jobs (?)

  • User: spark
  • Total Uptime: 3.2 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 384
Event Timeline

Completed Jobs (384)

Page:
Job Id (Job Group) Description Submitted Duration ▴ Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
316 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 187 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:37:32 2 s 1/1
3/3
144 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 101 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:11:32 2 s 1/1
3/3
380 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 219 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:09:32 2 s 1/1
3/3
370 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 214 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:04:31 2 s 1/1
3/3
358 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 208 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:58:32 2 s 1/1
3/3
340 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 199 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:49:32 2 s 1/1
3/3
284 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 171 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:21:32 2 s 1/1
3/3
262 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 160 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:10:32 2 s 1/1
3/3
224 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 141 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:51:32 2 s 1/1
3/3
178 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 118 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:28:31 2 s 1/1
3/3
174 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 116 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:26:32 2 s 1/1
3/3
270 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 164 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:14:32 2 s 1/1
3/3
264 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 161 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:11:32 2 s 1/1
3/3
344 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 201 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:51:32 2 s 1/1
3/3
300 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 179 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:29:32 2 s 1/1
3/3
374 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 216 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:06:32 2 s 1/1
3/3
238 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 148 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:58:32 2 s 1/1
3/3
230 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 144 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:54:32 2 s 1/1
3/3
378 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 218 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:08:32 2 s 1/1
3/3
232 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 145 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:55:32 2 s 1/1
3/3
324 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 191 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:41:31 2 s 1/1
3/3
292 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 175 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:25:32 2 s 1/1
3/3
354 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 206 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:56:32 2 s 1/1
3/3
302 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 180 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:30:32 2 s 1/1
3/3
350 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 204 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:54:32 2 s 1/1
3/3
322 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 190 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:40:32 2 s 1/1
3/3
356 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 207 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:57:31 2 s 1/1
3/3
346 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 202 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:52:31 2 s 1/1
3/3
320 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 189 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:39:32 2 s 1/1
3/3
200 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 129 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:39:32 2 s 1/1
3/3
114 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 86 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:56:32 2 s 1/1
3/3
172 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 115 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:25:32 2 s 1/1
3/3
348 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 203 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:53:32 2 s 1/1
3/3
210 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 134 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:44:32 2 s 1/1
3/3
94 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 76 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:46:32 2 s 1/1
3/3
368 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 213 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:03:31 2 s 1/1
3/3
276 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 167 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:17:32 2 s 1/1
3/3
376 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 217 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:07:31 2 s 1/1
3/3
336 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 197 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:47:32 2 s 1/1
3/3
148 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 103 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:13:32 2 s 1/1
3/3
330 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 194 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:44:32 2 s 1/1
3/3
204 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 131 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:41:32 2 s 1/1
3/3
196 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 127 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:37:31 2 s 1/1
3/3
364 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 211 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:01:32 2 s 1/1
3/3
188 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 123 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:33:32 2 s 1/1
3/3
244 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 151 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:01:32 2 s 1/1
3/3
242 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 150 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:00:32 2 s 1/1
3/3
208 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 133 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:43:32 2 s 1/1
3/3
128 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 93 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:03:32 2 s 1/1
3/3
194 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 126 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:36:31 2 s 1/1
3/3
152 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 105 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:15:32 2 s 1/1
3/3
286 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 172 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:22:32 2 s 1/1
3/3
296 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 177 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:27:31 2 s 1/1
3/3
198 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 128 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:38:32 2 s 1/1
3/3
134 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 96 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:06:32 2 s 1/1
3/3
130 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 94 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:04:31 2 s 1/1
3/3
120 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 89 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:59:32 2 s 1/1
3/3
314 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 186 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:36:32 2 s 1/1
3/3
72 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 65 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:35:32 2 s 1/1
3/3
110 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 84 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:54:32 2 s 1/1
3/3
88 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 73 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:43:32 2 s 1/1
3/3
66 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 62 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:32:32 2 s 1/1
3/3
214 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 136 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:46:32 2 s 1/1
3/3
118 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 88 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:58:31 2 s 1/1
3/3
186 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 122 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:32:32 2 s 1/1
3/3
164 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 111 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:21:31 2 s 1/1
3/3
108 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 83 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:53:31 2 s 1/1
3/3
272 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 165 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:15:32 2 s 1/1
3/3
74 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 66 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:36:32 2 s 1/1
3/3
28 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 43 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:13:31 2 s 1/1
3/3
84 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 71 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:41:32 2 s 1/1
3/3
20 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 39 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:09:32 2 s 1/1
3/3
282 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 170 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:20:32 2 s 1/1
3/3
162 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 110 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:20:32 2 s 1/1
3/3
4 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 31 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:02:08 2 s 1/1
3/3
3 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 30 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:02:01 2 s 1/1
3/3
122 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 90 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:00:32 2 s 1/1
3/3
274 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 166 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:16:32 2 s 1/1
4/4
254 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 156 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:06:32 2 s 1/1
4/4
268 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 163 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:13:32 2 s 1/1
4/4
234 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 146 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:56:32 2 s 1/1
4/4
266 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 162 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:12:31 2 s 1/1
4/4
280 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 169 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:19:31 2 s 1/1
4/4
132 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 95 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:05:32 2 s 1/1
3/3
240 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 149 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:59:32 2 s 1/1
4/4
90 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 74 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:44:32 2 s 1/1
4/4
342 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 200 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:50:32 2 s 1/1
3/3
248 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 153 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:03:31 2 s 1/1
4/4
226 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 142 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 18:52:31 2 s 1/1
4/4
52 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 55 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:25:32 2 s 1/1
4/4
96 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 77 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:47:32 2 s 1/1
4/4
80 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 69 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:39:32 2 s 1/1
4/4
32 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 45 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 17:15:32 3 s 1/1
3/3
252 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 155 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 19:05:31 3 s 1/1
3/3
2 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 30 start at NativeMethodAccessorImpl.java:0 2026/06/17 17:01:58 3 s 1/1
3/3
372 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 215 start at NativeMethodAccessorImpl.java:0 2026/06/17 20:05:32 3 s 1/1
3/3
290 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 174 start at NativeMethodAccessorImpl.java:0 2026/06/17 19:24:32 3 s 1/1
3/3
382 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 220 start at NativeMethodAccessorImpl.java:0 2026/06/17 20:10:32 3 s 1/1
3/3
294 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 176 start at NativeMethodAccessorImpl.java:0 2026/06/17 19:26:32 3 s 1/1
3/3
182 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 120 start at NativeMethodAccessorImpl.java:0 2026/06/17 18:30:32 3 s 1/1
3/3
Page: