Spark Jobs (?)

  • User: spark
  • Total Uptime: 5.3 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 644
Event Timeline

Completed Jobs (644)

Page:
Job Id (Job Group) ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
643 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4037 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:50:32 4 s 1/1
3/3
642 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4037 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:50:31 2 s 1/1
3/3
641 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4036 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:49:32 5 s 1/1
3/3
640 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4036 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:49:32 2 s 1/1
3/3
639 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4035 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:48:32 5 s 1/1
3/3
638 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4035 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:48:31 2 s 1/1
3/3
637 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4034 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:47:32 5 s 1/1
3/3
636 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4034 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:47:32 3 s 1/1
3/3
635 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4033 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:46:32 5 s 1/1
3/3
634 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4033 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:46:32 2 s 1/1
3/3
633 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4032 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:45:32 5 s 1/1
3/3
632 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4032 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:45:32 2 s 1/1
3/3
631 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4031 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:44:32 5 s 1/1
3/3
630 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4031 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:44:31 2 s 1/1
3/3
629 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4030 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:43:32 5 s 1/1
3/3
628 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4030 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:43:32 2 s 1/1
3/3
627 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4029 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:42:32 6 s 1/1
3/3
626 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4029 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:42:32 4 s 1/1
3/3
625 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4028 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:41:32 4 s 1/1
3/3
624 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4028 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:41:32 2 s 1/1
3/3
623 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4027 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:40:32 5 s 1/1
3/3
622 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4027 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:40:32 2 s 1/1
3/3
621 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4026 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:39:32 5 s 1/1
3/3
620 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4026 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:39:32 3 s 1/1
3/3
619 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4025 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:38:32 5 s 1/1
3/3
618 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4025 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:38:32 2 s 1/1
3/3
617 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4024 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:37:32 5 s 1/1
3/3
616 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4024 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:37:32 2 s 1/1
3/3
615 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4023 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:36:32 5 s 1/1
3/3
614 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4023 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:36:32 2 s 1/1
3/3
613 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4022 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:35:32 5 s 1/1
3/3
612 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4022 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:35:32 4 s 1/1
3/3
611 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4021 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:34:32 5 s 1/1
3/3
610 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4021 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:34:32 4 s 1/1
3/3
609 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4020 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:33:32 5 s 1/1
3/3
608 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4020 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:33:31 2 s 1/1
3/3
607 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4019 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:32:33 5 s 1/1
3/3
606 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4019 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:32:32 4 s 1/1
3/3
605 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4018 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:31:32 4 s 1/1
3/3
604 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4018 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:31:32 2 s 1/1
3/3
603 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4017 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:30:32 5 s 1/1
3/3
602 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4017 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:30:32 3 s 1/1
3/3
601 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4016 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:29:32 5 s 1/1
3/3
600 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4016 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:29:32 2 s 1/1
3/3
599 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4015 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:28:32 7 s 1/1
4/4
598 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4015 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:28:32 2 s 1/1
4/4
597 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4014 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:27:32 5 s 1/1
3/3
596 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4014 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:27:32 2 s 1/1
3/3
595 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4013 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:26:32 5 s 1/1
3/3
594 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4013 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:26:32 2 s 1/1
3/3
593 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4012 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:25:32 5 s 1/1
3/3
592 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4012 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:25:32 3 s 1/1
3/3
591 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4011 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:24:33 5 s 1/1
3/3
590 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4011 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:24:32 2 s 1/1
3/3
589 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4010 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:23:32 5 s 1/1
3/3
588 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4010 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:23:31 4 s 1/1
3/3
587 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4009 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:22:32 5 s 1/1
3/3
586 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4009 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:22:32 2 s 1/1
3/3
585 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4008 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:21:32 6 s 1/1
3/3
584 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4008 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:21:32 3 s 1/1
3/3
583 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4007 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:20:32 5 s 1/1
3/3
582 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4007 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:20:32 2 s 1/1
3/3
581 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4006 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:19:32 4 s 1/1
3/3
580 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4006 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:19:32 3 s 1/1
3/3
579 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4005 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:18:32 5 s 1/1
3/3
578 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4005 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:18:31 4 s 1/1
3/3
577 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4004 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:17:32 5 s 1/1
3/3
576 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4004 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:17:31 3 s 1/1
3/3
575 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4003 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:16:32 5 s 1/1
3/3
574 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4003 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:16:32 2 s 1/1
3/3
573 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4002 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:15:32 4 s 1/1
3/3
572 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4002 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:15:32 2 s 1/1
3/3
571 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4001 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:14:32 5 s 1/1
3/3
570 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4001 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:14:32 2 s 1/1
3/3
569 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 4000 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:13:32 5 s 1/1
3/3
568 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 4000 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:13:32 2 s 1/1
3/3
567 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 3999 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:12:32 5 s 1/1
3/3
566 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 3999 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:12:31 2 s 1/1
3/3
565 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 3998 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:11:32 5 s 1/1
3/3
564 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 3998 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:11:31 2 s 1/1
3/3
563 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 3997 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:10:32 5 s 1/1
3/3
562 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 3997 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:10:31 2 s 1/1
3/3
561 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 3996 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:09:32 5 s 1/1
3/3
560 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 3996 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:09:32 2 s 1/1
3/3
559 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 3995 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:08:32 7 s 1/1
4/4
558 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 3995 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:08:32 5 s 1/1
4/4
557 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 3994 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:07:32 5 s 1/1
3/3
556 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 3994 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:07:32 2 s 1/1
3/3
555 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 3993 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:06:31 5 s 1/1
3/3
554 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 3993 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:06:31 2 s 1/1
3/3
553 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 3992 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:05:32 5 s 1/1
3/3
552 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 3992 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:05:31 2 s 1/1
3/3
551 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 3991 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:04:31 6 s 1/1
3/3
550 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 3991 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:04:31 3 s 1/1
3/3
549 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 3990 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:03:32 6 s 1/1
4/4
548 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 3990 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:03:32 2 s 1/1
4/4
547 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 3989 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:02:32 5 s 1/1
3/3
546 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 3989 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:02:32 4 s 1/1
3/3
545 (d6eb5518-4a24-47a1-8f48-519243b5d278) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = d6eb5518-4a24-47a1-8f48-519243b5d278 batch = 3988 start at NativeMethodAccessorImpl.java:0 2026/06/20 11:01:32 5 s 1/1
3/3
544 (3fdfd0a3-4fd5-44a7-8494-3baaafd13d78) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 3fdfd0a3-4fd5-44a7-8494-3baaafd13d78 batch = 3988 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/20 11:01:32 2 s 1/1
3/3
Page: