flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Run scala.App on Cluster
Date Wed, 10 Jun 2015 20:28:09 GMT
Hi,

use ./bin/flink run -c your.MainClass yourJar to specify the Main class.
Check the documentation of the CLI client for details.

Cheers, Fabian
On Jun 10, 2015 22:24, "Felix Neutatz" <neutatz@googlemail.com> wrote:

> Hi,
>
> I try to run this Scala program:
>
> https://github.com/FelixNeutatz/wikiTrends/blob/master/extraction/src/main/scala/io/sanfran/wikiTrends/extraction/flink/DownloadTopKPages.scala
> on a cluster.
>
> I tried this command:
>
> /share/flink/flink-0.9-SNAPSHOT/bin/flink run
> /home/neutatz/jars/extraction-1.0-SNAPSHOT.jar
> io.sanfran.wikiTrends.extraction.flink.DownloadTopKPages
>
> org.apache.flink.client.program.ProgramInvocationException: Neither a
> 'Main-Class', nor a 'program-class' entry was found in the jar file.
> at
>
> org.apache.flink.client.program.PackagedProgram.getEntryPointClassNameFromJar(PackagedProgram.java:501)
> at
>
> org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:134)
> at
>
> org.apache.flink.client.program.PackagedProgram.<init>(PackagedProgram.java:102)
> at org.apache.flink.client.CliFrontend.buildProgram(CliFrontend.java:654)
> at org.apache.flink.client.CliFrontend.run(CliFrontend.java:256)
> at
> org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:880)
> at org.apache.flink.client.CliFrontend.main(CliFrontend.java:922)
>
> Do I have to change my Scala program or can I use another command?
>
> Thank you for your help,
> Felix
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message