Re: env.fromElements produces TypeInformation error

[Dan Drewes]

I've tested it, but unfortunately it does not solve the problem.
The error message remains the same.

Am 04.06.2016 um 19:38 schrieb Simone Robutti:

I'm not sure if this is the solution and I don't have the possibility
to try right now, but you should move the case class "State"
definition outside the abstract class.

2016-06-04 17:34 GMT+02:00 Dan Drewes <dre...@campus.tu-berlin.de
<mailto:dre...@campus.tu-berlin.de>>:


    Hi,

    compiling the code:

    def minimize(f:DF, init:T):T = {

       //create execution environment val env = 
ExecutionEnvironment.getExecutionEnvironment

       valinitialstate =initialState(f, init)

    val iterativestate= env.fromElements(initialstate).iterate(10000) {
         iterationInput: DataSet[State] =>
         val result = iterationInput.map {
             oldstate => computeNextState(adjustedFun, oldstate)
           }
           result
       }
    }

    objectIterationsFirstOrderMinimizer {
    case class State[+T,+ConvergenceInfo,+History] (x:T,
                                                        value: Double, grad:T,
                                                        adjustedValue: Double, 
adjustedGradient:T,
                                                        iter: Int,
                                                        initialAdjVal: Double,
                                                        history:History,
                                                        
convergenceInfo:ConvergenceInfo,
                                                        searchFailed: Boolean 
=false) {
       }

    ... fails with the error: could not find implicit value for
    evidence parameter of type
    
org.apache.flink.api.common.typeinfo.TypeInformation[IterationsFirstOrderMinimizer.this.State]
    val iterativestate= env.fromElements(initialState(f,
    init)).iterate(10000) {                                         ^
    Google only told me toimport org.apache.flink.api.scala._
    which i do. The other suggested solution for generic methods
    
(https://ci.apache.org/projects/flink/flink-docs-master/internals/types_serialization.html)
    does also not apply because it's the fromElements call that
    produces the error. I am very new to Flink and Scala and because I
    don't know if the code I posted above is enough to say what I'm
    doing wrong, you can find the complete scala file attached. Thanks
    in advance for any ideas and hints. Best, Dan

    
<https://www.avast.com/sig-email?utm_medium=email&utm_source=link&utm_campaign=sig-email&utm_content=emailclient>
        Virenfrei. www.avast.com
    
<https://www.avast.com/sig-email?utm_medium=email&utm_source=link&utm_campaign=sig-email&utm_content=emailclient>

---
Diese E-Mail wurde von Avast Antivirus-Software auf Viren geprüft.
https://www.avast.com/antivirus