importing types doesn't fix “could not find implicit value for evidence parameter of type …TypeInformation”

Posted by devinbost on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/importing-types-doesn-t-fix-could-not-find-implicit-value-for-evidence-parameter-of-type-TypeInforma-tp41043.html

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?