(DEPRECATED) Apache Flink User Mailing List archive.

(no subject)

classic Classic list List threaded Threaded
♦
♦
 5 messages Options
王宇
Reply | Threaded
Open this post in threaded view
♦
♦
|

(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"))


thanks
Yun Gao
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: TypeInformation not found

Yun Gao
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:王宇 <[hidden email]>
Send Date:Tue Jun 23 09:42:47 2020
Recipients:User <[hidden email]>
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"))


thanks
王宇
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: TypeInformation not found

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

image.png

On Tue, Jun 23, 2020 at 11:16 AM Yun Gao <[hidden email]> 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:王宇 <[hidden email]>
Send Date:Tue Jun 23 09:42:47 2020
Recipients:User <[hidden email]>
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"))


thanks
Yun Gao
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re: Re: TypeInformation not found

Yun Gao
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 <[hidden email]>
Send Date:Tue Jun 23 15:51:27 2020
Recipients:Yun Gao <[hidden email]>
CC:User <[hidden email]>
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 <[hidden email]> 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:王宇 <[hidden email]>
Send Date:Tue Jun 23 09:42:47 2020
Recipients:User <[hidden email]>
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"))


thanks
Arvid Heise-3
Reply | Threaded
Open this post in threaded view
♦
♦
|

Re:

Arvid Heise-3
In reply to this post by 王宇
Hi,

your error matches what I see when I forget to import 
import org.apache.flink.api.scala._
Could you please double-check and if you did that post a (minimal) example?

Best,

Arvid

On Tue, Jun 23, 2020 at 3:42 AM 王宇 <[hidden email]> wrote:
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"))


thanks


--

Arvid Heise | Senior Java Developer


Follow us @VervericaData

--

Join Flink Forward - The Apache Flink Conference

Stream Processing | Event Driven | Real Time

--

Ververica GmbH | Invalidenstrasse 115, 10115 Berlin, Germany

--

Ververica GmbH
Registered at Amtsgericht Charlottenburg: HRB 158244 B
Managing Directors: Timothy Alexander Steinert, Yip Park Tung Jason, Ji (Toni) Cheng   
Free forum by Nabble Edit this page