[MAHOUT-2006] AsFactor has unexpected behavior when partitions not set

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Won't Fix
• Fix Version/s: 0.13.2

Environment

Zeppelin Notebook, Spark 2.1, scala 2.10

• Assignee: Unassigned
• Reporter: Trevor Grant
• Created: 15/Jul/17 05:48
• Updated: 31/Jan/24 22:11
• Resolved: 31/Jan/24 21:51

Description

```
val drmA = drmParallelize(dense((0.0), (0.0), (1.0), (0.0), (2.0)), numPartitions = 2)

val factorizer = new AsFactor().fit(drmA)

val factoredA = factorizer.transform(drmA).collect
```

Yields:
```
drmA: org.apache.mahout.math.drm.CheckpointedDrm[Int] = org.apache.mahout.sparkbindings.drm.CheckpointedDrmSpark@75dcf2b2
factorizer: org.apache.mahout.math.algorithms.preprocessing.AsFactorModel = org.apache.mahout.math.algorithms.preprocessing.AsFactorModel@13b49f81
factoredA: org.apache.mahout.math.Matrix =
{
0 =>

{0:1.0}

1 =>

{0:1.0}

2 =>

{1:1.0}

3 =>

{0:1.0}

4 => {}
}
```

as expected, however

```
val drmA = drmParallelize(dense((0.0), (0.0), (1.0), (0.0), (2.0)))

val factorizer = new AsFactor().fit(drmA)

val factoredA = factorizer.transform(drmA).collect
```

Yields:
```
drmA: org.apache.mahout.math.drm.CheckpointedDrm[Int] = org.apache.mahout.sparkbindings.drm.CheckpointedDrmSpark@75dcf2b2
factorizer: org.apache.mahout.math.algorithms.preprocessing.AsFactorModel = org.apache.mahout.math.algorithms.preprocessing.AsFactorModel@13b49f81
factoredA: org.apache.mahout.math.Matrix =
{
0 => {}
1 => {}
2 => {}
3 => {}
4 => {}
}
```