I posted this problem on Stack Overflow here:
https://stackoverflow.com/questions/65930023/flink-importing-types-doesnt-fix-could-not-find-implicit-value-for-evidence

Basically, I can't even get a basic map to work like this:

object AmplitudeExample {
  def main(args: Array[String]) {
    import org.apache.flink.streaming.api.scala._
    import org.apache.flink.api.scala._
    val env = StreamExecutionEnvironment.getExecutionEnvironment

    val text = 
env.readTextFile("/Users/dbost/src/amplitude-flink/example-data.json")

    val partitionedEvents = text
      .map(t => t)

    partitionedEvents.print()
  }
}

I get:

could not find implicit value for evidence parameter of type
org.apache.flink.api.common.typeinfo.TypeInformation[String] .map(t =>
t)

I'm using Flink 1.12.1 and Scala 2.12. What am I missing here?

Devin G. Bost

Reply via email to