[GitHub] spark pull request #21179: Update StreamingKMeans.scala

2018-04-27 Thread ddna1021
GitHub user ddna1021 opened a pull request: https://github.com/apache/spark/pull/21179 Update StreamingKMeans.scala ## What changes were proposed in this pull request? I think the ‘n_t+t’ in the following code may be wrong, it shoud be ‘n_t+1’ that means

[GitHub] spark pull request #20220: Update PageRank.scala

2018-01-10 Thread ddna1021
GitHub user ddna1021 opened a pull request: https://github.com/apache/spark/pull/20220 Update PageRank.scala ## What changes were proposed in this pull request? Hi, acording to code below, "if (id == src) (0.0, Double.NegativeInfinity) else (0.0, 0.0)"

[GitHub] spark pull request #18845: [SPARK-21596] Update StreamExecution.scala

2017-08-04 Thread ddna1021
Github user ddna1021 closed the pull request at: https://github.com/apache/spark/pull/18845 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] spark issue #18845: [SPARK-21596] Update StreamExecution.scala

2017-08-04 Thread ddna1021
Github user ddna1021 commented on the issue: https://github.com/apache/spark/pull/18845 Should I close my PR,Sorry,I am a rookie --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[GitHub] spark pull request #18845: [SPARK-21596] Update StreamExecution.scala

2017-08-04 Thread ddna1021
GitHub user ddna1021 reopened a pull request: https://github.com/apache/spark/pull/18845 [SPARK-21596] Update StreamExecution.scala [SPARK-21596] link to https://issues.apache.org/jira/browse/SPARK-21596 ## What changes were proposed in this pull request

[GitHub] spark pull request #18845: [SPARK-21596] Update StreamExecution.scala

2017-08-04 Thread ddna1021
Github user ddna1021 closed the pull request at: https://github.com/apache/spark/pull/18845 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] spark issue #18845: [SPARK-21596] Update StreamExecution.scala

2017-08-04 Thread ddna1021
Github user ddna1021 commented on the issue: https://github.com/apache/spark/pull/18845 Ok,that menas my PR is invalid? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[GitHub] spark issue #18845: Update StreamExecution.scala

2017-08-04 Thread ddna1021
Github user ddna1021 commented on the issue: https://github.com/apache/spark/pull/18845 [SPARK-21596] means we must check the return value HDFSMetadataLog.get(), so it should ensure all the places taht calling the get() method of subclass of HDFSMetadataLog check the return value

[GitHub] spark issue #18845: Update StreamExecution.scala

2017-08-04 Thread ddna1021
Github user ddna1021 commented on the issue: https://github.com/apache/spark/pull/18845 [SPARK-21596] means we must check the return value HDFSMetadataLog.get(), so it should ensure all the places taht calling the get() method of subclass of HDFSMetadataLog check the return value

[GitHub] spark pull request #18845: Update StreamExecution.scala

2017-08-04 Thread ddna1021
GitHub user ddna1021 opened a pull request: https://github.com/apache/spark/pull/18845 Update StreamExecution.scala link to https://issues.apache.org/jira/browse/SPARK-21596 ## What changes were proposed in this pull request? class OffsetSeqLog is subclass