Skip to content

Commit 3b74483

Browse files
committed
fix aksk
Signed-off-by: wjhuang2016 <[email protected]>
1 parent c911a65 commit 3b74483

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

main.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ import (
2020
"fmt"
2121
"math/rand"
2222
"os"
23+
"strings"
2324
"time"
2425

2526
"github.com/go-sql-driver/mysql"
@@ -171,6 +172,8 @@ func main() {
171172
dataSource := S3ImportIntoDataSource[rand.Intn(len(S3ImportIntoDataSource))]
172173
if *platform == "ks3" {
173174
dataSource = KS3ImportIntoDataSource[rand.Intn(len(KS3ImportIntoDataSource))]
175+
aksk := (*globalSortUri)[strings.Index(*globalSortUri, "?"):]
176+
dataSource += aksk
174177
}
175178
importSQL := fmt.Sprintf("IMPORT INTO sbtest1 FROM '%s' WITH FIELDS_DEFINED_NULL_BY='NULL', SPLIT_FILE, THREAD=8,LINES_TERMINATED_BY='\n'", dataSource)
176179
_, err = tidbC.ExecContext(context.Background(), importSQL)

0 commit comments

Comments
 (0)