Spark Jobs (?)

  • User: spark
  • Total Uptime: 13.7 h
  • Scheduling Mode: FIFO
  • Completed Jobs: 1650, only showing 950
Event Timeline

Completed Jobs (1650, only showing 950)

Job Id (Job Group) ▾ Description Submitted Duration Stages: Succeeded/Total Tasks (for all stages): Succeeded/Total
1649 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5766 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:40:32 4 s 1/1
3/3
1648 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5766 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:40:32 2 s 1/1
3/3
1647 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5765 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:39:32 4 s 1/1
3/3
1646 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5765 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:39:32 2 s 1/1
3/3
1645 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5764 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:38:32 4 s 1/1
3/3
1644 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5764 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:38:31 2 s 1/1
3/3
1643 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5763 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:37:32 5 s 1/1
3/3
1642 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5763 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:37:31 2 s 1/1
3/3
1641 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5762 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:36:32 5 s 1/1
3/3
1640 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5762 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:36:31 2 s 1/1
3/3
1639 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5761 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:35:32 5 s 1/1
3/3
1638 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5761 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:35:32 3 s 1/1
3/3
1637 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5760 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:34:32 5 s 1/1
3/3
1636 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5760 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:34:32 2 s 1/1
3/3
1635 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5759 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:33:32 5 s 1/1
3/3
1634 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5759 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:33:32 2 s 1/1
3/3
1633 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5758 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:32:32 5 s 1/1
3/3
1632 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5758 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:32:32 2 s 1/1
3/3
1631 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5757 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:31:32 5 s 1/1
3/3
1630 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5757 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:31:32 4 s 1/1
3/3
1629 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5756 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:30:32 5 s 1/1
3/3
1628 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5756 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:30:32 2 s 1/1
3/3
1627 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5755 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:29:32 6 s 1/1
3/3
1626 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5755 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:29:32 2 s 1/1
3/3
1625 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5754 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:28:33 5 s 1/1
3/3
1624 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5754 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:28:32 2 s 1/1
3/3
1623 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5753 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:27:32 4 s 1/1
3/3
1622 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5753 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:27:32 3 s 1/1
3/3
1621 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5752 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:26:32 5 s 1/1
3/3
1620 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5752 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:26:31 2 s 1/1
3/3
1619 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5751 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:25:32 4 s 1/1
3/3
1618 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5751 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:25:31 3 s 1/1
3/3
1617 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5750 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:24:33 5 s 1/1
3/3
1616 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5750 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:24:32 4 s 1/1
3/3
1615 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5749 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:23:32 4 s 1/1
3/3
1614 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5749 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:23:32 2 s 1/1
3/3
1613 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5748 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:22:32 5 s 1/1
3/3
1612 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5748 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:22:32 2 s 1/1
3/3
1611 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5747 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:21:32 5 s 1/1
3/3
1610 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5747 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:21:32 2 s 1/1
3/3
1609 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5746 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:20:32 5 s 1/1
3/3
1608 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5746 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:20:31 4 s 1/1
3/3
1607 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5745 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:19:32 5 s 1/1
3/3
1606 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5745 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:19:31 2 s 1/1
3/3
1605 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5744 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:18:32 5 s 1/1
3/3
1604 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5744 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:18:31 4 s 1/1
3/3
1603 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5743 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:17:32 5 s 1/1
3/3
1602 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5743 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:17:31 2 s 1/1
3/3
1601 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5742 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:16:32 5 s 1/1
3/3
1600 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5742 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:16:32 2 s 1/1
3/3
1599 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5741 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:15:32 4 s 1/1
3/3
1598 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5741 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:15:31 3 s 1/1
3/3
1597 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5740 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:14:32 5 s 1/1
3/3
1596 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5740 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:14:32 2 s 1/1
3/3
1595 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5739 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:13:32 5 s 1/1
3/3
1594 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5739 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:13:32 2 s 1/1
3/3
1593 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5738 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:12:32 5 s 1/1
3/3
1592 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5738 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:12:31 3 s 1/1
3/3
1591 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5737 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:11:32 4 s 1/1
3/3
1590 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5737 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:11:31 2 s 1/1
3/3
1589 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5736 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:10:33 5 s 1/1
3/3
1588 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5736 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:10:32 3 s 1/1
3/3
1587 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5735 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:09:32 4 s 1/1
3/3
1586 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5735 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:09:31 2 s 1/1
3/3
1585 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5734 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:08:32 5 s 1/1
3/3
1584 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5734 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:08:31 2 s 1/1
3/3
1583 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5733 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:07:32 5 s 1/1
3/3
1582 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5733 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:07:32 3 s 1/1
3/3
1581 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5732 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:06:32 5 s 1/1
3/3
1580 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5732 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:06:31 2 s 1/1
3/3
1579 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5731 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:05:32 4 s 1/1
3/3
1578 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5731 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:05:32 3 s 1/1
3/3
1577 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5730 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:04:32 5 s 1/1
3/3
1576 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5730 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:04:32 2 s 1/1
3/3
1575 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5729 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:03:32 5 s 1/1
3/3
1574 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5729 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:03:32 2 s 1/1
3/3
1573 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5728 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:02:32 5 s 1/1
3/3
1572 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5728 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:02:32 2 s 1/1
3/3
1571 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5727 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:01:32 4 s 1/1
3/3
1570 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5727 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:01:31 2 s 1/1
3/3
1569 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5726 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 16:00:32 5 s 1/1
3/3
1568 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5726 start at NativeMethodAccessorImpl.java:0 2026/06/21 16:00:32 4 s 1/1
3/3
1567 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5725 start at NativeMethodAccessorImpl.java:0 2026/06/21 15:59:33 5 s 1/1
3/3
1566 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5725 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 15:59:32 2 s 1/1
3/3
1565 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5724 start at NativeMethodAccessorImpl.java:0 2026/06/21 15:58:31 5 s 1/1
3/3
1564 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5724 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 15:58:31 2 s 1/1
3/3
1563 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5723 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 15:57:32 5 s 1/1
3/3
1562 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5723 start at NativeMethodAccessorImpl.java:0 2026/06/21 15:57:32 4 s 1/1
3/3
1561 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5722 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 15:56:32 5 s 1/1
3/3
1560 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5722 start at NativeMethodAccessorImpl.java:0 2026/06/21 15:56:32 3 s 1/1
3/3
1559 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5721 start at NativeMethodAccessorImpl.java:0 2026/06/21 15:55:32 5 s 1/1
3/3
1558 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5721 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 15:55:32 2 s 1/1
3/3
1557 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5720 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 15:54:32 5 s 1/1
3/3
1556 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5720 start at NativeMethodAccessorImpl.java:0 2026/06/21 15:54:32 3 s 1/1
3/3
1555 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5719 start at NativeMethodAccessorImpl.java:0 2026/06/21 15:53:32 5 s 1/1
3/3
1554 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5719 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 15:53:32 2 s 1/1
3/3
1553 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5718 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 15:52:32 5 s 1/1
3/3
1552 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5718 start at NativeMethodAccessorImpl.java:0 2026/06/21 15:52:32 3 s 1/1
3/3
1551 (177ff9f8-c5f4-4957-a098-ae2d1263d4a5) kafka_raw_to_minio id = 6c45c1bd-1ec2-40da-a725-46bc6d56e93f runId = 177ff9f8-c5f4-4957-a098-ae2d1263d4a5 batch = 5717 start at NativeMethodAccessorImpl.java:0 2026/06/21 15:51:32 5 s 1/1
3/3
1550 (2bd06791-4445-4a9e-a8c4-2e6591f26744) kafka_to_clickhouse id = 11427933-bcb1-4d0e-a115-29ac89a0b3f8 runId = 2bd06791-4445-4a9e-a8c4-2e6591f26744 batch = 5717 call at /opt/spark/python/lib/py4j-0.10.9.7-src.zip/py4j/clientserver.py:617 2026/06/21 15:51:32 2 s 1/1
3/3