Spark Jobs (?)

  • User: spark
  • Total Uptime: 13.8 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 1651, only showing 951
Event Timeline

Completed Jobs (1651, only showing 951)

Job Id (Job Group) ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
1650 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14055 start at NativeMethodAccessorImpl.java:0 2026/06/27 11:05:32 5 s 1/1
3/3
1649 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14054 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 11:05:31 2 s 1/1
3/3
1648 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14054 start at NativeMethodAccessorImpl.java:0 2026/06/27 11:04:32 4 s 1/1
3/3
1647 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14053 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 11:04:31 2 s 1/1
3/3
1646 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14053 start at NativeMethodAccessorImpl.java:0 2026/06/27 11:03:32 5 s 1/1
3/3
1645 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14052 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 11:03:32 2 s 1/1
3/3
1644 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14052 start at NativeMethodAccessorImpl.java:0 2026/06/27 11:02:32 5 s 1/1
3/3
1643 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14051 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 11:02:31 2 s 1/1
3/3
1642 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14051 start at NativeMethodAccessorImpl.java:0 2026/06/27 11:01:32 5 s 1/1
3/3
1641 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14050 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 11:01:32 2 s 1/1
3/3
1640 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14050 start at NativeMethodAccessorImpl.java:0 2026/06/27 11:00:33 5 s 1/1
3/3
1639 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14049 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 11:00:32 2 s 1/1
3/3
1638 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14049 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:59:32 6 s 1/1
3/3
1637 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14048 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:59:32 2 s 1/1
3/3
1636 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14047 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:58:32 5 s 1/1
3/3
1635 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14048 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:58:32 4 s 1/1
3/3
1634 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14047 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:57:32 5 s 1/1
3/3
1633 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14046 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:57:32 2 s 1/1
3/3
1632 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14046 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:56:32 5 s 1/1
3/3
1631 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14045 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:56:32 2 s 1/1
3/3
1630 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14045 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:55:32 4 s 1/1
3/3
1629 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14044 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:55:32 2 s 1/1
3/3
1628 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14044 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:54:32 5 s 1/1
3/3
1627 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14043 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:54:31 2 s 1/1
3/3
1626 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14043 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:53:32 5 s 1/1
3/3
1625 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14042 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:53:31 2 s 1/1
3/3
1624 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14042 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:52:32 5 s 1/1
3/3
1623 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14041 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:52:32 2 s 1/1
3/3
1622 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14041 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:51:32 5 s 1/1
3/3
1621 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14040 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:51:32 2 s 1/1
3/3
1620 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14040 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:50:32 6 s 1/1
3/3
1619 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14039 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:50:32 2 s 1/1
3/3
1618 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14039 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:49:32 5 s 1/1
3/3
1617 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14038 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:49:32 2 s 1/1
3/3
1616 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14038 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:48:32 5 s 1/1
3/3
1615 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14037 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:48:32 2 s 1/1
3/3
1614 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14036 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:47:32 5 s 1/1
3/3
1613 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14037 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:47:32 3 s 1/1
3/3
1612 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14035 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:46:32 5 s 1/1
3/3
1611 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14036 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:46:31 3 s 1/1
3/3
1610 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14035 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:45:32 5 s 1/1
3/3
1609 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14034 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:45:32 2 s 1/1
3/3
1608 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14034 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:44:31 5 s 1/1
3/3
1607 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14033 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:44:31 2 s 1/1
3/3
1606 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14033 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:43:32 5 s 1/1
3/3
1605 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14032 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:43:32 2 s 1/1
3/3
1604 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14032 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:42:32 5 s 1/1
3/3
1603 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14031 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:42:32 2 s 1/1
3/3
1602 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14030 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:41:31 5 s 1/1
3/3
1601 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14031 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:41:31 3 s 1/1
3/3
1600 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14030 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:40:32 5 s 1/1
3/3
1599 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14029 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:40:32 2 s 1/1
3/3
1598 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14029 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:39:32 5 s 1/1
3/3
1597 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14028 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:39:32 2 s 1/1
3/3
1596 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14027 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:38:32 5 s 1/1
3/3
1595 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14028 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:38:32 4 s 1/1
3/3
1594 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14027 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:37:32 5 s 1/1
3/3
1593 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14026 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:37:32 2 s 1/1
3/3
1592 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14026 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:36:32 5 s 1/1
3/3
1591 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14025 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:36:31 2 s 1/1
3/3
1590 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14025 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:35:32 6 s 1/1
3/3
1589 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14024 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:35:32 2 s 1/1
3/3
1588 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14024 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:34:32 5 s 1/1
3/3
1587 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14023 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:34:32 2 s 1/1
3/3
1586 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14023 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:33:32 5 s 1/1
3/3
1585 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14022 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:33:32 2 s 1/1
3/3
1584 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14021 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:32:32 5 s 1/1
3/3
1583 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14022 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:32:32 4 s 1/1
3/3
1582 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14020 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:31:32 5 s 1/1
3/3
1581 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14021 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:31:32 3 s 1/1
3/3
1580 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14020 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:30:32 5 s 1/1
3/3
1579 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14019 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:30:31 2 s 1/1
3/3
1578 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14019 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:29:32 4 s 1/1
3/3
1577 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14018 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:29:32 2 s 1/1
3/3
1576 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14018 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:28:32 5 s 1/1
3/3
1575 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14017 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:28:32 2 s 1/1
3/3
1574 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14017 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:27:32 5 s 1/1
3/3
1573 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14016 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:27:32 2 s 1/1
3/3
1572 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14016 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:26:32 5 s 1/1
3/3
1571 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14015 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:26:32 2 s 1/1
3/3
1570 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14015 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:25:32 5 s 1/1
3/3
1569 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14014 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:25:32 2 s 1/1
3/3
1568 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14014 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:24:32 5 s 1/1
3/3
1567 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14013 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:24:32 2 s 1/1
3/3
1566 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14013 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:23:32 5 s 1/1
3/3
1565 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14012 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:23:32 2 s 1/1
3/3
1564 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14012 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:22:32 5 s 1/1
3/3
1563 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14011 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:22:32 2 s 1/1
3/3
1562 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14011 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:21:32 4 s 1/1
3/3
1561 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14010 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:21:32 2 s 1/1
3/3
1560 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14010 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:20:32 5 s 1/1
3/3
1559 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14009 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:20:32 2 s 1/1
3/3
1558 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14008 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:19:32 5 s 1/1
3/3
1557 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14009 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:19:32 3 s 1/1
3/3
1556 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14008 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:18:32 5 s 1/1
3/3
1555 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14007 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:18:32 2 s 1/1
3/3
1554 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14007 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:17:32 5 s 1/1
3/3
1553 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14006 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:17:32 2 s 1/1
3/3
1552 (da7db828-95a1-45a5-b0f8-6881440c4ddd) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = da7db828-95a1-45a5-b0f8-6881440c4ddd batch = 14005 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/27 10:16:32 5 s 1/1
3/3
1551 (dfea9fd6-ec85-4cdf-853d-dfa79705db20) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = dfea9fd6-ec85-4cdf-853d-dfa79705db20 batch = 14006 start at NativeMethodAccessorImpl.java:0 2026/06/27 10:16:32 3 s 1/1
3/3