Spark Jobs (?)

  • User: spark
  • Total Uptime: 4.8 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 582
Event Timeline

Completed Jobs (582)

Page:
Job Id (Job Group) ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
581 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 319 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:49:32 5 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
579 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 318 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:48:32 7 s 1/1
4/4
578 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 318 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:48:32 2 s 1/1
4/4
577 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 317 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:47:32 5 s 1/1
3/3
576 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 317 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:47:32 2 s 1/1
3/3
575 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 316 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:46:32 5 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
573 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 315 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:45:32 5 s 1/1
3/3
572 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 315 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:45:32 2 s 1/1
3/3
571 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 314 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:44:32 5 s 1/1
3/3
570 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 314 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:44:32 3 s 1/1
3/3
569 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 313 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:43:32 5 s 1/1
3/3
568 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 313 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:43:32 3 s 1/1
3/3
567 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 312 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:42:32 7 s 1/1
4/4
566 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 312 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:42:32 2 s 1/1
4/4
565 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 311 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:41:32 5 s 1/1
3/3
564 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 311 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:41:32 3 s 1/1
3/3
563 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 310 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:40:32 4 s 1/1
3/3
562 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 310 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:40:32 3 s 1/1
3/3
561 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 309 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:39:32 5 s 1/1
3/3
560 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 309 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:39:32 2 s 1/1
3/3
559 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 308 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:38:32 5 s 1/1
3/3
558 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 308 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:38:32 3 s 1/1
3/3
557 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 307 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:37:32 5 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
555 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 306 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:36:32 5 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
553 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 305 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:35:32 6 s 1/1
3/3
552 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 305 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:35:32 3 s 1/1
3/3
551 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 304 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:34:32 5 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
549 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 303 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:33:32 5 s 1/1
3/3
548 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 303 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:33:32 2 s 1/1
3/3
547 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 302 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:32:32 5 s 1/1
3/3
546 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 302 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:32:32 4 s 1/1
3/3
545 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 301 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:31:32 5 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
543 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 300 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:30:32 4 s 1/1
3/3
542 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 300 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:30:31 3 s 1/1
3/3
541 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 299 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:29:32 5 s 1/1
3/3
540 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 299 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:29:31 3 s 1/1
3/3
539 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 298 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:28:32 5 s 1/1
3/3
538 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 298 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:28:32 2 s 1/1
3/3
537 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 297 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:27:32 5 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
535 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 296 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:26:32 5 s 1/1
3/3
534 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 296 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:26:31 3 s 1/1
3/3
533 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 295 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:25:32 5 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
531 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 294 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:24:32 5 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
529 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 293 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:23:32 5 s 1/1
3/3
528 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 293 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:23:32 3 s 1/1
3/3
527 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 292 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:22:32 6 s 1/1
3/3
526 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 292 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:22:32 4 s 1/1
3/3
525 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 291 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:21:32 5 s 1/1
3/3
524 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 291 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:21:32 2 s 1/1
3/3
523 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 290 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:20:32 6 s 1/1
3/3
522 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 290 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:20:31 4 s 1/1
3/3
521 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 289 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:19:32 5 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
519 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 288 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:18:32 5 s 1/1
3/3
518 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 288 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:18:32 4 s 1/1
3/3
517 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 287 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:17:32 5 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
515 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 286 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:16:32 5 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
513 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 285 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:15:32 5 s 1/1
3/3
512 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 285 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:15:32 3 s 1/1
3/3
511 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 284 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:14:32 5 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
509 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 283 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:13:32 5 s 1/1
3/3
508 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 283 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:13:32 2 s 1/1
3/3
507 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 282 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:12:32 5 s 1/1
3/3
506 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 282 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:12:32 4 s 1/1
3/3
505 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 281 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:11:32 5 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
503 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 280 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:10:32 5 s 1/1
3/3
502 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 280 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:10:32 3 s 1/1
3/3
501 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 279 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:09:31 5 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
499 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 278 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:08:32 5 s 1/1
3/3
498 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 278 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:08:31 2 s 1/1
3/3
497 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 277 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:07:32 5 s 1/1
3/3
496 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 277 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:07:32 3 s 1/1
3/3
495 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 276 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:06:32 5 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
493 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 275 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:05:32 5 s 1/1
3/3
492 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 275 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:05:32 4 s 1/1
3/3
491 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 274 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:04:32 5 s 1/1
3/3
490 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 274 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:04:31 2 s 1/1
3/3
489 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 273 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:03:31 5 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
487 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 272 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:02:31 5 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
485 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 271 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:01:32 5 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
483 (30fb0157-daed-48e3-8c9c-44cb36eb986e) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 30fb0157-daed-48e3-8c9c-44cb36eb986e batch = 270 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/17 21:00:32 5 s 1/1
3/3
482 (e4e223f8-9cc1-454a-87d1-d3e31030f282) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = e4e223f8-9cc1-454a-87d1-d3e31030f282 batch = 270 start at NativeMethodAccessorImpl.java:0 2026/06/17 21:00:32 4 s 1/1
3/3
Page: