Spark Jobs (?)

  • User: spark
  • Total Uptime: 4.4 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 529
Event Timeline

Completed Jobs (529)

Page:
Job Id (Job Group) ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
528 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15981 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:13:32 7 s 1/1
4/4
527 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15979 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:13:32 2 s 1/1
4/4
526 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15980 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:12:32 5 s 1/1
3/3
525 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15978 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:12:32 2 s 1/1
3/3
524 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15979 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:11:32 5 s 1/1
3/3
523 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15977 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:11:32 2 s 1/1
3/3
522 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15976 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:10:32 5 s 1/1
3/3
521 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15978 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:10:32 3 s 1/1
3/3
520 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15975 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:09:32 5 s 1/1
3/3
519 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15977 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:09:32 4 s 1/1
3/3
518 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15974 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:08:32 5 s 1/1
3/3
517 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15976 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:08:32 3 s 1/1
3/3
516 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15973 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:07:32 5 s 1/1
3/3
515 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15975 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:07:31 4 s 1/1
3/3
514 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15974 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:06:32 5 s 1/1
3/3
513 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15972 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:06:31 2 s 1/1
3/3
512 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15971 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:05:32 6 s 1/1
3/3
511 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15973 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:05:32 4 s 1/1
3/3
510 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15972 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:04:32 5 s 1/1
3/3
509 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15970 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:04:32 2 s 1/1
3/3
508 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15969 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:03:32 7 s 1/1
4/4
507 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15971 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:03:32 5 s 1/1
4/4
506 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15970 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:02:32 5 s 1/1
3/3
505 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15968 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:02:31 2 s 1/1
3/3
504 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15967 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:01:32 6 s 1/1
3/3
503 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15969 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:01:32 4 s 1/1
3/3
502 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15966 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 19:00:32 6 s 1/1
3/3
501 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15968 start at NativeMethodAccessorImpl.java:0 2026/06/28 19:00:32 4 s 1/1
3/3
500 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15967 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:59:32 5 s 1/1
3/3
499 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15965 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:59:32 2 s 1/1
3/3
498 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15966 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:58:32 5 s 1/1
3/3
497 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15964 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:58:32 2 s 1/1
3/3
496 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15965 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:57:32 5 s 1/1
3/3
495 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15963 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:57:32 2 s 1/1
3/3
494 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15964 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:56:32 5 s 1/1
3/3
493 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15962 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:56:32 2 s 1/1
3/3
492 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15961 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:55:32 5 s 1/1
3/3
491 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15963 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:55:31 3 s 1/1
3/3
490 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15960 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:54:32 5 s 1/1
3/3
489 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15962 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:54:32 4 s 1/1
3/3
488 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15961 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:53:32 5 s 1/1
3/3
487 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15959 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:53:31 2 s 1/1
3/3
486 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15960 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:52:32 5 s 1/1
3/3
485 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15958 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:52:32 2 s 1/1
3/3
484 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15959 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:51:32 5 s 1/1
3/3
483 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15957 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:51:31 2 s 1/1
3/3
482 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15958 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:50:32 5 s 1/1
3/3
481 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15956 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:50:32 2 s 1/1
3/3
480 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15955 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:49:32 5 s 1/1
3/3
479 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15957 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:49:32 4 s 1/1
3/3
478 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15954 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:48:32 5 s 1/1
3/3
477 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15956 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:48:32 4 s 1/1
3/3
476 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15955 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:47:32 5 s 1/1
3/3
475 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15953 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:47:32 2 s 1/1
3/3
474 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15952 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:46:32 5 s 1/1
3/3
473 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15954 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:46:32 3 s 1/1
3/3
472 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15953 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:45:32 5 s 1/1
3/3
471 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15951 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:45:32 2 s 1/1
3/3
470 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15950 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:44:32 5 s 1/1
3/3
469 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15952 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:44:32 3 s 1/1
3/3
468 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15951 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:43:32 5 s 1/1
3/3
467 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15949 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:43:32 2 s 1/1
3/3
466 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15948 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:42:32 5 s 1/1
3/3
465 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15950 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:42:32 4 s 1/1
3/3
464 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15949 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:41:32 5 s 1/1
3/3
463 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15947 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:41:32 2 s 1/1
3/3
462 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15948 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:40:32 6 s 1/1
3/3
461 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15946 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:40:32 2 s 1/1
3/3
460 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15947 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:39:31 5 s 1/1
3/3
459 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15945 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:39:31 2 s 1/1
3/3
458 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15944 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:38:32 5 s 1/1
3/3
457 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15946 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:38:32 4 s 1/1
3/3
456 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15945 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:37:32 7 s 1/1
4/4
455 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15943 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:37:31 3 s 1/1
4/4
454 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15942 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:36:32 5 s 1/1
3/3
453 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15944 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:36:32 4 s 1/1
3/3
452 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15943 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:35:32 5 s 1/1
3/3
451 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15941 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:35:32 2 s 1/1
3/3
450 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15940 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:34:32 5 s 1/1
3/3
449 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15942 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:34:32 3 s 1/1
3/3
448 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15941 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:33:32 5 s 1/1
3/3
447 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15939 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:33:31 2 s 1/1
3/3
446 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15938 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:32:32 5 s 1/1
3/3
445 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15940 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:32:32 3 s 1/1
3/3
444 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15939 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:31:32 5 s 1/1
3/3
443 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15937 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:31:32 2 s 1/1
3/3
442 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15938 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:30:32 5 s 1/1
3/3
441 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15936 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:30:32 2 s 1/1
3/3
440 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15935 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:29:32 5 s 1/1
3/3
439 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15937 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:29:31 4 s 1/1
3/3
438 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15936 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:28:32 4 s 1/1
3/3
437 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15934 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:28:32 2 s 1/1
3/3
436 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15933 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:27:32 5 s 1/1
3/3
435 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15935 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:27:32 3 s 1/1
3/3
434 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15934 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:26:32 5 s 1/1
3/3
433 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15932 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:26:32 2 s 1/1
3/3
432 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15933 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:25:32 5 s 1/1
3/3
431 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15931 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:25:32 2 s 1/1
3/3
430 (834b49b1-8901-4af8-83eb-bf0f54cf1839) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 834b49b1-8901-4af8-83eb-bf0f54cf1839 batch = 15932 start at NativeMethodAccessorImpl.java:0 2026/06/28 18:24:32 5 s 1/1
3/3
429 (ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = ae9850c0-cf4f-4f59-a9d4-48bbc7ab3412 batch = 15930 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/28 18:24:32 2 s 1/1
3/3
Page: