[ 
https://issues.apache.org/jira/browse/S2GRAPH-237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601942#comment-16601942
 ] 

Hwansung Yu commented on S2GRAPH-237:
-------------------------------------

[~steamshon]

I have send PR (https://github.com/apache/incubator-s2graph/pull/184).

Could you review? I checked the example works fine.

Thank you.

> Refactor unused variable on AnnoyIndexBuildSink class
> -----------------------------------------------------
>
>                 Key: S2GRAPH-237
>                 URL: https://issues.apache.org/jira/browse/S2GRAPH-237
>             Project: S2Graph
>          Issue Type: Bug
>            Reporter: Hwansung Yu
>            Assignee: Hwansung Yu
>            Priority: Minor
>
> {code:java}
> val df = repartition(preprocess(inputDF), 
> inputDF.sparkSession.sparkContext.defaultParallelism)
> if (inputDF.isStreaming) throw new IllegalStateException("AnnoyIndexBuildSink 
> can not be run as streaming.")
> else {
>       ALSModelProcess.buildAnnoyIndex(conf, inputDF)
> }
> {code}
> In "write" method of AnnoyIndexBuildSink class, variable "df" is never used.
> So, repartition does not working .
> I think that second parameter of buildAnnoyIndex shoule be "df", not 
> "inputDF".



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to