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

[devinbost]

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? 

[Piotr Nowojski-4]

Hey Devin,

Have you maybe tried looking for an answer via Google? Via just copying pasting your error message into Google I'm getting hundreds of results pointing towards:

import org.apache.flink.api.scala._

Best,

Piotrek

czw., 28 sty 2021 o 04:13 Devin Bost <[hidden email]> napisał(a):

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

[Piotr Nowojski-4]

Hey,

Sorry for my hasty response. I didn't notice you have the import inside the code block.

Have you maybe tried one of the responses suggested in the Stackoverflow by other users?

Best,

Piotrek

pon., 1 lut 2021 o 15:49 Piotr Nowojski <[hidden email]> napisał(a):

Hey Devin,

Have you maybe tried looking for an answer via Google? Via just copying pasting your error message into Google I'm getting hundreds of results pointing towards:

import org.apache.flink.api.scala._

Best,

Piotrek

czw., 28 sty 2021 o 04:13 Devin Bost <[hidden email]> napisał(a):

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