File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -701,13 +701,14 @@ Y_UNIT_TEST_SUITE(KqpQueryService) {
701701 UNIT_ASSERT_UNEQUAL (exMode, EEx::IfExists);
702702 const TString ifNotExistsStatement = exMode == EEx::IfNotExists ? " IF NOT EXISTS" : " " ;
703703 const TString objType = isStore ? " TABLESTORE" : " TABLE" ;
704+ const TString hash = !isStore ? " PARTITION BY HASH(Key) " : " " ;
704705 auto sql = TStringBuilder () << R"(
705706 --!syntax_v1
706707 CREATE )" << objType << " " << ifNotExistsStatement << " `" << objPath << R"( ` (
707708 Key Uint64 NOT NULL,
708709 Value String,
709710 PRIMARY KEY (Key)
710- )
711+ ))" << hash << R"(
711712 WITH (
712713 STORE = COLUMN,
713714 AUTO_PARTITIONING_MIN_PARTITIONS_COUNT = 10
@@ -769,6 +770,7 @@ Y_UNIT_TEST_SUITE(KqpQueryService) {
769770 TTestHelper::TColumnTable testTable;
770771 testTable.SetName (objPath)
771772 .SetPrimaryKey ({" Key" })
773+ .SetSharding ({" Key" })
772774 .SetSchema (schema);
773775 {
774776 TTestHelper::TUpdatesBuilder tableInserter (testTable.GetArrowSchema (schema));
You can’t perform that action at this time.
0 commit comments