@@ -182,20 +182,20 @@ test_that("add and get file to be downloaded with Spark job on every node", {
182182 # Test add directory recursively.
183183 path <- tempdir()
184184 dir_name <- basename(path )
185- path1 <- paste0(path , " /hello.txt" )
185+ path1 <- paste0(path , " /" , " hello.txt" )
186186 file.create(path1 )
187- sub_path <- paste0(path , " /sub_hello" )
187+ sub_path <- paste0(path , " /" , " sub_hello" )
188188 dir.create(sub_path )
189- path2 <- paste0(sub_path , " /sub_hello.txt" )
189+ path2 <- paste0(sub_path , " /" , " sub_hello.txt" )
190190 file.create(path2 )
191191 words <- " Hello World!"
192192 sub_words <- " Sub Hello World!"
193193 writeLines(words , path1 )
194194 writeLines(sub_words , path2 )
195195 spark.addFile(path , recursive = TRUE )
196- download_path1 = spark.getSparkFiles(paste0(dir_name , " /hello.txt" ))
196+ download_path1 <- spark.getSparkFiles(paste0(dir_name , " /" , " hello.txt" ))
197197 expect_equal(readLines(download_path1 ), words )
198- download_path2 = spark.getSparkFiles(paste0(dir_name , " /sub_hello/sub_hello.txt" ))
198+ download_path2 <- spark.getSparkFiles(paste0(dir_name , " /" , " sub_hello/sub_hello.txt" ))
199199 expect_equal(readLines(download_path2 ), sub_words )
200200 unlink(path , recursive = TRUE )
201201 sparkR.session.stop()
0 commit comments