[
https://issues.apache.org/jira/browse/SPARK-20520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Felix Cheung updated SPARK-20520:
---------------------------------
Description:
Running R CMD check on SparkR 2.2 RC1 packages
{code}
Failed -------------------------------------------------------------------------
1. Failure: read.stream, write.stream, awaitTermination, stopQuery
(@test_streaming.R#56)
head(sql("SELECT count(*) FROM people"))[[1]] not equal to 3.
1/1 mismatches
[1] 0 - 3 == -3
2. Failure: read.stream, write.stream, awaitTermination, stopQuery
(@test_streaming.R#60)
head(sql("SELECT count(*) FROM people"))[[1]] not equal to 6.
1/1 mismatches
[1] 3 - 6 == -3
3. Failure: print from explain, lastProgress, status, isActive
(@test_streaming.R#75)
any(grepl("\"description\" : \"MemorySink\"", capture.output(lastProgress(q))))
isn't true.
4. Failure: Stream other format (@test_streaming.R#95) -------------------------
head(sql("SELECT count(*) FROM people3"))[[1]] not equal to 3.
1/1 mismatches
[1] 0 - 3 == -3
5. Failure: Stream other format (@test_streaming.R#98) -------------------------
any(...) isn't true.
{code}
Need to investigate
was:
This JIRA lists tasks for the next Spark release's QA period for SparkR.
The list below gives an overview of what is involved, and the corresponding
JIRA issues are linked below that.
h2. API
* Audit new public APIs (from the generated html doc)
** relative to Spark Scala/Java APIs
** relative to popular R libraries
h2. Documentation and example code
* For new algorithms, create JIRAs for updating the user guide sections &
examples
* Update Programming Guide
* Update website
> R streaming test failed on Windows
> ----------------------------------
>
> Key: SPARK-20520
> URL: https://issues.apache.org/jira/browse/SPARK-20520
> Project: Spark
> Issue Type: Umbrella
> Components: SparkR
> Reporter: Felix Cheung
> Assignee: Felix Cheung
> Priority: Critical
>
> Running R CMD check on SparkR 2.2 RC1 packages
> {code}
> Failed
> -------------------------------------------------------------------------
> 1. Failure: read.stream, write.stream, awaitTermination, stopQuery
> (@test_streaming.R#56)
> head(sql("SELECT count(*) FROM people"))[[1]] not equal to 3.
> 1/1 mismatches
> [1] 0 - 3 == -3
> 2. Failure: read.stream, write.stream, awaitTermination, stopQuery
> (@test_streaming.R#60)
> head(sql("SELECT count(*) FROM people"))[[1]] not equal to 6.
> 1/1 mismatches
> [1] 3 - 6 == -3
> 3. Failure: print from explain, lastProgress, status, isActive
> (@test_streaming.R#75)
> any(grepl("\"description\" : \"MemorySink\"",
> capture.output(lastProgress(q)))) isn't true.
> 4. Failure: Stream other format (@test_streaming.R#95)
> -------------------------
> head(sql("SELECT count(*) FROM people3"))[[1]] not equal to 3.
> 1/1 mismatches
> [1] 0 - 3 == -3
> 5. Failure: Stream other format (@test_streaming.R#98)
> -------------------------
> any(...) isn't true.
> {code}
> Need to investigate
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
