This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.2-lts by this push:
new a978148080 [branch-1.2] remove topn and cold hot data test case
a978148080 is described below
commit a9781480809cd8d5998e0c446efd7ed332f79504
Author: morningman <[email protected]>
AuthorDate: Fri Feb 10 20:10:29 2023 +0800
[branch-1.2] remove topn and cold hot data test case
---
.../scalar_types/sql/infomation_schema.out | 21 --
.../cold_heat_separation/policy/alter.groovy | 182 -----------
.../cold_heat_separation/policy/create.groovy | 334 ---------------------
.../suites/cold_heat_separation/policy/drop.groovy | 99 ------
.../suites/cold_heat_separation/policy/show.groovy | 66 ----
.../use_policy/alter_table_add_policy.groovy | 132 --------
.../create_table_use_partition_policy.groovy | 156 ----------
.../use_policy/create_table_use_policy.groovy | 104 -------
.../use_policy/modify_partition_add_policy.groovy | 118 --------
.../use_policy/use_default_storage_policy.groovy | 88 ------
.../scalar_types/sql/infomation_schema.sql | 1 -
11 files changed, 1301 deletions(-)
diff --git
a/regression-test/data/datatype_p0/scalar_types/sql/infomation_schema.out
b/regression-test/data/datatype_p0/scalar_types/sql/infomation_schema.out
deleted file mode 100644
index faca55aa1a..0000000000
--- a/regression-test/data/datatype_p0/scalar_types/sql/infomation_schema.out
+++ /dev/null
@@ -1,21 +0,0 @@
--- This file is automatically generated. You should know what you did if you
want to edit this
--- !infomation_schema --
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup k1 1 \N YES bigint \N \N
19 0 \N \N \N bigint(20) DUP
19 0 \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_bool 2 \N YES tinyint \N \N
\N 0 \N \N \N tinyint(1)
\N 0 \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_tinyint 3 \N YES tinyint \N
\N 3 0 \N \N \N tinyint(4)
3 0 \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_smallint 4 \N YES smallint
\N \N 5 0 \N \N \N smallint(6)
5 0 \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_int 5 \N YES int \N \N
10 0 \N \N \N int(11)
10 0 \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_bigint 6 \N YES bigint \N
\N 19 0 \N \N \N bigint(20)
19 0 \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_largeint 7 \N YES bigint unsigned
\N \N 39 \N \N \N \N largeint
39 \N \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_float 8 \N YES float \N \N
7 7 \N \N \N float
7 7 \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_double 9 \N YES double \N
\N 15 15 \N \N \N double
15 15 \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_decimal 10 \N YES decimal \N
\N 20 3 \N \N \N decimal(20,3)
20 3 \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_decimalv3 11 \N YES decimal \N
\N 20 3 \N \N \N decimalv3(20, 3)
20 3 \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_date 12 \N YES date \N \N
\N \N \N \N \N date
\N \N \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_datetime 13 \N YES datetime
\N \N \N \N \N \N \N datetime
\N \N \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_datev2 14 \N YES date \N
\N \N \N \N \N \N datev2
\N \N \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_datetimev2 15 \N YES datetime
\N \N 18 0 \N \N \N datetimev2(0)
\N 0 \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_char 16 \N YES char 15 60
\N \N \N \N \N char(15)
15 \N \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_varchar 17 \N YES varchar 100
400 \N \N \N \N \N varchar(100)
100 \N \N \N
-internal regression_test_datatype_p0_scalar_types
tbl_scalar_types_dup c_string 18 \N YES varchar
2147483643 -20 \N \N \N \N \N string
2147483643 \N \N \N
-
diff --git a/regression-test/suites/cold_heat_separation/policy/alter.groovy
b/regression-test/suites/cold_heat_separation/policy/alter.groovy
deleted file mode 100644
index 07166df0d3..0000000000
--- a/regression-test/suites/cold_heat_separation/policy/alter.groovy
+++ /dev/null
@@ -1,182 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-suite("alter_policy") {
- sql """ADMIN SET FRONTEND CONFIG ("enable_storage_policy" = "true");"""
-
- def has_resouce_policy_alter = sql """
- SHOW RESOURCES WHERE NAME = "has_resouce_policy_alter";
- """
- if(has_resouce_policy_alter.size() == 0) {
- sql """
- CREATE RESOURCE "has_resouce_policy_alter"
- PROPERTIES(
- "type"="s3",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_REGION" = "bj",
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_MAX_CONNECTIONS" = "50",
- "AWS_REQUEST_TIMEOUT_MS" = "3000",
- "AWS_CONNECTION_TIMEOUT_MS" = "1000",
- "AWS_BUCKET" = "test-bucket"
- );
- """
-
- sql """
- CREATE STORAGE POLICY has_resouce_policy_alter_policy
- PROPERTIES(
- "storage_resource" = "has_resouce_policy_alter",
- "cooldown_ttl" = "1d"
- )
- """
- }
-
- // support
- def alter_result_succ_1 = try_sql """
- ALTER RESOURCE "has_resouce_policy_alter"
PROPERTIES("AWS_MAX_CONNECTIONS" = "1111");
- """
-
- def alter_result_succ_2 = try_sql """
- ALTER RESOURCE "has_resouce_policy_alter"
PROPERTIES("AWS_CONNECTION_TIMEOUT_MS" = "2222");
- """
-
- def alter_result_succ_5 = try_sql """
- ALTER RESOURCE "has_resouce_policy_alter" PROPERTIES("AWS_SECRET_KEY"
= "5555");
- """
-
- def alter_result_succ_6 = try_sql """
- ALTER RESOURCE "has_resouce_policy_alter" PROPERTIES("AWS_ACCESS_KEY"
= "6666");
- """
-
- def alter_result_succ_7 = try_sql """
- ALTER RESOURCE "has_resouce_policy_alter"
PROPERTIES("AWS_REQUEST_TIMEOUT_MS" = "7777");
- """
-
- // errCode = 2, detailMessage = current not support modify property :
AWS_REGION
- def alter_result_fail_1 = try_sql """
- ALTER RESOURCE "has_resouce_policy_alter" PROPERTIES("AWS_REGION" =
"8888");
- """
-
- // errCode = 2, detailMessage = current not support modify property :
AWS_BUCKET
- def alter_result_fail_2 = try_sql """
- ALTER RESOURCE "has_resouce_policy_alter" PROPERTIES("AWS_BUCKET" =
"9999");
- """
-
- // errCode = 2, detailMessage = current not support modify property :
AWS_ROOT_PATH
- def alter_result_fail_3 = try_sql """
- ALTER RESOURCE "has_resouce_policy_alter" PROPERTIES("AWS_ROOT_PATH" =
"10101010");
- """
-
- // errCode = 2, detailMessage = current not support modify property :
AWS_ENDPOINT
- def alter_result_fail_4 = try_sql """
- ALTER RESOURCE "has_resouce_policy_alter" PROPERTIES("AWS_ENDPOINT" =
"11111111");
- """
-
- def show_alter_result = order_sql """
- SHOW RESOURCES WHERE NAME = "has_resouce_policy_alter";
- """
-
- // [[has_resouce_policy_alter, s3, AWS_ACCESS_KEY, 6666],
- // [has_resouce_policy_alter, s3, AWS_BUCKET, test-bucket],
- // [has_resouce_policy_alter, s3, AWS_CONNECTION_TIMEOUT_MS, 2222],
- // [has_resouce_policy_alter, s3, AWS_ENDPOINT, http://bj.s3.comaaaa],
- // [has_resouce_policy_alter, s3, AWS_MAX_CONNECTIONS, 1111],
- // [has_resouce_policy_alter, s3, AWS_REGION, bj],
- // [has_resouce_policy_alter, s3, AWS_REQUEST_TIMEOUT_MS, 7777],
- // [has_resouce_policy_alter, s3, AWS_ROOT_PATH, path/to/rootaaaa],
- // [has_resouce_policy_alter, s3, AWS_SECRET_KEY, ******],
- // [has_resouce_policy_alter, s3, type, s3]]
- // AWS_ACCESS_KEY
- assertEquals(show_alter_result[0][3], "6666")
- // AWS_BUCKET
- assertEquals(show_alter_result[1][3], "test-bucket")
- // AWS_CONNECTION_TIMEOUT_MS
- assertEquals(show_alter_result[2][3], "2222")
- // AWS_ENDPOINT
- assertEquals(show_alter_result[3][3], "http://bj.s3.comaaaa";)
- // AWS_MAX_CONNECTIONS
- assertEquals(show_alter_result[4][3], "1111")
- // AWS_REGION
- assertEquals(show_alter_result[5][3], "bj")
- // AWS_REQUEST_TIMEOUT_MS
- assertEquals(show_alter_result[6][3], "7777")
- // s3_rootpath
- assertEquals(show_alter_result[7][3], "path/to/rootaaaa")
- // AWS_SECRET_KEY
- assertEquals(show_alter_result[8][3], "******")
- // type
- assertEquals(show_alter_result[9][3], "s3")
-
- def storage_exist = { name ->
- def show_storage_policy = sql """
- SHOW STORAGE POLICY;
- """
- for(iter in show_storage_policy){
- if(name == iter[0]){
- return true;
- }
- }
- return false;
- }
-
-
- if (!storage_exist.call("has_test_policy_to_alter")) {
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY has_test_policy_to_alter
- PROPERTIES(
- "storage_resource" = "has_resouce_policy_alter",
- "cooldown_ttl" = "10086"
- );
- """
- assertEquals(storage_exist.call("has_test_policy_to_alter"), true)
- }
-
- // OK
- def alter_result_sql_succ_ttl = try_sql """
- ALTER STORAGE POLICY has_test_policy_to_alter
PROPERTIES("cooldown_ttl" = "10000");
- """
-
- // OK
- def alter_result_sql_succ_datetime = try_sql """
- ALTER STORAGE POLICY has_test_policy_to_alter
PROPERTIES("cooldown_datetime" = "2023-06-08 00:00:00");
- """
-
- // FAILED
- def alter_result_sql_failed_storage_resource = try_sql """
- ALTER STORAGE POLICY has_test_policy_to_alter
PROPERTIES("storage_resource" = "has_resouce_policy_alter");
- """
- // errCode = 2, detailMessage = not support change storage policy's
storage resource, you can change s3 properties by alter resource
- assertEquals(alter_result_sql_failed_storage_resource, null)
-
- if (!storage_exist.call("has_test_policy_to_alter_1")) {
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY has_test_policy_to_alter_1
- PROPERTIES(
- "storage_resource" = "has_resouce_policy_alter",
- "cooldown_datetime" = "2025-06-08 00:00:00"
- );
- """
- assertEquals(storage_exist.call("has_test_policy_to_alter_1"), true)
- }
-
- // go to check be、fe log about notify alter.
- def alter_result_succ_again = try_sql """
- ALTER RESOURCE "has_resouce_policy_alter" PROPERTIES("AWS_ACCESS_KEY"
= "akakak");
- """
-}
diff --git a/regression-test/suites/cold_heat_separation/policy/create.groovy
b/regression-test/suites/cold_heat_separation/policy/create.groovy
deleted file mode 100644
index c217486ad1..0000000000
--- a/regression-test/suites/cold_heat_separation/policy/create.groovy
+++ /dev/null
@@ -1,334 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-suite("create_policy") {
- sql """ADMIN SET FRONTEND CONFIG ("enable_storage_policy" = "true");"""
-
- def has_created_1 = sql """
- SHOW RESOURCES WHERE NAME = "crete_policy_1";
- """
-
- // doesn't have name crete_policy_1 resources
- // normal
- if(has_created_1.size() == 0) {
- sql """
- CREATE RESOURCE "crete_policy_1"
- PROPERTIES(
- "type" = "s3",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_REGION" = "bj",
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_MAX_CONNECTIONS" = "50",
- "AWS_REQUEST_TIMEOUT_MS" = "3000",
- "AWS_CONNECTION_TIMEOUT_MS" = "1000",
- "AWS_BUCKET" = "test-bucket"
- );
- """
-
- def create_sucess = sql """
- SHOW RESOURCES WHERE NAME = "crete_policy_1";
- """
- assertEquals(create_sucess.size(), 10)
-
- def failed_cannot_create_duplicate_name_resources = try_sql """
- CREATE RESOURCE "crete_policy_1"
- PROPERTIES(
- "type" = "s3",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaab";,
- "AWS_REGION" = "bjc",
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_MAX_CONNECTIONS" = "50",
- "AWS_REQUEST_TIMEOUT_MS" = "3000",
- "AWS_CONNECTION_TIMEOUT_MS" = "1000",
- "AWS_BUCKET" = "test-bucket"
- );
- """
-
- // errCode = 2, detailMessage = Resource(crete_policy_1) already exist
- assertEquals(failed_cannot_create_duplicate_name_resources, null)
- }
-
- // can't create success, due to missing required items
- def has_created_2 = sql """
- SHOW RESOURCES WHERE NAME = "crete_policy_2";
- """
- if (has_created_2.size() == 0) {
- def failed_create_1 = try_sql """
- CREATE RESOURCE "crete_policy_2"
- PROPERTIES(
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_REGION" = "bj",
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_MAX_CONNECTIONS" = "50",
- "AWS_REQUEST_TIMEOUT_MS" = "3000",
- "AWS_CONNECTION_TIMEOUT_MS" = "1000",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- // errCode = 2, detailMessage = Resource type can't be null
- assertEquals(failed_create_1, null)
- }
-
- if (has_created_2.size() == 0) {
- def failed_create_2 = try_sql """
- CREATE RESOURCE "crete_policy_2"
- PROPERTIES(
- "type" = "s3",
- "AWS_REGION" = "bj",
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_MAX_CONNECTIONS" = "50",
- "AWS_REQUEST_TIMEOUT_MS" = "3000",
- "AWS_CONNECTION_TIMEOUT_MS" = "1000",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- // errCode = 2, detailMessage = Missing [AWS_ENDPOINT] in properties.
- assertEquals(failed_create_2, null)
- }
-
- if (has_created_2.size() == 0) {
- def failed_create_2 = try_sql """
- CREATE RESOURCE "crete_policy_2"
- PROPERTIES(
- "type" = "s3",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_MAX_CONNECTIONS" = "50",
- "AWS_REQUEST_TIMEOUT_MS" = "3000",
- "AWS_CONNECTION_TIMEOUT_MS" = "1000",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- // errCode = 2, detailMessage = Missing [AWS_REGION] in properties.
- assertEquals(failed_create_2, null)
- }
-
- if (has_created_2.size() == 0) {
- def failed_create_2 = try_sql """
- CREATE RESOURCE "crete_policy_2"
- PROPERTIES(
- "type"="s3",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_REGION" = "bj",
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_MAX_CONNECTIONS" = "50",
- "AWS_REQUEST_TIMEOUT_MS" = "3000",
- "AWS_CONNECTION_TIMEOUT_MS" = "1000",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- // errCode = 2, detailMessage = Missing [AWS_ACCESS_KEY] in properties.
- assertEquals(failed_create_2, null)
- }
-
- if (has_created_2.size() == 0) {
- def failed_create_2 = try_sql """
- CREATE RESOURCE "crete_policy_2"
- PROPERTIES(
- "type"="s3",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_REGION" = "bj",
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_MAX_CONNECTIONS" = "50",
- "AWS_REQUEST_TIMEOUT_MS" = "3000",
- "AWS_CONNECTION_TIMEOUT_MS" = "1000",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- // errCode = 2, detailMessage = Missing [AWS_SECRET_KEY] in properties.
- assertEquals(failed_create_2, null)
- }
-
- // can create success, because there are default values
- def has_created_3 = sql """
- SHOW RESOURCES WHERE NAME = "crete_policy_3";
- """
- if (has_created_3.size() == 0) {
- def succ_create_3 = try_sql """
- CREATE RESOURCE "crete_policy_3"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- // "AWS_MAX_CONNECTIONS" = "50", "AWS_REQUEST_TIMEOUT_MS" =
"3000","AWS_CONNECTION_TIMEOUT_MS" = "1000"
- assertEquals(succ_create_3.size(), 1)
- }
-
- // create policy
-
-
- def storage_exist = { name ->
- def show_storage_policy = sql """
- SHOW STORAGE POLICY;
- """
- for(iter in show_storage_policy){
- if(name == iter[0]){
- return true;
- }
- }
- return false;
- }
-
- if (!storage_exist.call("testPolicy_10")) {
- def create_s3_resource = try_sql """
- CREATE RESOURCE "testPolicy_10_resource"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY testPolicy_10
- PROPERTIES(
- "storage_resource" = "testPolicy_10_resource",
- "cooldown_datetime" = "2022-06-08 00:00:00"
- );
- """
- assertEquals(storage_exist.call("testPolicy_10"), true)
- }
-
- if (!storage_exist.call("testPolicy_11")) {
- def create_s3_resource = try_sql """
- CREATE RESOURCE "testPolicy_11_resource"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY testPolicy_11
- PROPERTIES(
- "storage_resource" = "testPolicy_11_resource",
- "cooldown_ttl" = "10086"
- );
- """
- assertEquals(storage_exist.call("testPolicy_11"), true)
- }
-
- if (!storage_exist.call("testPolicy_12")) {
- def create_s3_resource = try_sql """
- CREATE RESOURCE "testPolicy_12_resource"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY testPolicy_12
- PROPERTIES(
- "storage_resource" = "testPolicy_12_resource",
- "cooldown_ttl" = "10086",
- "cooldown_datetime" = "2022-06-08 00:00:00"
- );
- """
- // errCode = 2, detailMessage = cooldown_datetime and cooldown_ttl
can't be set together.
- assertEquals(storage_exist.call("testPolicy_12"), false)
- }
-
- if (!storage_exist.call("testPolicy_13")) {
- def create_s3_resource = try_sql """
- CREATE RESOURCE "testPolicy_13_resource"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY testPolicy_13
- PROPERTIES(
- "storage_resource" = "testPolicy_13_resource",
- "cooldown_ttl" = "-10086"
- );
- """
- // errCode = 2, detailMessage = cooldown_ttl must >= 0.
- assertEquals(storage_exist.call("testPolicy_13"), false)
- }
-
- if (!storage_exist.call("testPolicy_14")) {
- def create_s3_resource = try_sql """
- CREATE RESOURCE "testPolicy_14_resource"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY testPolicy_14
- PROPERTIES(
- "storage_resource" = "testPolicy_14_resource",
- "cooldown_datetime" = "2022-06-08"
- );
- """
- // errCode = 2, detailMessage = cooldown_datetime format error:
2022-06-08
- assertEquals(storage_exist.call("testPolicy_14"), false)
- }
-
- if (!storage_exist.call("testPolicy_15")) {
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY testPolicy_15
- PROPERTIES(
- "storage_resource" = "s3_resource_not_exist",
- "cooldown_datetime" = "2022-06-08 00:00:00"
- );
- """
- // errCode = 2, detailMessage = storage resource doesn't exist:
s3_resource_not_exist
- assertEquals(storage_exist.call("testPolicy_15"), false)
- }
-}
diff --git a/regression-test/suites/cold_heat_separation/policy/drop.groovy
b/regression-test/suites/cold_heat_separation/policy/drop.groovy
deleted file mode 100644
index 57976f8f08..0000000000
--- a/regression-test/suites/cold_heat_separation/policy/drop.groovy
+++ /dev/null
@@ -1,99 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-suite("drop_policy") {
- sql """ADMIN SET FRONTEND CONFIG ("enable_storage_policy" = "true");"""
-
- def storage_exist = { name ->
- def show_storage_policy = sql """
- SHOW STORAGE POLICY;
- """
- for(iter in show_storage_policy){
- if(name == iter[0]){
- return true;
- }
- }
- return false;
- }
-
- if (!storage_exist.call("drop_policy_test")) {
- def has_resouce_policy_drop = sql """
- SHOW RESOURCES WHERE NAME = "resouce_policy_drop";
- """
- if(has_resouce_policy_drop.size() == 0) {
- sql """
- CREATE RESOURCE "resouce_policy_drop"
- PROPERTIES(
- "type"="s3",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_REGION" = "bj",
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_MAX_CONNECTIONS" = "50",
- "AWS_REQUEST_TIMEOUT_MS" = "3000",
- "AWS_CONNECTION_TIMEOUT_MS" = "1000",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- }
-
- def drop_result = try_sql """
- DROP RESOURCE 'resouce_policy_drop'
- """
- // can drop, no policy use
- assertEquals(drop_result.size(), 1)
-
- sql """
- CREATE RESOURCE "resouce_policy_drop"
- PROPERTIES(
- "type"="s3",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_REGION" = "bj",
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_MAX_CONNECTIONS" = "50",
- "AWS_REQUEST_TIMEOUT_MS" = "3000",
- "AWS_CONNECTION_TIMEOUT_MS" = "1000",
- "AWS_BUCKET" = "test-bucket"
- );
- """
-
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY drop_policy_test
- PROPERTIES(
- "storage_resource" = "resouce_policy_drop",
- "cooldown_datetime" = "2022-06-08 00:00:00"
- );
- """
- assertEquals(storage_exist.call("drop_policy_test"), true)
-
- def drop_s3_resource_result_1 = try_sql """
- DROP RESOURCE 'resouce_policy_drop'
- """
- // errCode = 2, detailMessage = S3 resource used by policy, can't drop
it.
- assertEquals(drop_s3_resource_result_1, null)
-
- def drop_policy_ret = try_sql """
- DROP STORAGE POLICY drop_policy_test
- """
- // errCode = 2, detailMessage = current not support drop storage
policy.
- assertEquals(drop_policy_ret, null)
- }
-
-}
diff --git a/regression-test/suites/cold_heat_separation/policy/show.groovy
b/regression-test/suites/cold_heat_separation/policy/show.groovy
deleted file mode 100644
index 06a4340372..0000000000
--- a/regression-test/suites/cold_heat_separation/policy/show.groovy
+++ /dev/null
@@ -1,66 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-import groovy.json.JsonSlurper
-
-suite("show_policy") {
- sql """ADMIN SET FRONTEND CONFIG ("enable_storage_policy" = "true");"""
-
- def storage_exist = { name ->
- def show_storage_policy = sql """
- SHOW STORAGE POLICY;
- """
- for(iter in show_storage_policy){
- if(name == iter[0]){
- return true;
- }
- }
- return false;
- }
-
- if (!storage_exist.call("showPolicy_1_policy")){
- def create_s3_resource = try_sql """
- CREATE RESOURCE "showPolicy_1_resource"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY showPolicy_1_policy
- PROPERTIES(
- "storage_resource" = "showPolicy_1_resource",
- "cooldown_datetime" = "2022-06-08 00:00:00"
- );
- """
- }
- def show_result = sql """
- SHOW STORAGE POLICY;
- """
-
- def jsonSlurper = new JsonSlurper()
- if (show_result.size != 0){
- def json_ret = jsonSlurper.parseText(show_result[0][5])
- assertEquals(json_ret["AWS_SECRET_KEY"], "******")
- }
- assertEquals(storage_exist.call("showPolicy_1_policy"), true)
-}
diff --git
a/regression-test/suites/cold_heat_separation/use_policy/alter_table_add_policy.groovy
b/regression-test/suites/cold_heat_separation/use_policy/alter_table_add_policy.groovy
deleted file mode 100644
index 2963650903..0000000000
---
a/regression-test/suites/cold_heat_separation/use_policy/alter_table_add_policy.groovy
+++ /dev/null
@@ -1,132 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-suite("add_table_policy_by_alter_table") {
- sql """ADMIN SET FRONTEND CONFIG ("enable_storage_policy" = "true");"""
-
- def create_table_not_have_policy_result = try_sql """
- CREATE TABLE IF NOT EXISTS create_table_not_have_policy
- (
- k1 BIGINT,
- k2 LARGEINT,
- v1 VARCHAR(2048)
- )
- UNIQUE KEY(k1)
- DISTRIBUTED BY HASH (k1) BUCKETS 3
- PROPERTIES(
- "replication_num" = "1"
- );
- """
- assertEquals(create_table_not_have_policy_result.size(), 1);
-
- def alter_table_use_not_exist_policy_result = try_sql """
- ALTER TABLE create_table_not_have_policy set ("storage_policy" =
"policy_not_exist");
- """
- // errCode = 2, detailMessage = Resource does not exist. name:
policy_not_exist
- assertEquals(alter_table_use_not_exist_policy_result, null);
-
- def storage_exist = { name ->
- def show_storage_policy = sql """
- SHOW STORAGE POLICY;
- """
- for(iter in show_storage_policy){
- if(name == iter[0]){
- return true;
- }
- }
- return false;
- }
-
- if (!storage_exist.call("created_create_table_alter_policy")) {
- def create_s3_resource = try_sql """
- CREATE RESOURCE "test_create_alter_table_use_resource"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY created_create_table_alter_policy
- PROPERTIES(
- "storage_resource" = "test_create_alter_table_use_resource",
- "cooldown_datetime" = "2022-06-08 00:00:00"
- );
- """
- assertEquals(storage_exist.call("created_create_table_alter_policy"),
true)
- }
-
- def alter_table_try_again_result = try_sql """
- ALTER TABLE create_table_not_have_policy set ("storage_policy" =
"created_create_table_alter_policy");
- """
- // OK
- assertEquals(alter_table_try_again_result.size(), 1);
-
- def alter_table_when_table_has_storage_policy_result = try_sql """
- ALTER TABLE create_table_not_have_policy set ("storage_policy" =
"created_create_table_alter_policy");
- """
- // errCode = 2, detailMessage = Do not support alter table's storage
policy , this table [create_table_not_have_policy] has storage policy
created_create_table_alter_policy
- assertEquals(alter_table_when_table_has_storage_policy_result, null);
-
- if (!storage_exist.call("created_create_table_alter_policy_1")) {
- def create_s3_resource = try_sql """
- CREATE RESOURCE "test_create_alter_table_use_resource_1"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY created_create_table_alter_policy_1
- PROPERTIES(
- "storage_resource" = "test_create_alter_table_use_resource_1",
- "cooldown_datetime" = "2022-06-08 00:00:00"
- );
- """
-
assertEquals(storage_exist.call("created_create_table_alter_policy_1"), true)
- }
-
- // current not support change storage policy name
- def cannot_modify_exist_storage_policy_table_result = try_sql """
- ALTER TABLE create_table_not_have_policy set ("storage_policy" =
"created_create_table_alter_policy_1");
- """
- // errCode = 2, detailMessage = Do not support alter table's storage
policy , this table [create_table_not_have_policy] has storage policy
created_create_table_alter_policy
- assertEquals(cannot_modify_exist_storage_policy_table_result, null);
-
- // you can change created_create_table_alter_policy's policy cooldown
time, cooldown ttl property,
- // by alter storage policy
- def modify_storage_policy_property_result = try_sql """
- ALTER STORAGE POLICY "created_create_table_alter_policy_1"
PROPERTIES("cooldown_datetime" = "2026-06-08 00:00:00");
- """
- // change s3 resource, ak、sk by alter resource
- def modify_storage_policy_property_result_1 = try_sql """
- ALTER RESOURCE "test_create_alter_table_use_resource_1"
PROPERTIES("AWS_ACCESS_KEY" = "has_been_changed");
- """
-
- sql """
- DROP TABLE create_table_not_have_policy;
- """
-}
diff --git
a/regression-test/suites/cold_heat_separation/use_policy/create_table_use_partition_policy.groovy
b/regression-test/suites/cold_heat_separation/use_policy/create_table_use_partition_policy.groovy
deleted file mode 100644
index 3a1b4ff833..0000000000
---
a/regression-test/suites/cold_heat_separation/use_policy/create_table_use_partition_policy.groovy
+++ /dev/null
@@ -1,156 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
-suite("create_table_use_partition_policy") {
- sql """ADMIN SET FRONTEND CONFIG ("enable_storage_policy" = "true");"""
-
- SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
- Date date = new Date(System.currentTimeMillis() + 3600000)
- def cooldownTime = format.format(date)
-
- def create_table_partition_use_not_create_policy = try_sql """
- CREATE TABLE IF NOT EXISTS create_table_partition_use_not_create_policy
- (
- k1 DATE,
- k2 INT,
- V1 VARCHAR(2048) REPLACE
- ) PARTITION BY RANGE (k1) (
- PARTITION p1 VALUES LESS THAN ("2022-01-01") ("storage_policy" =
"not_exist_policy_1" ,"replication_num"="1"),
- PARTITION p2 VALUES LESS THAN ("2022-02-01") ("storage_policy" =
"not_exist_policy_2" ,"replication_num"="1")
- ) DISTRIBUTED BY HASH(k2) BUCKETS 1;
- """
-
- // errCode = 2, detailMessage = Storage policy does not exist. name:
not_exist_policy_1
- assertEquals(create_table_partition_use_not_create_policy, null)
-
- def storage_exist = { name ->
- def show_storage_policy = sql """
- SHOW STORAGE POLICY;
- """
- for(iter in show_storage_policy){
- if(name == iter[0]){
- return true;
- }
- }
- return false;
- }
-
- if (!storage_exist.call("test_create_table_partition_use_policy_1")) {
- def create_s3_resource = try_sql """
- CREATE RESOURCE "test_create_table_partition_use_resource_1"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY test_create_table_partition_use_policy_1
- PROPERTIES(
- "storage_resource" = "test_create_table_partition_use_resource_1",
- "cooldown_datetime" = "$cooldownTime"
- );
- """
-
assertEquals(storage_exist.call("test_create_table_partition_use_policy_1"),
true)
- }
-
-
- if (!storage_exist.call("test_create_table_partition_use_policy_2")) {
- def create_s3_resource = try_sql """
- CREATE RESOURCE "test_create_table_partition_use_resource_2"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY test_create_table_partition_use_policy_2
- PROPERTIES(
- "storage_resource" = "test_create_table_partition_use_resource_2",
- "cooldown_datetime" = "$cooldownTime"
- );
- """
-
assertEquals(storage_exist.call("test_create_table_partition_use_policy_2"),
true)
- }
-
- // success
- def create_table_partition_use_created_policy = try_sql """
- CREATE TABLE IF NOT EXISTS create_table_partition_use_created_policy
- (
- k1 DATE,
- k2 INT,
- V1 VARCHAR(2048) REPLACE
- ) PARTITION BY RANGE (k1) (
- PARTITION p1 VALUES LESS THAN ("2022-01-01") ("storage_policy" =
"test_create_table_partition_use_policy_1" ,"replication_num"="1"),
- PARTITION p2 VALUES LESS THAN ("2022-02-01") ("storage_policy" =
"test_create_table_partition_use_policy_2" ,"replication_num"="1")
- ) DISTRIBUTED BY HASH(k2) BUCKETS 1;
- """
-
- assertEquals(create_table_partition_use_created_policy.size(), 1);
-
- sql """
- DROP TABLE create_table_partition_use_created_policy
- """
-
- def create_table_partition_use_created_policy_1 = try_sql """
- CREATE TABLE IF NOT EXISTS create_table_partition_use_created_policy_1
- (
- k1 DATEV2,
- k2 INT,
- V1 VARCHAR(2048) REPLACE
- ) PARTITION BY RANGE (k1) (
- PARTITION p1 VALUES LESS THAN ("2022-01-01") ("storage_policy" =
"test_create_table_partition_use_policy_1" ,"replication_num"="1"),
- PARTITION p2 VALUES LESS THAN ("2022-02-01") ("storage_policy" =
"test_create_table_partition_use_policy_2" ,"replication_num"="1")
- ) DISTRIBUTED BY HASH(k2) BUCKETS 1;
- """
-
- assertEquals(create_table_partition_use_created_policy_1.size(), 1);
-
- sql """
- DROP TABLE create_table_partition_use_created_policy_1
- """
-
- def create_table_partition_use_created_policy_2 = try_sql """
- CREATE TABLE IF NOT EXISTS create_table_partition_use_created_policy_2
- (
- k1 DATETIMEV2(3),
- k2 INT,
- V1 VARCHAR(2048) REPLACE
- ) PARTITION BY RANGE (k1) (
- PARTITION p1 VALUES LESS THAN ("2022-01-01 00:00:00.111")
("storage_policy" = "test_create_table_partition_use_policy_1"
,"replication_num"="1"),
- PARTITION p2 VALUES LESS THAN ("2022-02-01 00:00:00.111")
("storage_policy" = "test_create_table_partition_use_policy_2"
,"replication_num"="1")
- ) DISTRIBUTED BY HASH(k2) BUCKETS 1;
- """
-
- assertEquals(create_table_partition_use_created_policy_2.size(), 1);
-
- sql """
- DROP TABLE create_table_partition_use_created_policy_2
- """
-}
diff --git
a/regression-test/suites/cold_heat_separation/use_policy/create_table_use_policy.groovy
b/regression-test/suites/cold_heat_separation/use_policy/create_table_use_policy.groovy
deleted file mode 100644
index 871d07c9e9..0000000000
---
a/regression-test/suites/cold_heat_separation/use_policy/create_table_use_policy.groovy
+++ /dev/null
@@ -1,104 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
-suite("create_table_use_policy") {
- sql """ADMIN SET FRONTEND CONFIG ("enable_storage_policy" = "true");"""
-
- SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
- Date date = new Date(System.currentTimeMillis() + 3600000)
- def cooldownTime = format.format(date)
-
- def create_table_use_not_create_policy = try_sql """
- CREATE TABLE IF NOT EXISTS create_table_use_not_create_policy
- (
- k1 BIGINT,
- k2 LARGEINT,
- v1 VARCHAR(2048)
- )
- UNIQUE KEY(k1)
- DISTRIBUTED BY HASH (k1) BUCKETS 3
- PROPERTIES(
- "storage_policy" = "not_exist_policy",
- "replication_num" = "1"
- );
- """
-
- // errCode = 2, detailMessage = Storage policy does not exist. name:
not_exist_policy
- assertEquals(create_table_use_not_create_policy, null)
-
- def storage_exist = { name ->
- def show_storage_policy = sql """
- SHOW STORAGE POLICY;
- """
- for(iter in show_storage_policy){
- if(name == iter[0]){
- return true;
- }
- }
- return false;
- }
-
- def create_s3_resource = try_sql """
- CREATE RESOURCE IF NOT EXISTS "test_create_table_use_resource"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY IF NOT EXISTS test_create_table_use_policy
- PROPERTIES(
- "storage_resource" = "test_create_table_use_resource",
- "cooldown_datetime" = "$cooldownTime"
- );
- """
-
- sql """ALTER STORAGE POLICY test_create_table_use_policy
PROPERTIES("cooldown_datetime" = "$cooldownTime")"""
-
- assertEquals(storage_exist.call("test_create_table_use_policy"), true)
-
- // success
- def create_table_use_created_policy = try_sql """
- CREATE TABLE IF NOT EXISTS create_table_use_created_policy
- (
- k1 BIGINT,
- k2 LARGEINT,
- v1 VARCHAR(2048)
- )
- UNIQUE KEY(k1)
- DISTRIBUTED BY HASH (k1) BUCKETS 3
- PROPERTIES(
- "storage_policy" = "test_create_table_use_policy",
- "replication_num" = "1"
- );
- """
-
- assertEquals(create_table_use_created_policy.size(), 1);
-
- sql """
- DROP TABLE IF EXISTS create_table_use_created_policy
- """
-
-}
diff --git
a/regression-test/suites/cold_heat_separation/use_policy/modify_partition_add_policy.groovy
b/regression-test/suites/cold_heat_separation/use_policy/modify_partition_add_policy.groovy
deleted file mode 100644
index c7dc83379e..0000000000
---
a/regression-test/suites/cold_heat_separation/use_policy/modify_partition_add_policy.groovy
+++ /dev/null
@@ -1,118 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
-suite("add_table_policy_by_modify_partition") {
- sql """ADMIN SET FRONTEND CONFIG ("enable_storage_policy" = "true");"""
-
- SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss")
- Date date = new Date(System.currentTimeMillis() + 3600000)
- def cooldownTime = format.format(date)
-
- sql """DROP TABLE IF EXISTS create_table_partition"""
- def create_table_partition_not_have_policy_result = try_sql """
- CREATE TABLE IF NOT EXISTS `create_table_partition` (
- `lo_orderkey` bigint(20) NOT NULL COMMENT "",
- `lo_linenumber` bigint(20) NOT NULL COMMENT "",
- `lo_custkey` int(11) NOT NULL COMMENT "",
- `lo_partkey` int(11) NOT NULL COMMENT "",
- `lo_suppkey` int(11) NOT NULL COMMENT "",
- `lo_orderdate` int(11) NOT NULL COMMENT "",
- `lo_orderpriority` varchar(16) NOT NULL COMMENT "",
- `lo_shippriority` int(11) NOT NULL COMMENT "",
- `lo_quantity` bigint(20) NOT NULL COMMENT "",
- `lo_extendedprice` bigint(20) NOT NULL COMMENT "",
- `lo_ordtotalprice` bigint(20) NOT NULL COMMENT "",
- `lo_discount` bigint(20) NOT NULL COMMENT "",
- `lo_revenue` bigint(20) NOT NULL COMMENT "",
- `lo_supplycost` bigint(20) NOT NULL COMMENT "",
- `lo_tax` bigint(20) NOT NULL COMMENT "",
- `lo_commitdate` bigint(20) NOT NULL COMMENT "",
- `lo_shipmode` varchar(11) NOT NULL COMMENT ""
- )
- PARTITION BY RANGE(`lo_orderdate`)
- (PARTITION p1992 VALUES [("-2147483648"), ("19930101")),
- PARTITION p1998 VALUES [("19980101"), ("19990101")) )
- DISTRIBUTED BY HASH(`lo_orderkey`) BUCKETS 4
- PROPERTIES (
- "replication_num" = "1"
- );
- """
- assertEquals(create_table_partition_not_have_policy_result.size(), 1);
-
- // support
- // 1. ALTER TABLE create_table_partition MODIFY PARTITION p1992
SET("storage_policy"="not_exist_policy");
- // 2. ALTER TABLE create_table_partition MODIFY PARTITION (p1992, p1998)
SET("storage_policy"="not_exist_policy");
- // 3. ALTER TABLE create_table_partition MODIFY PARTITION (*)
SET("storage_policy"="not_exist_policy");
- def alter_table_partition_use_not_exist_policy_result = try_sql """
- ALTER TABLE create_table_partition MODIFY PARTITION p1992
SET("storage_policy"="not_exist_policy");
- """
- // errCode = 2, detailMessage = Resource does not exist. name:
not_exist_policy
- assertEquals(alter_table_partition_use_not_exist_policy_result, null);
-
- def storage_exist = { name ->
- def show_storage_policy = sql """
- SHOW STORAGE POLICY;
- """
- for(iter in show_storage_policy){
- if(name == iter[0]){
- return true;
- }
- }
- return false;
- }
-
- def create_s3_resource = try_sql """
- CREATE RESOURCE IF NOT EXISTS
"test_modify_partition_table_use_resource"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- def create_succ_1 = try_sql """
- CREATE STORAGE POLICY IF NOT EXISTS
created_create_table_partition_alter_policy
- PROPERTIES(
- "storage_resource" = "test_modify_partition_table_use_resource",
- "cooldown_datetime" = "$cooldownTime"
- );
- """
- sql """ALTER STORAGE POLICY created_create_table_partition_alter_policy
PROPERTIES("cooldown_datetime" = "$cooldownTime")"""
-
assertEquals(storage_exist.call("created_create_table_partition_alter_policy"),
true)
-
- def alter_table_partition_try_again_result = try_sql """
- ALTER TABLE create_table_partition MODIFY PARTITION (*)
SET("storage_policy"="created_create_table_partition_alter_policy");
- """
- // OK
- assertEquals(alter_table_partition_try_again_result.size(), 1);
-
- def alter_table_when_table_partition_has_storage_policy_result = try_sql
"""
- ALTER TABLE create_table_partition MODIFY PARTITION p1992
SET("storage_policy"="created_create_table_partition_alter_policy");
- """
- // errCode = 2, detailMessage = Do not support alter table's partition
storage policy , this table [create_table_partition] and partition [p1992] has
storage policy created_create_table_partition_alter_policy
- assertEquals(alter_table_when_table_partition_has_storage_policy_result,
null);
-
- sql """
- DROP TABLE IF EXISTS create_table_partition;
- """
-}
diff --git
a/regression-test/suites/cold_heat_separation/use_policy/use_default_storage_policy.groovy
b/regression-test/suites/cold_heat_separation/use_policy/use_default_storage_policy.groovy
deleted file mode 100644
index fb65808514..0000000000
---
a/regression-test/suites/cold_heat_separation/use_policy/use_default_storage_policy.groovy
+++ /dev/null
@@ -1,88 +0,0 @@
-// Licensed to the Apache Software Foundation (ASF) under one
-// or more contributor license agreements. See the NOTICE file
-// distributed with this work for additional information
-// regarding copyright ownership. The ASF licenses this file
-// to you under the Apache License, Version 2.0 (the
-// "License"); you may not use this file except in compliance
-// with the License. You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing,
-// software distributed under the License is distributed on an
-// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-// KIND, either express or implied. See the License for the
-// specific language governing permissions and limitations
-// under the License.
-
-suite("use_default_storage_policy") {
- sql """ADMIN SET FRONTEND CONFIG ("enable_storage_policy" = "true");"""
-
- def storage_exist = { name ->
- def show_storage_policy = sql """
- SHOW STORAGE POLICY;
- """
- for(iter in show_storage_policy){
- if(name == iter[0]){
- return true;
- }
- }
- return false;
- }
-
- if (!storage_exist.call("default_storage_policy")) {
- def create_table_use_default_policy_but_not_set_default_policy_result
= try_sql """
- CREATE TABLE IF NOT EXISTS use_default_storage_policy
- ( k1 DATE, k2 INT, V1 VARCHAR(2048) REPLACE )
- PARTITION BY RANGE (k1)
- (
- PARTITION p1 VALUES LESS THAN ("2022-01-01") ("storage_policy"
= "default_storage_policy", "replication_num"="1"),
- PARTITION p2 VALUES LESS THAN ("2022-02-01") ("storage_policy"
= "default_storage_policy", "replication_num"="1")
- ) DISTRIBUTED BY HASH(k2) BUCKETS 1;
- """
- // errCode = 2, detailMessage = Use default storage policy, but not
give s3 info, please use alter resource to add default storage policy S3 info.
-
assertEquals(create_table_use_default_policy_but_not_set_default_policy_result,
null);
-
- def create_s3_resource = try_sql """
- CREATE RESOURCE "default_s3_resource"
- PROPERTIES(
- "type"="s3",
- "AWS_REGION" = "bj",
- "AWS_ENDPOINT" = "http://bj.s3.comaaaa";,
- "AWS_ROOT_PATH" = "path/to/rootaaaa",
- "AWS_SECRET_KEY" = "aaaa",
- "AWS_ACCESS_KEY" = "bbba",
- "AWS_BUCKET" = "test-bucket"
- );
- """
- def create_succ_1 = try_sql """
- ALTER STORAGE POLICY default_storage_policy PROPERTIES(
- "storage_resource" = "default_s3_resource",
- "cooldown_ttl" = "1008611"
- );
- """
- assertEquals(storage_exist.call("default_storage_policy"), true)
- }
-
- def create_table_use_default_policy_has_set_default_policy_result =
try_sql """
- CREATE TABLE IF NOT EXISTS use_default_storage_policy
- ( k1 DATE, k2 INT, V1 VARCHAR(2048) REPLACE )
- PARTITION BY RANGE (k1)
- (
- PARTITION p1 VALUES LESS THAN ("2022-01-01") ("storage_policy" =
"default_storage_policy", "replication_num"="1"),
- PARTITION p2 VALUES LESS THAN ("2022-02-01") ("storage_policy" =
"default_storage_policy", "replication_num"="1")
- ) DISTRIBUTED BY HASH(k2) BUCKETS 1;
- """
- // success
-
assertEquals(create_table_use_default_policy_has_set_default_policy_result.size(),
1)
-
- // you can change default_storage_policy's policy property, such as ak、sk,
- // so table create_table_not_have_policy will use AWS_ACCESS_KEY =
"has_been_changed"
- def modify_storage_policy_property_result_1 = try_sql """
- ALTER RESOURCE "default_s3_resource" PROPERTIES("AWS_ACCESS_KEY" =
"has_been_changed");
- """
-
- sql """
- DROP TABLE use_default_storage_policy;
- """
-}
diff --git
a/regression-test/suites/datatype_p0/scalar_types/sql/infomation_schema.sql
b/regression-test/suites/datatype_p0/scalar_types/sql/infomation_schema.sql
deleted file mode 100644
index 0014622537..0000000000
--- a/regression-test/suites/datatype_p0/scalar_types/sql/infomation_schema.sql
+++ /dev/null
@@ -1 +0,0 @@
-SELECT * FROM `information_schema`.`COLUMNS` WHERE TABLE_SCHEMA =
'regression_test_datatype_p0_scalar_types' AND TABLE_NAME =
'tbl_scalar_types_dup' ORDER BY ORDINAL_POSITION;
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
