Hwansung Yu created S2GRAPH-237:

             Summary: 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

val df = repartition(preprocess(inputDF), 

if (inputDF.isStreaming) throw new IllegalStateException("AnnoyIndexBuildSink 
can not be run as streaming.")
else {
      ALSModelProcess.buildAnnoyIndex(conf, inputDF)

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

Reply via email to