Skip to content

Commit fc4a10e

Browse files
committed
commented column stop
1 parent e52a67e commit fc4a10e

File tree

1 file changed

+21
-21
lines changed

1 file changed

+21
-21
lines changed

ydb/tests/olap/restarts/test_nodes_restart.py

Lines changed: 21 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -75,30 +75,32 @@ def create_table(self, thread_id: int):
7575
self.ydb_client.query(f"""
7676
--!syntax_v1
7777
CREATE TABLE `{tableName}` (
78-
`Key` Uint64 NOT NULL,
79-
`Value1` String,
80-
PRIMARY KEY (`Key`)
81-
)
82-
TABLESTORE `TableStore`;
78+
Key Uint64 NOT NULL,
79+
Value String,
80+
PRIMARY KEY (Key)
81+
) WITH (
82+
STORE = COLUMN,
83+
AUTO_PARTITIONING_MIN_PARTITIONS_COUNT = 5
84+
);
8385
""")
8486
self.ydb_client.query(f"""
8587
ALTER TABLE `{tableName}`
86-
ADD COLUMN `Value2` String;
87-
""")
88+
ADD COLUMN `Value2` String;
89+
""")
8890

8991
def test(self):
90-
self.ydb_client.query("""
91-
--!syntax_v1
92-
CREATE TABLESTORE `TableStore` (
93-
Key Uint64 NOT NULL,
94-
Value1 String,
95-
PRIMARY KEY (Key)
96-
)
97-
WITH (
98-
STORE = COLUMN,
99-
AUTO_PARTITIONING_MIN_PARTITIONS_COUNT = 10
100-
);
101-
""")
92+
# self.ydb_client.query("""
93+
# --!syntax_v1
94+
# CREATE TABLESTORE `TableStore` (
95+
# Key Uint64 NOT NULL,
96+
# Value1 String,
97+
# PRIMARY KEY (Key)
98+
# )
99+
# WITH (
100+
# STORE = COLUMN,
101+
# AUTO_PARTITIONING_MIN_PARTITIONS_COUNT = 10
102+
# );
103+
# """)
102104

103105
threads: list[TestThread] = []
104106
# threads.append(TestThread(target=ydb_workload.bulk_upsert, args=[wait_time, 10, 1000, True]))
@@ -122,5 +124,3 @@ def test(self):
122124

123125
for thread in threads:
124126
thread.join()
125-
126-

0 commit comments

Comments
 (0)