@@ -290,19 +290,19 @@ public void testEncryption() throws Exception {
290290
291291 // create s3 job
292292 sql = "CREATE JOB my_job"
293- + " ON STREAMING"
294- + " DO"
295- + " INSERT INTO test.`student`"
296- + " SELECT * FROM S3"
297- + " ("
298- + " \" uri\" = \" s3://bucketname/demo/*.csv\" ,"
299- + " \" format\" = \" csv\" ,"
300- + " \" column_separator\" = \" ,\" ,"
301- + " \" s3.endpoint\" = \" s3.ap-southeast-1.amazonaws.com\" ,"
302- + " \" s3.region\" = \" ap-southeast-1\" ,"
303- + " \" s3.access_key\" = \" ak\" ,"
304- + " \" s3.secret_key\" = \" abcdefg\" "
305- + " );" ;
293+ + " ON STREAMING"
294+ + " DO"
295+ + " INSERT INTO test.`student`"
296+ + " SELECT * FROM S3"
297+ + " ("
298+ + " \" uri\" = \" s3://bucketname/demo/*.csv\" ,"
299+ + " \" format\" = \" csv\" ,"
300+ + " \" column_separator\" = \" ,\" ,"
301+ + " \" s3.endpoint\" = \" s3.ap-southeast-1.amazonaws.com\" ,"
302+ + " \" s3.region\" = \" ap-southeast-1\" ,"
303+ + " \" s3.access_key\" = \" ak\" ,"
304+ + " \" s3.secret_key\" = \" abcdefg\" "
305+ + " );" ;
306306
307307 res = "CREATE JOB my_job"
308308 + " ON STREAMING"
0 commit comments