Hi Yu,

   I tried WordCount and the attached test, it should be able to run normally 
in my IDEA. Could you have a check of the imported project, or reimport the 
project if there are still problems ? 

Best,
Yun
 ------------------Original Mail ------------------
Sender:Yu Wang <yuwang0...@gmail.com>
Send Date:Tue Jun 23 15:51:27 2020
Recipients:Yun Gao <yungao...@aliyun.com>
CC:User <user@flink.apache.org>
Subject:Re: TypeInformation not found

thanks  Yun Gao!have added "import org.apache.flink.api.scala._", I just to run 
wordcount in idea .



On Tue, Jun 23, 2020 at 11:16 AM Yun Gao <yungao...@aliyun.com> wrote:

Hi yu,

    Have you add "import org.apache.flink.api.scala._"? It seems should be ok 
if the import has been added in the program:

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

object Test {
  def main(args: Array[String]): Unit = {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    val solutionInput = env.fromElements((1, "1"))
    solutionInput.print()
    env.execute()
  }
}


Best,
Yun





 ------------------Original Mail ------------------
Sender:王宇 <yuwang0...@gmail.com>
Send Date:Tue Jun 23 09:42:47 2020
Recipients:User <user@flink.apache.org>
Subject:No Subject

Hi, all
     some error occurred when I run flink in minicluster, 
flink-version:1.11、scala-version:2.12.0.

Error:(33, 41) could not find implicit value for evidence parameter of type 
org.apache.flink.api.common.typeinfo.TypeInformation[(Int, String)]
    val solutionInput = env.fromElements((1, "1"))
Error:(33, 41) not enough arguments for method fromElements: (implicit 
evidence$14: scala.reflect.ClassTag[(Int, String)], implicit evidence$15: 
org.apache.flink.api.common.typeinfo.TypeInformation[(Int, 
String)])org.apache.flink.api.scala.DataSet[(Int, String)].
Unspecified value parameter evidence$15.
    val solutionInput = env.fromElements((1, "1"))
Error:(34, 40) could not find implicit value for evidence parameter of type 
org.apache.flink.api.common.typeinfo.TypeInformation[(Int, String)]
    val worksetInput = env.fromElements((2, "2"))
Error:(34, 40) not enough arguments for method fromElements: (implicit 
evidence$14: scala.reflect.ClassTag[(Int, String)], implicit evidence$15: 
org.apache.flink.api.common.typeinfo.TypeInformation[(Int, 
String)])org.apache.flink.api.scala.DataSet[(Int, String)].
Unspecified value parameter evidence$15.
    val worksetInput = env.fromElements((2, "2"))
Error:(47, 41) could not find implicit value for evidence parameter of type 
org.apache.flink.api.common.typeinfo.TypeInformation[(Int, String)]
    val solutionInput = env.fromElements((1, "1"))

have tried 
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/types_serialization.html#type-information-in-the-scala-api

thanks

Reply via email to