Spark Jobs (?)

  • User: spark
  • Total Uptime: 4.9 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 624
Event Timeline

Completed Jobs (624)

Page:
Job Id (Job Group) ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
623 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29380 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:46:03 2 s 1/1
3/3
622 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28781 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:45:32 5 s 1/1
3/3
621 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29379 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:45:32 3 s 1/1
3/3
620 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29378 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:44:32 5 s 1/1
3/3
619 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28780 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:44:32 2 s 1/1
3/3
618 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29377 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:43:32 5 s 1/1
3/3
617 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28779 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:43:32 2 s 1/1
3/3
616 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28778 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:42:32 5 s 1/1
3/3
615 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29376 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:42:32 3 s 1/1
3/3
614 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28777 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:41:32 5 s 1/1
3/3
613 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29375 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:41:32 3 s 1/1
3/3
612 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29374 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:40:32 5 s 1/1
3/3
611 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28776 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:40:32 2 s 1/1
3/3
610 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28775 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:39:32 5 s 1/1
3/3
609 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29373 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:39:32 4 s 1/1
3/3
608 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29372 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:38:32 5 s 1/1
3/3
607 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28774 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:38:32 2 s 1/1
3/3
606 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28773 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:37:32 5 s 1/1
3/3
605 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29371 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:37:32 3 s 1/1
3/3
604 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29370 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:37:08 2 s 1/1
3/3
603 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29369 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:36:32 5 s 1/1
3/3
602 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28772 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:36:32 2 s 1/1
3/3
601 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29368 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:35:32 5 s 1/1
3/3
600 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28771 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:35:31 2 s 1/1
3/3
599 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29367 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:34:32 5 s 1/1
3/3
598 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28770 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:34:32 2 s 1/1
3/3
597 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28769 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:33:32 5 s 1/1
3/3
596 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29366 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:33:32 3 s 1/1
3/3
595 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29365 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:32:32 5 s 1/1
3/3
594 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28768 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:32:32 2 s 1/1
3/3
593 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28767 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:31:32 5 s 1/1
3/3
592 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29364 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:31:32 3 s 1/1
3/3
591 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29363 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:30:33 5 s 1/1
3/3
590 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28766 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:30:32 2 s 1/1
3/3
589 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29362 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:29:32 5 s 1/1
3/3
588 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28765 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:29:32 2 s 1/1
3/3
587 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28764 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:28:32 5 s 1/1
3/3
586 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29361 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:28:32 3 s 1/1
3/3
585 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29360 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:28:08 2 s 1/1
3/3
584 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29359 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:27:32 5 s 1/1
3/3
583 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28763 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:27:32 2 s 1/1
3/3
582 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29358 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:26:32 5 s 1/1
3/3
581 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28762 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:26:32 2 s 1/1
3/3
580 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29357 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:25:32 5 s 1/1
3/3
579 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28761 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:25:32 2 s 1/1
3/3
578 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28760 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:24:32 5 s 1/1
3/3
577 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29356 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:24:32 4 s 1/1
3/3
576 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29355 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:23:32 5 s 1/1
3/3
575 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28759 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:23:32 2 s 1/1
3/3
574 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28758 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:22:32 5 s 1/1
3/3
573 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29354 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:22:32 3 s 1/1
3/3
572 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29353 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:21:32 5 s 1/1
3/3
571 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28757 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:21:32 2 s 1/1
3/3
570 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29352 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:20:32 5 s 1/1
3/3
569 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28756 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:20:32 2 s 1/1
3/3
568 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29351 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:19:32 5 s 1/1
3/3
567 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28755 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:19:32 2 s 1/1
3/3
566 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29350 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:19:04 2 s 1/1
3/3
565 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28754 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:18:32 5 s 1/1
3/3
564 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29349 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:18:32 4 s 1/1
3/3
563 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29348 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:17:32 5 s 1/1
3/3
562 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28753 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:17:32 2 s 1/1
3/3
561 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29347 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:16:32 5 s 1/1
3/3
560 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28752 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:16:32 2 s 1/1
3/3
559 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29346 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:15:32 5 s 1/1
3/3
558 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28751 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:15:32 2 s 1/1
3/3
557 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28750 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:14:32 5 s 1/1
3/3
556 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29345 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:14:32 3 s 1/1
3/3
555 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28749 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:13:32 5 s 1/1
3/3
554 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29344 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:13:32 3 s 1/1
3/3
553 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28748 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:12:32 5 s 1/1
3/3
552 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29343 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:12:32 3 s 1/1
3/3
551 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28747 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:11:31 5 s 1/1
3/3
550 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29342 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:11:31 3 s 1/1
3/3
549 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29341 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:10:32 5 s 1/1
3/3
548 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28746 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:10:32 2 s 1/1
3/3
547 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29340 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:10:09 2 s 1/1
3/3
546 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29339 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:09:32 5 s 1/1
3/3
545 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28745 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:09:31 2 s 1/1
3/3
544 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29338 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:08:32 5 s 1/1
3/3
543 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28744 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:08:32 2 s 1/1
3/3
542 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29337 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:07:33 5 s 1/1
3/3
541 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28743 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:07:33 2 s 1/1
3/3
540 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29336 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:06:32 4 s 1/1
3/3
539 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28742 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:06:31 2 s 1/1
3/3
538 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28741 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:05:32 5 s 1/1
3/3
537 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29335 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:05:32 4 s 1/1
3/3
536 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29334 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:04:32 5 s 1/1
3/3
535 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28740 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:04:32 2 s 1/1
3/3
534 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29333 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:03:32 5 s 1/1
3/3
533 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28739 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:03:31 2 s 1/1
3/3
532 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28738 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:02:32 5 s 1/1
3/3
531 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29332 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:02:32 4 s 1/1
3/3
530 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29331 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:01:32 3 s 1/1
3/3
529 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28737 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:01:32 2 s 1/1
3/3
528 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29330 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:01:10 3 s 1/1
3/3
527 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29329 start at NativeMethodAccessorImpl.java:0 2026/07/07 16:00:32 5 s 1/1
3/3
526 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28736 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 16:00:32 2 s 1/1
3/3
525 (a688d6e7-3b9d-47f9-a8aa-54bd0337eb37) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = a688d6e7-3b9d-47f9-a8aa-54bd0337eb37 batch = 29328 start at NativeMethodAccessorImpl.java:0 2026/07/07 15:59:32 5 s 1/1
3/3
524 (c34cfc89-12da-47e2-85f5-c8f1d73e620b) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = c34cfc89-12da-47e2-85f5-c8f1d73e620b batch = 28735 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/07/07 15:59:32 2 s 1/1
3/3
Page: