thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-25 09:02:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix ZooKepper paths in zero_copy_schema_converter.py

Browse Source
This commit is contained in:
Anton Ivashkin 2022-02-17 17:05:49 +03:00
parent dfd8d4067d
commit 243726aa29
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
utils/zero_copy/zero_copy_schema_converter.py
View File

@ -4,6 +4,7 @@ import socket
import uuid import uuid
from kazoo.client import KazooClient from kazoo.client import KazooClient
def parse_args(): def parse_args():
""" """
Parse command-line arguments. Parse command-line arguments.
@ -17,7 +18,7 @@ def parse_args():
parser.add_argument('-u', '--user', default='', help='ZooKeeper ACL user') parser.add_argument('-u', '--user', default='', help='ZooKeeper ACL user')
parser.add_argument('-p', '--password', default='', help='ZooKeeper ACL password') parser.add_argument('-p', '--password', default='', help='ZooKeeper ACL password')
parser.add_argument('-r', '--root', default='/clickhouse', help='ZooKeeper root path for ClickHouse') parser.add_argument('-r', '--root', default='/clickhouse', help='ZooKeeper root path for ClickHouse')
parser.add_argument('-z', '--zcroot', default='zero_copy', help='ZooKeeper node for new zero-copy data') parser.add_argument('-z', '--zcroot', default='clickhouse/zero_copy', help='ZooKeeper node for new zero-copy data')
parser.add_argument('--dryrun', default=False, action='store_true', help='Do not perform any actions') parser.add_argument('--dryrun', default=False, action='store_true', help='Do not perform any actions')
parser.add_argument('--cleanup', default=False, action='store_true', help='Clean old nodes') parser.add_argument('--cleanup', default=False, action='store_true', help='Clean old nodes')
parser.add_argument('-v', '--verbose', action='store_true', default=False, help='Verbose mode') parser.add_argument('-v', '--verbose', action='store_true', default=False, help='Verbose mode')
@ -34,7 +35,7 @@ zc_nodes = ['zero_copy_s3', 'zero_copy_hdfs']
def convert_node(client, args, path, zc_node): def convert_node(client, args, path, zc_node):
base_path = f'{path}/{zc_node}/shared' base_path = f'{path}/{zc_node}/shared'
parts = client.get_children(base_path) parts = client.get_children(base_path)
table_id_path = f'{path}/table_id' table_id_path = f'{path}/table_shared_id'
table_id = '' table_id = ''
if client.exists(table_id_path): if client.exists(table_id_path):
table_id = client.get(table_id_path)[0].decode('UTF-8') table_id = client.get(table_id_path)[0].decode('UTF-8')