[ https://issues.apache.org/jira/browse/FLINK-1378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14271057#comment-14271057 ]
Aljoscha Krettek commented on FLINK-1378: ----------------------------------------- I'm looking into it. > could not find implicit value for evidence parameter of type TypeInformation > ---------------------------------------------------------------------------- > > Key: FLINK-1378 > URL: https://issues.apache.org/jira/browse/FLINK-1378 > Project: Flink > Issue Type: Bug > Components: Scala API > Affects Versions: 0.7.0-incubating > Reporter: John Sandiford > > This is an example of one of many cases that I cannot get to compile with the > scala API. I have tried using T : TypeInformation and : ClassTag but still > cannot get it to work. > //libraryDependencies += "org.apache.flink" % "flink-scala" % > "0.7.0-incubating" > // > //libraryDependencies += "org.apache.flink" % "flink-clients" % > "0.7.0-incubating" > import org.apache.flink.api.scala._ > import scala.util.{Success, Try} > object Main extends App { > val env = ExecutionEnvironment.getExecutionEnvironment > val data: DataSet[Double] = env.fromElements(1.0, 2.0, 3.0, 4.0) > def f[T](data: DataSet[T]): DataSet[(T, Try[Seq[Double]])] = { > data.mapPartition((iterator: Iterator[T]) => { > val first = iterator.next() > val second = iterator.next() > Iterator((first, Success(Seq(2.0, 3.0))), (second, Success(Seq(3.0, > 1.0)))) > }) > } > val g = f(data) > g.print() > env.execute("Flink Test") > } -- This message was sent by Atlassian JIRA (v6.3.4#6332)