more test

Author: felixcheung

R/pkg/R/DataFrame.R

@@ -3764,7 +3764,7 @@ setMethod("write.stream",
             cols <- NULL
             if (!is.null(partitionBy)) {
               if (!all(sapply(partitionBy, function(c) { is.character(c) }))) {
-                stop("all partitionBy column names should be characters")
+                stop("All partitionBy column names should be characters.")
               }
               cols <- as.list(partitionBy)
             }

R/pkg/tests/fulltests/test_streaming.R

@@ -180,7 +180,13 @@ test_that("PartitionBy", {
   write.df(df, parquetPath, "parquet", "overwrite")
 
   df <- read.stream(path = parquetPath, schema = stringSchema)
-  q <- write.stream(df, "json", path = textPath, checkpointLocation = "append", partitionBy = "name")
+
+  expect_error(write.stream(df, "json", path = textPath, checkpointLocation = "append",
+                            partitionBy = c(1, 2)),
+                            "All partitionBy column names should be characters")
+
+  q <- write.stream(df, "json", path = textPath, checkpointLocation = "append",
+                    partitionBy = "name")
   awaitTermination(q, 5 * 1000)
   callJMethod(q@ssq, "processAllAvailable")