This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 50e999df7d0 [test](regression) delete invalid test cases (#32654)
50e999df7d0 is described below
commit 50e999df7d0a81702df75e5ab27e942186f7bc3f
Author: Gabriel <[email protected]>
AuthorDate: Fri Mar 22 12:20:44 2024 +0800
[test](regression) delete invalid test cases (#32654)
---
.../suites/job_p0/test_base_insert_job.groovy | 306 ---------------------
1 file changed, 306 deletions(-)
diff --git a/regression-test/suites/job_p0/test_base_insert_job.groovy
b/regression-test/suites/job_p0/test_base_insert_job.groovy
deleted file mode 100644
index 02e4ecc9c75..00000000000
--- a/regression-test/suites/job_p0/test_base_insert_job.groovy
+++ /dev/null
@@ -1,306 +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.time.LocalDateTime;
-import java.time.format.DateTimeFormatter;
-import java.time.Instant;
-import java.time.ZoneId;
-
-suite("test_base_insert_job") {
- def tableName = "t_test_BASE_inSert_job"
- def jobName = "insert_recovery_test_base_insert_job"
- def jobMixedName = "Insert_recovery_Test_base_insert_job"
- sql """drop table if exists `${tableName}` force"""
- sql """
- DROP JOB IF EXISTS where jobname = '${jobName}'
- """
- sql """
- DROP JOB IF EXISTS where jobname = 'JOB'
- """
- sql """
- DROP JOB IF EXISTS where jobname = 'DO'
- """
- sql """
- DROP JOB IF EXISTS where jobname = 'AT'
- """
- sql """
- DROP JOB IF EXISTS where jobname = 'SCHEDULE'
- """
- sql """
- DROP JOB IF EXISTS where jobname = 'STARTS'
- """
- sql """
- DROP JOB IF EXISTS where jobname = 'ENDS'
- """
- sql """
- DROP JOB IF EXISTS where jobname = '${jobMixedName}'
- """
-
- sql """
- DROP JOB IF EXISTS where jobname = '${jobName}'
- """
-
- sql """
- CREATE TABLE IF NOT EXISTS `${tableName}`
- (
- `timestamp` DATE NOT NULL COMMENT "['0000-01-01', '9999-12-31']",
- `type` TINYINT NOT NULL COMMENT "[-128, 127]",
- `user_id` BIGINT COMMENT "[-9223372036854775808,
9223372036854775807]"
- )
- DUPLICATE KEY(`timestamp`, `type`)
- DISTRIBUTED BY HASH(`type`) BUCKETS 1
- PROPERTIES (
- "replication_allocation" = "tag.location.default: 1"
- );
- """
- sql """
- CREATE JOB ${jobName} ON SCHEDULE every 1 second comment 'test' DO
insert into ${tableName} (timestamp, type, user_id) values
('2023-03-18','1','12213');
- """
- Thread.sleep(2500)
- sql """
- PAUSE JOB where jobname = '${jobName}'
- """
- def tblDatas = sql """select * from ${tableName}"""
- println tblDatas
- assert 3 >= tblDatas.size() >= (2 as Boolean) //at least 2 records, some
times 3 records
- def pauseJobId = sql """select id from jobs("type"="insert") where
Name='${jobName}'"""
- def taskStatus = sql """select status from tasks("type"="insert") where
jobid= '${pauseJobId.get(0).get(0)}'"""
- println taskStatus
- for (int i = 0; i < taskStatus.size(); i++) {
- assert taskStatus.get(i).get(0) != "FAILED"||taskStatus.get(i).get(0)
!= "STOPPED"||taskStatus.get(i).get(0) != "STOPPED"
- }
- sql """
- CREATE JOB ${jobMixedName} ON SCHEDULE every 1 second DO insert into
${tableName} (timestamp, type, user_id) values ('2023-03-18','1','12213');
- """
- def mixedNameJobs = sql """select name,comment from jobs("type"="insert")
where Name='${jobMixedName}'"""
- println mixedNameJobs
- assert mixedNameJobs.size() == 1 && mixedNameJobs.get(0).get(0) ==
jobMixedName
- assert mixedNameJobs.get(0).get(1) == ''
- sql """
- DROP JOB IF EXISTS where jobname = '${jobName}'
- """
- sql """
- DROP JOB IF EXISTS where jobname = '${jobMixedName}'
- """
-
- sql """drop table if exists `${tableName}` force """
- sql """
- CREATE TABLE IF NOT EXISTS `${tableName}`
- (
- `timestamp` DATE NOT NULL COMMENT "['0000-01-01', '9999-12-31']",
- `type` TINYINT NOT NULL COMMENT "[-128, 127]",
- `user_id` BIGINT COMMENT "[-9223372036854775808,
9223372036854775807]"
- )
- DUPLICATE KEY(`timestamp`, `type`)
- DISTRIBUTED BY HASH(`type`) BUCKETS 1
- PROPERTIES (
- "replication_allocation" = "tag.location.default: 1"
- );
- """
- def dataCount = sql """select count(*) from ${tableName}"""
- assert dataCount.get(0).get(0) == 0
- sql """
- CREATE JOB ${jobName} ON SCHEDULE at current_timestamp comment
'test for test&68686781jbjbhj//ncsa' DO insert into ${tableName} values
('2023-07-19', sleep(10000), 1001);
- """
-
- Thread.sleep(25000)
- def onceJob = sql """ select id,ExecuteSql from jobs("type"="insert")
where Name like '%${jobName}%' and ExecuteType='ONE_TIME' """
- assert onceJob.size() == 1
- def onceJobId = onceJob.get(0).get(0);
- def onceJobSql = onceJob.get(0).get(1);
- println onceJobSql
- def assertSql = "insert into ${tableName} values (\'2023-07-19\',
sleep(10000), 1001);"
- println assertSql
- assert onceJobSql == assertSql
- // test cancel task
- def datas = sql """select status,taskid from tasks("type"="insert") where
jobid= ${onceJobId}"""
- println datas
- assert datas.size() == 1
- assert datas.get(0).get(0) == "RUNNING"
- def taskId = datas.get(0).get(1)
- sql """cancel task where jobName='${jobName}' and taskId= ${taskId}"""
- def cancelTask = sql """ select status from tasks("type"="insert") where
jobid= ${onceJobId}"""
- println cancelTask
- //check task size is 0, cancel task where be deleted
- assert cancelTask.size() == 0
- // check table data
- def dataCount1 = sql """select count(1) from ${tableName}"""
- assert dataCount1.get(0).get(0) == 0
- // check job status
- def oncejob = sql """select status,comment from jobs("type"="insert")
where Name='${jobName}' """
- println oncejob
- assert oncejob.get(0).get(0) == "FINISHED"
- //assert comment
- assert oncejob.get(0).get(1) == "test for test&68686781jbjbhj//ncsa"
- sql """
- DROP JOB IF EXISTS where jobname = 'press'
- """
-
- sql """
- CREATE JOB press ON SCHEDULE every 10 hour starts CURRENT_TIMESTAMP
comment 'test for test&68686781jbjbhj//ncsa' DO insert into ${tableName}
values ('2023-07-19', 99, 99);
- """
- Thread.sleep(5000)
- def pressJob = sql """ select * from jobs("type"="insert") where
name='press' """
- println pressJob
-
- def recurringTableDatas = sql """ select count(1) from ${tableName} where
user_id=99 and type=99 """
- assert recurringTableDatas.get(0).get(0) == 1
- sql """
- DROP JOB IF EXISTS where jobname = '${jobName}'
- """
- sql """
- CREATE JOB ${jobName} ON SCHEDULE every 1 second comment 'test
for test&68686781jbjbhj//ncsa' DO insert into ${tableName} values
('2023-07-19', sleep(10000), 1001);
- """
-
- Thread.sleep(2500)
-
- sql """
- PAUSE JOB where jobname = '${jobName}'
- """
- def job = sql """ select id,ExecuteSql from jobs("type"="insert") where
Name like '%${jobName}%' """
- assert job.size() == 1
- def jobId = job.get(0).get(0);
- def tasks = sql """ select status from tasks("type"="insert") where jobid=
${jobId} """
- assert tasks.size() == 0
- sql """
- RESUME JOB where jobname = '${jobName}'
- """
- Thread.sleep(2500)
- def resumeTasks = sql """ select status from tasks("type"="insert") where
jobid= ${jobId} """
- println resumeTasks
- assert resumeTasks.size() == 1
- // assert same job name
- try {
- sql """
- CREATE JOB ${jobName} ON SCHEDULE EVERY 10 second comment 'test
for test&68686781jbjbhj//ncsa' DO insert into ${tableName} values
('2023-07-19', sleep(10000), 1001);
- """
- } catch (Exception e) {
- assert e.getMessage().contains("job name exist,
jobName:insert_recovery_test_base_insert_job")
- }
- def errorTblName = "${tableName}qwertyuioppoiuyte"
- sql """drop table if exists `${errorTblName}` force"""
- // assert error table name
- try {
- sql """
- CREATE JOB ${jobName} ON SCHEDULE EVERY 10 second comment 'test
for test&68686781jbjbhj//ncsa' DO insert into ${errorTblName} values
('2023-07-19', sleep(10000), 1001);
- """
- } catch (Exception e) {
- assert e.getMessage().contains("Unknown table
't_test_BASE_inSert_jobqwertyuioppoiuyte'")
- }
- // assert not support stmt
- try {
- sql """
- CREATE JOB ${jobName} ON SCHEDULE at current_timestamp comment
'test' DO update ${tableName} set type=2 where type=1;
- """
- } catch (Exception e) {
- assert e.getMessage().contains("Not support UpdateStmt type in job")
- }
- // assert start time greater than current time
- try {
- sql """
- CREATE JOB ${jobName} ON SCHEDULE at '2023-11-13 14:18:07'
comment 'test' DO insert into ${tableName} (timestamp, type, user_id) values
('2023-03-18','1','12213');
- """
- } catch (Exception e) {
- assert e.getMessage().contains("startTimeMs must be greater than
current time")
- }
- // assert end time less than start time
- try {
- sql """
- CREATE JOB test_one_time_error_starts ON SCHEDULE at '2023-11-13
14:18:07' comment 'test' DO insert into ${tableName} (timestamp, type,
user_id) values ('2023-03-18','1','12213');
- """
- } catch (Exception e) {
- assert e.getMessage().contains("startTimeMs must be greater than
current time")
- }
- try {
- sql """
- CREATE JOB inner_test ON SCHEDULE at '2023-11-13 14:18:07'
comment 'test' DO insert into ${tableName} (timestamp, type, user_id) values
('2023-03-18','1','12213');
- """
- } catch (Exception e) {
- assert e.getMessage().contains("job name can not start with inner_")
- }
- // assert end time less than start time
- try {
- sql """
- CREATE JOB test_error_starts ON SCHEDULE every 1 second ends
'2023-11-13 14:18:07' comment 'test' DO insert into ${tableName} (timestamp,
type, user_id) values ('2023-03-18','1','12213');
- """
- } catch (Exception e) {
- assert e.getMessage().contains("end time cannot be less than start
time")
- }
- // assert interval time unit can not be years
- try {
- sql """
- CREATE JOB test_error_starts ON SCHEDULE every 1 years ends
'2023-11-13 14:18:07' comment 'test' DO insert into ${tableName} (timestamp,
type, user_id) values ('2023-03-18','1','12213');
- """
- } catch (Exception e) {
- assert e.getMessage().contains("interval time unit can not be years")
- }
-
- // test keyword as job name
- sql """
- CREATE JOB JOB ON SCHEDULE every 20 second comment 'test' DO insert
into ${tableName} (timestamp, type, user_id) values ('2023-03-18','1','12213');
- """
- sql """
- CREATE JOB SCHEDULE ON SCHEDULE every 20 second comment 'test' DO
insert into ${tableName} (timestamp, type, user_id) values
('2023-03-18','1','12213');
- """
- sql """
- CREATE JOB DO ON SCHEDULE every 20 second comment 'test' DO insert
into ${tableName} (timestamp, type, user_id) values ('2023-03-18','1','12213');
- """
- sql """
- CREATE JOB AT ON SCHEDULE every 20 second comment 'test' DO insert
into ${tableName} (timestamp, type, user_id) values ('2023-03-18','1','12213');
- """
-
- sql """
- CREATE JOB STARTS ON SCHEDULE every 20 second comment 'test' DO
insert into ${tableName} (timestamp, type, user_id) values
('2023-03-18','1','12213');
- """
-
- sql """
- CREATE JOB ENDS ON SCHEDULE every 20 second comment 'test' DO
insert into ${tableName} (timestamp, type, user_id) values
('2023-03-18','1','12213');
- """
-
- def jobCountRsp = sql """select count(1) from jobs("type"="insert") where
name in ('JOB','DO','SCHEDULE','AT','STARTS','ENDS')"""
- assert jobCountRsp.get(0).get(0) == 6
-
- sql """
- DROP JOB IF EXISTS where jobname = '${jobName}'
- """
- sql """
- DROP JOB IF EXISTS where jobname = 'JOB'
- """
- sql """
- DROP JOB IF EXISTS where jobname = 'DO'
- """
- sql """
- DROP JOB IF EXISTS where jobname = 'AT'
- """
- sql """
- DROP JOB IF EXISTS where jobname = 'SCHEDULE'
- """
- sql """
- DROP JOB IF EXISTS where jobname = 'STARTS'
- """
- sql """
- DROP JOB IF EXISTS where jobname = 'ENDS'
- """
- sql """
- DROP JOB IF EXISTS where jobname = '${jobMixedName}'
- """
-
- sql """
- DROP JOB IF EXISTS where jobname = '${jobName}'
- """
-
-}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
