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



{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