Github user rawkintrevo commented on the pull request:

    https://github.com/apache/flink/pull/1849#issuecomment-212633912
  
    Also two quick issues.
    
    *pipelines*
    
    ```scala
    val scaler = MinMaxScaler()
    val pipeline = scaler.chainPredictor(mlr)
    val evaluationDS = survivalLV.map(x => (x.vector, x.label))
    
    pipeline.fit(survivalLV)
    scorer.evaluate(evaluationDS, pipeline).collect().head
    ```
    When using this with a ChainedPredictor as the predictor I get the 
following error:
    error: could not find implicit value for parameter evaluateOperation: 
org.apache.flink.ml.pipeline.EvaluateDataSetOperation[org.apache.flink.ml.pipeline.ChainedPredictor[org.apache.flink.ml.preprocessing.MinMaxScaler,org.apache.flink.ml.regression.MultipleLinearRegression],(org.apache.flink.ml.math.Vector,
 Double),Double]
    
    
    *MinMaxScaler()*
    Merging for me broke the following code:
    ```scala
    val scaler = MinMaxScaler()
    val scaledSurvivalLV = scaler.transform(survivalLV)
    ```
    With the following error (omiting part of the stack trace)
    Caused by: java.lang.NoSuchMethodError: 
breeze.linalg.Vector$.scalarOf()Lbreeze/linalg/support/ScalarOf;
        at 
org.apache.flink.ml.preprocessing.MinMaxScaler$$anonfun$3.apply(MinMaxScaler.scala:156)
        at 
org.apache.flink.ml.preprocessing.MinMaxScaler$$anonfun$3.apply(MinMaxScaler.scala:154)
        at org.apache.flink.api.scala.DataSet$$anon$7.reduce(DataSet.scala:584)
        at 
org.apache.flink.runtime.operators.chaining.ChainedAllReduceDriver.collect(ChainedAllReduceDriver.java:93)
        at 
org.apache.flink.runtime.operators.chaining.ChainedMapDriver.collect(ChainedMapDriver.java:78)
        at org.apache.flink.runtime.operators.MapDriver.run(MapDriver.java:97)
        at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:480)
        at 
org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:345)
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
        at java.lang.Thread.run(Thread.java:745)
    
    
    I'm looking for a work around.  Just saying I found a regression. Other 
than that, looks/works AWESOME well done. 


---
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 is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---

Reply via email to