Spark Jobs (?)

  • User: spark
  • Total Uptime: 6.6 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 792
Event Timeline

Completed Jobs (792)

Job Id (Job Group) Description Submitted Duration ▴ Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
740 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 399 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:09:32 2 s 1/1
3/3
780 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 419 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:29:32 2 s 1/1
3/3
424 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 241 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:31:32 2 s 1/1
3/3
790 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 424 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:34:32 2 s 1/1
3/3
754 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 406 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:16:32 2 s 1/1
3/3
758 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 408 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:18:32 2 s 1/1
3/3
504 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 281 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:11:32 2 s 1/1
3/3
750 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 404 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:14:32 2 s 1/1
3/3
666 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 362 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:32:32 2 s 1/1
3/3
650 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 354 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:24:31 2 s 1/1
3/3
622 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 340 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:10:32 2 s 1/1
3/3
574 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 316 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:46:32 2 s 1/1
3/3
532 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 295 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:25:32 2 s 1/1
3/3
458 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 258 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:48:32 2 s 1/1
3/3
494 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 276 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:06:32 2 s 1/1
3/3
486 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 272 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:02:31 2 s 1/1
3/3
420 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 239 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:29:32 2 s 1/1
3/3
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
636 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 347 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:17:32 2 s 1/1
3/3
638 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 348 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:18:31 2 s 1/1
3/3
554 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 306 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:36:32 2 s 1/1
3/3
478 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 268 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:58:32 2 s 1/1
3/3
676 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 367 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:37:31 2 s 1/1
3/3
628 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 343 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:13:32 2 s 1/1
3/3
770 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 414 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:24:32 2 s 1/1
3/3
604 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 331 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:01:32 2 s 1/1
3/3
778 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 418 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:28:32 2 s 1/1
3/3
772 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 415 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:25:32 2 s 1/1
3/3
608 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 333 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:03:32 2 s 1/1
3/3
684 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 371 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:41:32 2 s 1/1
3/3
550 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 304 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:34:32 2 s 1/1
3/3
418 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 238 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:28:32 2 s 1/1
3/3
394 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 226 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:16: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
660 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 359 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:29:32 2 s 1/1
3/3
514 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 286 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:16:32 2 s 1/1
3/3
464 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 261 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:51:31 2 s 1/1
3/3
388 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 223 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:13: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
724 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 391 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:01:32 2 s 1/1
3/3
530 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 294 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:24:32 2 s 1/1
3/3
396 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 227 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:17: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
720 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 389 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:59:31 2 s 1/1
3/3
688 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 373 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:43:32 2 s 1/1
3/3
686 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 372 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:42:32 2 s 1/1
3/3
434 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 246 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:36: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
712 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 385 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:55:32 2 s 1/1
3/3
664 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 361 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:31:32 2 s 1/1
3/3
590 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 324 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:54:31 2 s 1/1
3/3
484 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 271 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:01:32 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
596 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 327 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:57: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
788 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 423 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:33: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
678 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 368 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:38:31 2 s 1/1
3/3
632 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 345 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:15:32 2 s 1/1
3/3
544 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 301 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:31:31 2 s 1/1
3/3
488 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 273 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:03:31 2 s 1/1
3/3
430 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 244 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:34: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
748 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 403 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:13:32 2 s 1/1
3/3
594 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 326 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:56:32 2 s 1/1
3/3
536 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 297 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:27: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
746 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 402 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:12:31 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
580 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 319 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:49:32 2 s 1/1
3/3
516 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 287 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:17:31 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
690 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 374 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:44:32 2 s 1/1
3/3
520 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 289 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:19:32 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
774 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 416 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:26:32 2 s 1/1
3/3
680 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 369 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:39:32 2 s 1/1
3/3
462 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 260 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:50: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
500 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 279 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:09:31 2 s 1/1
3/3
438 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 248 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:38: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
738 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 398 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 23:08:31 2 s 1/1
3/3
592 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 325 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:55:32 2 s 1/1
3/3
556 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 307 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:37:32 2 s 1/1
3/3
510 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 284 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:14:32 2 s 1/1
3/3
472 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 265 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:55:32 2 s 1/1
3/3
398 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 228 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 20:18:32 2 s 1/1
3/3
644 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 351 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 22:21:31 2 s 1/1
3/3