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