Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 15B10200B5C for ; Thu, 28 Jul 2016 06:50:10 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 14397160A93; Thu, 28 Jul 2016 04:50:10 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 5DB5B160A90 for ; Thu, 28 Jul 2016 06:50:08 +0200 (CEST) Received: (qmail 99012 invoked by uid 500); 28 Jul 2016 04:50:07 -0000 Mailing-List: contact user-help@beam.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@beam.incubator.apache.org Delivered-To: mailing list user@beam.incubator.apache.org Received: (qmail 99001 invoked by uid 99); 28 Jul 2016 04:50:07 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 28 Jul 2016 04:50:07 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 91383CDED4 for ; Thu, 28 Jul 2016 04:50:06 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.179 X-Spam-Level: * X-Spam-Status: No, score=1.179 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id LqlSAEE0UHtw for ; Thu, 28 Jul 2016 04:50:03 +0000 (UTC) Received: from mail-it0-f49.google.com (mail-it0-f49.google.com [209.85.214.49]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 038315F295 for ; Thu, 28 Jul 2016 04:50:03 +0000 (UTC) Received: by mail-it0-f49.google.com with SMTP id u186so159527978ita.0 for ; Wed, 27 Jul 2016 21:50:02 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=K0vT2J8NZuN2M/d9s/UUdrW6263It17xndfzRLLr0oQ=; b=E346AeSuqs2RhfIQkeixnAdikP0IxunAIIs6oJDMcvF3m2etdpbwhSKODWApciCYU5 RWCTBvkVm4rAPo+luNvbWsV2p8NF2tZTTcCczcv2kIVA3yNJYPa1Reih2mh4T6tDNQPu oGKpIJDtmg9/QqTq/0VzFNHDeGrQs/NCXBP2OXmOxYyyzWdxMQdnLk+ZiVGHY3+wk+ZZ aQcU9hbnxVBK7MkksZa0j8SCvryuL1RajGOirLjU049nbtC8j+72gKdR+wo/b2hWIet7 pDnSR18dLDCgKHrPAKrjiKZg5nX1uH5xQ3n/GgOOm2TFFG1Xb2RB+L1lKH4ane+56QDC /4uA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=K0vT2J8NZuN2M/d9s/UUdrW6263It17xndfzRLLr0oQ=; b=bFFFOfZWNcvqXPiK16ZWFSLbHJp8rVgwPDobFAHxUyWi6rdMzFCAiCG9qfiTuI7bW9 G+BXUVFQm1LGgQ1zk5TpdxrJRQo0mJIXJoiXdtIojp1sQQX8u9nu97m7M5fw4fV77ios 1M/WLfnF+c6nNK4Cb8VyLGC2VBfYYtyQFQfAPX5dX38WaliNClqVMEfrXCTLt5hyGgoc xK161asd/mBBd6DFbEKyP+/HsHz8Jc4sf+wRHU+O6pNUTTX7IWkFg0JFplehL3v/J6mu CSKVPUUEngfPeYF/6zNvQYXiw88aXf4/j1kqPASCWmK03Za+FE79777xTP0vD1jhhgwf IVRg== X-Gm-Message-State: ALyK8tJVOsT9d4QloBwDRo29rENf539MlpYthhj+JmARn+oFAbRmFMDfATuY8VF1a7AX42GsLgqAJ2DwZlZhZQ== X-Received: by 10.36.61.201 with SMTP id n192mr107699102itn.92.1469681401510; Wed, 27 Jul 2016 21:50:01 -0700 (PDT) MIME-Version: 1.0 Received: by 10.79.69.132 with HTTP; Wed, 27 Jul 2016 21:50:00 -0700 (PDT) In-Reply-To: References: From: Dumi Loghin Date: Thu, 28 Jul 2016 12:50:00 +0800 Message-ID: Subject: Re: Flink Wordcount example on single node "No runner was specified" To: user@beam.incubator.apache.org Content-Type: multipart/alternative; boundary=001a11444e94dec1b10538aaddc1 archived-at: Thu, 28 Jul 2016 04:50:10 -0000 --001a11444e94dec1b10538aaddc1 Content-Type: text/plain; charset=UTF-8 Hi, Here is the entire output of the command (when running mvn -e): ~/incubator-beam/runners/flink/examples$ /home/hadoop/apache-maven-3.3.9/bin/mvn -e exec:java -Dexec.mainClass=org.apache.beam.runners.flink.examples.WordCount -Dinput=/home/hadoop/kinglear.txt -Doutput=wc-out.txt [INFO] Error stacktraces are turned on. [INFO] Scanning for projects... [INFO] [INFO] ------------------------------------------------------------------------ [INFO] Building Apache Beam :: Runners :: Flink :: Examples 0.2.0-incubating-SNAPSHOT [INFO] ------------------------------------------------------------------------ [INFO] [INFO] --- exec-maven-plugin:1.4.0:java (default-cli) @ beam-runners-flink_2.10-examples --- [WARNING] java.lang.reflect.InvocationTargetException at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:293) at java.lang.Thread.run(Thread.java:745) Caused by: java.lang.RuntimeException: Pipeline execution failed at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:113) at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:48) at org.apache.beam.sdk.Pipeline.run(Pipeline.java:183) at org.apache.beam.runners.flink.examples.WordCount.main(WordCount.java:117) ... 6 more Caused by: java.util.concurrent.TimeoutException: Futures timed out after [10000 milliseconds] at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219) at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:153) at scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:86) at scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:86) at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53) at scala.concurrent.Await$.ready(package.scala:86) at org.apache.flink.runtime.minicluster.FlinkMiniCluster.shutdown(FlinkMiniCluster.scala:340) at org.apache.flink.runtime.minicluster.FlinkMiniCluster.stop(FlinkMiniCluster.scala:319) at org.apache.flink.client.LocalExecutor.stop(LocalExecutor.java:126) at org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:194) at org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:90) at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.executePipeline(FlinkPipelineExecutionEnvironment.java:116) at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:110) ... 9 more [INFO] ------------------------------------------------------------------------ [INFO] BUILD FAILURE [INFO] ------------------------------------------------------------------------ [INFO] Total time: 49.646 s [INFO] Finished at: 2016-07-28T12:44:39+08:00 [INFO] Final Memory: 34M/451M [INFO] ------------------------------------------------------------------------ [ERROR] Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.4.0:java (default-cli) on project beam-runners-flink_2.10-examples: An exception occured while executing the Java class. null: InvocationTargetException: Pipeline execution failed: Futures timed out after [10000 milliseconds] -> [Help 1] org.apache.maven.lifecycle.LifecycleExecutionException: Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.4.0:java (default-cli) on project beam-runners-flink_2.10-examples: An exception occured while executing the Java class. null at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:212) at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:153) at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:145) at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject(LifecycleModuleBuilder.java:116) at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject(LifecycleModuleBuilder.java:80) at org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build(SingleThreadedBuilder.java:51) at org.apache.maven.lifecycle.internal.LifecycleStarter.execute(LifecycleStarter.java:128) at org.apache.maven.DefaultMaven.doExecute(DefaultMaven.java:307) at org.apache.maven.DefaultMaven.doExecute(DefaultMaven.java:193) at org.apache.maven.DefaultMaven.execute(DefaultMaven.java:106) at org.apache.maven.cli.MavenCli.execute(MavenCli.java:863) at org.apache.maven.cli.MavenCli.doMain(MavenCli.java:288) at org.apache.maven.cli.MavenCli.main(MavenCli.java:199) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced(Launcher.java:289) at org.codehaus.plexus.classworlds.launcher.Launcher.launch(Launcher.java:229) at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode(Launcher.java:415) at org.codehaus.plexus.classworlds.launcher.Launcher.main(Launcher.java:356) Caused by: org.apache.maven.plugin.MojoExecutionException: An exception occured while executing the Java class. null at org.codehaus.mojo.exec.ExecJavaMojo.execute(ExecJavaMojo.java:345) at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo(DefaultBuildPluginManager.java:134) at org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.java:207) ... 20 more Caused by: java.lang.reflect.InvocationTargetException at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:293) at java.lang.Thread.run(Thread.java:745) Caused by: java.lang.RuntimeException: Pipeline execution failed at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:113) at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:48) at org.apache.beam.sdk.Pipeline.run(Pipeline.java:183) at org.apache.beam.runners.flink.examples.WordCount.main(WordCount.java:117) ... 6 more Caused by: java.util.concurrent.TimeoutException: Futures timed out after [10000 milliseconds] at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219) at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:153) at scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:86) at scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:86) at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53) at scala.concurrent.Await$.ready(package.scala:86) at org.apache.flink.runtime.minicluster.FlinkMiniCluster.shutdown(FlinkMiniCluster.scala:340) at org.apache.flink.runtime.minicluster.FlinkMiniCluster.stop(FlinkMiniCluster.scala:319) at org.apache.flink.client.LocalExecutor.stop(LocalExecutor.java:126) at org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:194) at org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:90) at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.executePipeline(FlinkPipelineExecutionEnvironment.java:116) at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:110) ... 9 more [ERROR] [ERROR] Re-run Maven using the -X switch to enable full debug logging. [ERROR] [ERROR] For more information about the errors and possible solutions, please read the following articles: [ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionException Best regards, Dumi On Wed, Jul 27, 2016 at 7:48 PM, Maximilian Michels wrote: > Okay great! > > I think it was a permission problem before. It shouldn't matter where > the file is as long as Flink can access it. Still puzzled about the > error message, was that really the entire stack trace? > > On Wed, Jul 27, 2016 at 7:05 AM, Dumi Loghin wrote: > > Hi, > > > > The application is running if the input file is in the examples folder: > > > > ~/incubator-beam/runners/flink/examples$ > > /home/hadoop/apache-maven-3.3.9/bin/mvn exec:java > > -Dexec.mainClass=org.apache.beam.runners.flink.examples.WordCount > > -Dinput=kinglear.txt -Doutput=wc-out.txt > > > > ( as opposed to "~/incubator-beam/runners/flink/examples$ > > /home/hadoop/apache-maven-3.3.9/bin/mvn exec:java > > -Dexec.mainClass=org.apache.beam.runners.flink.examples.WordCount > > -Dinput=/home/hadoop/kinglear.txt -Doutput=wc-out.txt" that is throwing > the > > exception) > > > > Best regards, > > Dumi > > > > > > > > On Tue, Jul 26, 2016 at 11:53 PM, Maximilian Michels > wrote: > >> > >> Hi Dumi, > >> > >> The execution fails during shutdown of the local Flink cluster. Does > >> the program execute before the exception occurs? > >> > >> Best, > >> Max > >> > >> On Tue, Jul 26, 2016 at 5:15 AM, Dumi Loghin > wrote: > >> > Hi, > >> > > >> > Thank you! > >> > > >> > I have manually added WordCount.java and pom.xml to the latest Beam > code > >> > and > >> > try to run it. But now I'm getting the following exception: > >> > > >> > :~/incubator-beam/runners/flink/examples$ > >> > /home/hadoop/apache-maven-3.3.9/bin/mvn exec:java > >> > -Dexec.mainClass=org.apache.beam.runners.flink.examples.WordCount > >> > -Dinput=/home/hadoop/kinglear.txt -Doutput=wc-out.txt > >> > > >> > java.lang.reflect.InvocationTargetException > >> > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > >> > at > >> > > >> > > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) > >> > at > >> > > >> > > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > >> > at java.lang.reflect.Method.invoke(Method.java:606) > >> > at > >> > org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:293) > >> > at java.lang.Thread.run(Thread.java:745) > >> > Caused by: java.lang.RuntimeException: Pipeline execution failed > >> > at > >> > org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:113) > >> > at > >> > org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:48) > >> > at org.apache.beam.sdk.Pipeline.run(Pipeline.java:183) > >> > at > >> > > >> > > org.apache.beam.runners.flink.examples.WordCount.main(WordCount.java:117) > >> > ... 6 more > >> > Caused by: java.util.concurrent.TimeoutException: Futures timed out > >> > after > >> > [10000 milliseconds] > >> > at > >> > scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219) > >> > at > >> > scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:153) > >> > at > >> > scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:86) > >> > at > >> > scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:86) > >> > at > >> > > >> > > scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53) > >> > at scala.concurrent.Await$.ready(package.scala:86) > >> > at > >> > > >> > > org.apache.flink.runtime.minicluster.FlinkMiniCluster.shutdown(FlinkMiniCluster.scala:340) > >> > at > >> > > >> > > org.apache.flink.runtime.minicluster.FlinkMiniCluster.stop(FlinkMiniCluster.scala:319) > >> > at > >> > org.apache.flink.client.LocalExecutor.stop(LocalExecutor.java:126) > >> > at > >> > > >> > > org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:194) > >> > at > >> > > >> > > org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:90) > >> > at > >> > > >> > > org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.executePipeline(FlinkPipelineExecutionEnvironment.java:116) > >> > at > >> > org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:110) > >> > ... 9 more > >> > > >> > Best regards, > >> > Dumi > >> > > >> > On Mon, Jul 25, 2016 at 7:14 PM, Maximilian Michels > >> > wrote: > >> >> > >> >> Hi Dumi, > >> >> > >> >> Somewhere on the way we broke the exec configuration. I've fixed this > >> >> in this PR and updated the README: > >> >> https://github.com/apache/incubator-beam/pull/724 > >> >> > >> >> Should be merged soon. > >> >> > >> >> Best, > >> >> Max > >> >> > >> >> On Fri, Jul 22, 2016 at 2:49 PM, Lukasz Cwik > wrote: > >> >> > I think runner should be org.apache.beam.runners.flink.FlinkRunner > >> >> > and > >> >> > not > >> >> > org.apache.beam.runners.flink.FlinkRunner.class but that is > probably > >> >> > unrelated to the failure that you are seeing. > >> >> > > >> >> > On Fri, Jul 22, 2016 at 7:42 AM, Dumi Loghin > > >> >> > wrote: > >> >> >> > >> >> >> Hi, > >> >> >> > >> >> >> I'm still getting an exception related to arguments. I mention > that > >> >> >> I'm > >> >> >> working with commit adb472083460bc175a0685133eadb6a336f1a4a2 (22 > >> >> >> Jul). > >> >> >> > >> >> >> ~/incubator-beam/runners/flink/examples$ mvn exec:java > >> >> >> -Dexec.mainClass=org.apache.beam.runners.flink.examples.WordCount > >> >> >> > >> >> >> > -Dexec.args="--runner=org.apache.beam.runners.flink.FlinkRunner.class > >> >> >> --inputFile=/home/hadoop/kinglear.txt --output=wc-out.txt" > >> >> >> ... > >> >> >> [ERROR] Failed to execute goal > >> >> >> org.codehaus.mojo:exec-maven-plugin:1.4.0:java (default-cli) on > >> >> >> project > >> >> >> beam-runners-flink_2.10-examples: Unable to parse configuration of > >> >> >> mojo > >> >> >> org.codehaus.mojo:exec-maven-plugin:1.4.0:java for parameter > >> >> >> arguments: > >> >> >> Cannot store value into array: ArrayStoreException -> [Help 1] > >> >> >> ... > >> >> >> > >> >> >> However, I was able to run it in early June. If I revert to, for > >> >> >> example, > >> >> >> commit c2146b9f9d6a1f39a5699725ccb51829d751b88a (6 Jun) I'm not > >> >> >> getting > >> >> >> the > >> >> >> above exceptions. Maybe something changed in the options > (arguments) > >> >> >> handling code? > >> >> >> > >> >> >> Best regards, > >> >> >> Dumi > >> >> >> > >> >> >> On Wed, Jul 20, 2016 at 7:35 PM, Aljoscha Krettek > >> >> >> > >> >> >> wrote: > >> >> >>> > >> >> >>> I think it should work like this: > >> >> >>> > >> >> >>> mvn exec:java \ > >> >> >>> > -Dexec.mainClass=org.apache.beam.runners.flink.examples.WordCount \ > >> >> >>> > >> >> >>> > -Dexec.args="--runner=org.apache.beam.runners.flink.FlinkRunner.class > >> >> >>> --inputFile='"$input"' --output='"$outfile_prefix"'"' > >> >> >>> > >> >> >>> On Wed, 20 Jul 2016 at 10:47 Dumi Loghin > >> >> >>> wrote: > >> >> >>>> > >> >> >>>> Hi, > >> >> >>>> > >> >> >>>> I'm trying to run Wordcount example on Flink single node but I'm > >> >> >>>> getting > >> >> >>>> this error: > >> >> >>>> > >> >> >>>> ~/incubator-beam/runners/flink/examples$ mvn exec:exec > >> >> >>>> -Dinput=/home/hadoop/kinglear.txt -Doutput=wc-out.txt > >> >> >>>> -Drunner=FlinkRunner > >> >> >>>> ... > >> >> >>>> Exception in thread "main" java.lang.IllegalArgumentException: > No > >> >> >>>> Runner > >> >> >>>> was specified and the DirectRunner was not found on the > classpath. > >> >> >>>> Specify a runner by either: > >> >> >>>> Explicitly specifying a runner by providing the 'runner' > >> >> >>>> property > >> >> >>>> Adding the DirectRunner to the classpath > >> >> >>>> Calling 'PipelineOptions.setRunner(PipelineRunner)' directly > >> >> >>>> at > >> >> >>>> > >> >> >>>> > >> >> >>>> > org.apache.beam.sdk.options.PipelineOptions$DirectRunner.create(PipelineOptions.java:282) > >> >> >>>> at > >> >> >>>> > >> >> >>>> > >> >> >>>> > org.apache.beam.sdk.options.PipelineOptions$DirectRunner.create(PipelineOptions.java:273) > >> >> >>>> at > >> >> >>>> > >> >> >>>> > >> >> >>>> > org.apache.beam.sdk.options.ProxyInvocationHandler.getDefault(ProxyInvocationHandler.java:482) > >> >> >>>> at > >> >> >>>> > >> >> >>>> > >> >> >>>> > org.apache.beam.sdk.options.ProxyInvocationHandler.invoke(ProxyInvocationHandler.java:157) > >> >> >>>> at > >> >> >>>> > >> >> >>>> > >> >> >>>> > org.apache.beam.sdk.options.PipelineOptionsValidator.validate(PipelineOptionsValidator.java:72) > >> >> >>>> at > >> >> >>>> > >> >> >>>> > >> >> >>>> > org.apache.beam.sdk.options.PipelineOptionsFactory$Builder.as(PipelineOptionsFactory.java:306) > >> >> >>>> at > >> >> >>>> > >> >> >>>> > >> >> >>>> > org.apache.beam.runners.flink.examples.WordCount.main(WordCount.java:106) > >> >> >>>> ... > >> >> >>>> > >> >> >>>> > >> >> >>>> I've tried with -Drunner=FlinkRunner and without it and I get > the > >> >> >>>> same > >> >> >>>> error. Moreover, the runner is also set in the source: > >> >> >>>> > >> >> >>>> options.setRunner(FlinkRunner.class); > >> >> >>>> > >> >> >>>> Any suggestions? > >> >> >>>> > >> >> >>>> Best regards, > >> >> >>>> Dumi > >> >> >> > >> >> >> > >> >> > > >> > > >> > > > > > > --001a11444e94dec1b10538aaddc1 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi,

Here is the entire output of the co= mmand (when running mvn -e):

~/incubator-beam= /runners/flink/examples$ /home/hadoop/apache-maven-3.3.9/bin/mvn -e exec:ja= va -Dexec.mainClass=3Dorg.apache.beam.runners.flink.examples.WordCount -Din= put=3D/home/hadoop/kinglear.txt -Doutput=3Dwc-out.txt
[INFO] Erro= r stacktraces are turned on.
[INFO] Scanning for projects...
[INFO]
[INFO] ---------------------------------------------= ---------------------------
[INFO] Building Apache Beam :: Runner= s :: Flink :: Examples 0.2.0-incubating-SNAPSHOT
[INFO] ---------= ---------------------------------------------------------------
[= INFO]
[INFO] --- exec-maven-plugin:1.4.0:java (default-cli) @ bea= m-runners-flink_2.10-examples ---
[WARNING]
java.lang.r= eflect.InvocationTargetException
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at s= un.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
=C2=A0= =C2=A0 =C2=A0 =C2=A0 at sun.reflect.NativeMethodAccessorImpl.invoke(Native= MethodAccessorImpl.java:57)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at sun.re= flect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java= :43)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.lang.reflect.Method.invo= ke(Method.java:606)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.codehaus.m= ojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:293)
=C2=A0 =C2=A0 = =C2=A0 =C2=A0 at java.lang.Thread.run(Thread.java:745)
Caused by:= java.lang.RuntimeException: Pipeline execution failed
=C2=A0 =C2= =A0 =C2=A0 =C2=A0 at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRun= ner.java:113)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.beam.runn= ers.flink.FlinkRunner.run(FlinkRunner.java:48)
=C2=A0 =C2=A0 =C2= =A0 =C2=A0 at org.apache.beam.sdk.Pipeline.run(Pipeline.java:183)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.beam.runners.flink.examples.Word= Count.main(WordCount.java:117)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 ... 6 = more
Caused by: java.util.concurrent.TimeoutException: Futures ti= med out after [10000 milliseconds]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at= scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at scala.concurrent.impl.Promise$DefaultP= romise.ready(Promise.scala:153)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at sc= ala.concurrent.Await$$anonfun$ready$1.apply(package.scala:86)
=C2= =A0 =C2=A0 =C2=A0 =C2=A0 at scala.concurrent.Await$$anonfun$ready$1.apply(p= ackage.scala:86)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at scala.concurrent.= BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
= =C2=A0 =C2=A0 =C2=A0 =C2=A0 at scala.concurrent.Await$.ready(package.scala:= 86)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.runtime.minic= luster.FlinkMiniCluster.shutdown(FlinkMiniCluster.scala:340)
=C2= =A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.runtime.minicluster.FlinkMiniC= luster.stop(FlinkMiniCluster.scala:319)
=C2=A0 =C2=A0 =C2=A0 =C2= =A0 at org.apache.flink.client.LocalExecutor.stop(LocalExecutor.java:126)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.client.LocalExecut= or.executePlan(LocalExecutor.java:194)
=C2=A0 =C2=A0 =C2=A0 =C2= =A0 at org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.= java:90)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.beam.runners.f= link.FlinkPipelineExecutionEnvironment.executePipeline(FlinkPipelineExecuti= onEnvironment.java:116)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache= .beam.runners.flink.FlinkRunner.run(FlinkRunner.java:110)
=C2=A0 = =C2=A0 =C2=A0 =C2=A0 ... 9 more
[INFO] --------------------------= ----------------------------------------------
[INFO] BUILD FAILU= RE
[INFO] -------------------------------------------------------= -----------------
[INFO] Total time: 49.646 s
[INFO] Fi= nished at: 2016-07-28T12:44:39+08:00
[INFO] Final Memory: 34M/451= M
[INFO] --------------------------------------------------------= ----------------
[ERROR] Failed to execute goal org.codehaus.mojo= :exec-maven-plugin:1.4.0:java (default-cli) on project beam-runners-flink_2= .10-examples: An exception occured while executing the Java class. null: In= vocationTargetException: Pipeline execution failed: Futures timed out after= [10000 milliseconds] -> [Help 1]
org.apache.maven.lifecycle.L= ifecycleExecutionException: Failed to execute goal org.codehaus.mojo:exec-m= aven-plugin:1.4.0:java (default-cli) on project beam-runners-flink_2.10-exa= mples: An exception occured while executing the Java class. null
= =C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.maven.lifecycle.internal.MojoExec= utor.execute(MojoExecutor.java:212)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 a= t org.apache.maven.lifecycle.internal.MojoExecutor.execute(MojoExecutor.jav= a:153)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.maven.lifecycle.= internal.MojoExecutor.execute(MojoExecutor.java:145)
=C2=A0 =C2= =A0 =C2=A0 =C2=A0 at org.apache.maven.lifecycle.internal.LifecycleModuleBui= lder.buildProject(LifecycleModuleBuilder.java:116)
=C2=A0 =C2=A0 = =C2=A0 =C2=A0 at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder= .buildProject(LifecycleModuleBuilder.java:80)
=C2=A0 =C2=A0 =C2= =A0 =C2=A0 at org.apache.maven.lifecycle.internal.builder.singlethreaded.Si= ngleThreadedBuilder.build(SingleThreadedBuilder.java:51)
=C2=A0 = =C2=A0 =C2=A0 =C2=A0 at org.apache.maven.lifecycle.internal.LifecycleStarte= r.execute(LifecycleStarter.java:128)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 = at org.apache.maven.DefaultMaven.doExecute(DefaultMaven.java:307)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.maven.DefaultMaven.doExecute(Def= aultMaven.java:193)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.mav= en.DefaultMaven.execute(DefaultMaven.java:106)
=C2=A0 =C2=A0 =C2= =A0 =C2=A0 at org.apache.maven.cli.MavenCli.execute(MavenCli.java:863)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.maven.cli.MavenCli.doMain(M= avenCli.java:288)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.maven= .cli.MavenCli.main(MavenCli.java:199)
=C2=A0 =C2=A0 =C2=A0 =C2=A0= at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
= =C2=A0 =C2=A0 =C2=A0 =C2=A0 at sun.reflect.NativeMethodAccessorImpl.invoke(= NativeMethodAccessorImpl.java:57)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at = sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImp= l.java:43)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.lang.reflect.Metho= d.invoke(Method.java:606)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.code= haus.plexus.classworlds.launcher.Launcher.launchEnhanced(Launcher.java:289)=
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.codehaus.plexus.classworlds.l= auncher.Launcher.launch(Launcher.java:229)
=C2=A0 =C2=A0 =C2=A0 = =C2=A0 at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCod= e(Launcher.java:415)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.codehaus.= plexus.classworlds.launcher.Launcher.main(Launcher.java:356)
Caus= ed by: org.apache.maven.plugin.MojoExecutionException: An exception occured= while executing the Java class. null
=C2=A0 =C2=A0 =C2=A0 =C2=A0= at org.codehaus.mojo.exec.ExecJavaMojo.execute(ExecJavaMojo.java:345)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.maven.plugin.DefaultBuildPl= uginManager.executeMojo(DefaultBuildPluginManager.java:134)
=C2= =A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.maven.lifecycle.internal.MojoExecuto= r.execute(MojoExecutor.java:207)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 ... = 20 more
Caused by: java.lang.reflect.InvocationTargetException
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at sun.reflect.NativeMethodAccessorImpl= .invoke0(Native Method)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at sun.reflec= t.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at sun.reflect.DelegatingMethodAccessorImpl.= invoke(DelegatingMethodAccessorImpl.java:43)
=C2=A0 =C2=A0 =C2=A0= =C2=A0 at java.lang.reflect.Method.invoke(Method.java:606)
=C2= =A0 =C2=A0 =C2=A0 =C2=A0 at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJ= avaMojo.java:293)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.lang.Thread= .run(Thread.java:745)
Caused by: java.lang.RuntimeException: Pipe= line execution failed
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.b= eam.runners.flink.FlinkRunner.run(FlinkRunner.java:113)
=C2=A0 = =C2=A0 =C2=A0 =C2=A0 at org.apache.beam.runners.flink.FlinkRunner.run(Flink= Runner.java:48)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.beam.sd= k.Pipeline.run(Pipeline.java:183)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at = org.apache.beam.runners.flink.examples.WordCount.main(WordCount.java:117)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 ... 6 more
Caused by: java.u= til.concurrent.TimeoutException: Futures timed out after [10000 millisecond= s]
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at scala.concurrent.impl.Promise$D= efaultPromise.ready(Promise.scala:219)
=C2=A0 =C2=A0 =C2=A0 =C2= =A0 at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:153= )
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at scala.concurrent.Await$$anonfun$= ready$1.apply(package.scala:86)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at sc= ala.concurrent.Await$$anonfun$ready$1.apply(package.scala:86)
=C2= =A0 =C2=A0 =C2=A0 =C2=A0 at scala.concurrent.BlockContext$DefaultBlockConte= xt$.blockOn(BlockContext.scala:53)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at= scala.concurrent.Await$.ready(package.scala:86)
=C2=A0 =C2=A0 = =C2=A0 =C2=A0 at org.apache.flink.runtime.minicluster.FlinkMiniCluster.shut= down(FlinkMiniCluster.scala:340)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at o= rg.apache.flink.runtime.minicluster.FlinkMiniCluster.stop(FlinkMiniCluster.= scala:319)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.client= .LocalExecutor.stop(LocalExecutor.java:126)
=C2=A0 =C2=A0 =C2=A0 = =C2=A0 at org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.j= ava:194)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.api.java= .LocalEnvironment.execute(LocalEnvironment.java:90)
=C2=A0 =C2=A0= =C2=A0 =C2=A0 at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvir= onment.executePipeline(FlinkPipelineExecutionEnvironment.java:116)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.beam.runners.flink.FlinkRunner.= run(FlinkRunner.java:110)
=C2=A0 =C2=A0 =C2=A0 =C2=A0 ... 9 more<= /div>
[ERROR]
[ERROR] Re-run Maven using the -X switch to ena= ble full debug logging.
[ERROR]
[ERROR] For more inform= ation about the errors and possible solutions, please read the following ar= ticles:

Best regards,
Dumi

On Wed, Jul 27, 2016 at 7:48 PM, Maximilian Michels= <= mxm@apache.org> wrote:
Okay= great!

I think it was a permission problem before. It shouldn't matter where the file is as long as Flink can access it. Still puzzled about the
error message, was that really the entire stack trace?

On Wed, Jul 27, 2016 at 7:05 AM, Dumi Loghin <dumiloghin@gmail.com> wrote:
> Hi,
>
> The application is running if the input file is in the examples folder= :
>
> ~/incubator-beam/runners/flink/examples$
> /home/hadoop/apache-maven-3.3.9/bin/mvn exec:java
> -Dexec.mainClass=3Dorg.apache.beam.runners.flink.examples.WordCount > -Dinput=3Dkinglear.txt -Doutput=3Dwc-out.txt
>
> ( as opposed to "~/incubator-beam/runners/flink/examples$
> /home/hadoop/apache-maven-3.3.9/bin/mvn exec:java
> -Dexec.mainClass=3Dorg.apache.beam.runners.flink.examples.WordCount > -Dinput=3D/home/hadoop/kinglear.txt -Doutput=3Dwc-out.txt" that i= s throwing the
> exception)
>
> Best regards,
> Dumi
>
>
>
> On Tue, Jul 26, 2016 at 11:53 PM, Maximilian Michels <mxm@apache.org> wrote:
>>
>> Hi Dumi,
>>
>> The execution fails during shutdown of the local Flink cluster. Do= es
>> the program execute before the exception occurs?
>>
>> Best,
>> Max
>>
>> On Tue, Jul 26, 2016 at 5:15 AM, Dumi Loghin <dumiloghin@gmail.com> wrote:
>> > Hi,
>> >
>> > Thank you!
>> >
>> > I have manually added WordCount.java and pom.xml to the lates= t Beam code
>> > and
>> > try to run it. But now I'm getting the following exceptio= n:
>> >
>> > :~/incubator-beam/runners/flink/examples$
>> > /home/hadoop/apache-maven-3.3.9/bin/mvn exec:java
>> > -Dexec.mainClass=3Dorg.apache.beam.runners.flink.examples.Wor= dCount
>> > -Dinput=3D/home/hadoop/kinglear.txt -Doutput=3Dwc-out.txt
>> >
>> > java.lang.reflect.InvocationTargetException
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at sun.reflect.NativeMethodA= ccessorImpl.invoke0(Native Method)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> >
>> > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAcces= sorImpl.java:57)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> >
>> > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMet= hodAccessorImpl.java:43)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at java.lang.reflect.Method.= invoke(Method.java:606)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> > org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:2= 93)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at java.lang.Thread.run(Thre= ad.java:745)
>> > Caused by: java.lang.RuntimeException: Pipeline execution fai= led
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> > org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.jav= a:113)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> > org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.jav= a:48)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at org.apache.beam.sdk.Pipel= ine.run(Pipeline.java:183)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> >
>> > org.apache.beam.runners.flink.examples.WordCount.main(WordCou= nt.java:117)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0... 6 more
>> > Caused by: java.util.concurrent.TimeoutException: Futures tim= ed out
>> > after
>> > [10000 milliseconds]
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> > scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.sc= ala:219)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> > scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.sc= ala:153)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> > scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:8= 6)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> > scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:8= 6)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> >
>> > scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(Bl= ockContext.scala:53)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at scala.concurrent.Await$.r= eady(package.scala:86)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> >
>> > org.apache.flink.runtime.minicluster.FlinkMiniCluster.shutdow= n(FlinkMiniCluster.scala:340)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> >
>> > org.apache.flink.runtime.minicluster.FlinkMiniCluster.stop(Fl= inkMiniCluster.scala:319)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> > org.apache.flink.client.LocalExecutor.stop(LocalExecutor.java= :126)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> >
>> > org.apache.flink.client.LocalExecutor.executePlan(LocalExecut= or.java:194)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> >
>> > org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvir= onment.java:90)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> >
>> > org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironme= nt.executePipeline(FlinkPipelineExecutionEnvironment.java:116)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0at
>> > org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.jav= a:110)
>> >=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0... 9 more
>> >
>> > Best regards,
>> > Dumi
>> >
>> > On Mon, Jul 25, 2016 at 7:14 PM, Maximilian Michels <mxm@apache.org>
>> > wrote:
>> >>
>> >> Hi Dumi,
>> >>
>> >> Somewhere on the way we broke the exec configuration. I&#= 39;ve fixed this
>> >> in this PR and updated the README:
>> >> https://github.com/apache/incubat= or-beam/pull/724
>> >>
>> >> Should be merged soon.
>> >>
>> >> Best,
>> >> Max
>> >>
>> >> On Fri, Jul 22, 2016 at 2:49 PM, Lukasz Cwik <lcwik@google.com> wrote:
>> >> > I think runner should be org.apache.beam.runners.fli= nk.FlinkRunner
>> >> > and
>> >> > not
>> >> > org.apache.beam.runners.flink.FlinkRunner.class but = that is probably
>> >> > unrelated to the failure that you are seeing.
>> >> >
>> >> > On Fri, Jul 22, 2016 at 7:42 AM, Dumi Loghin <dumiloghin@gmail.com>
>> >> > wrote:
>> >> >>
>> >> >> Hi,
>> >> >>
>> >> >> I'm still getting an exception related to ar= guments. I mention that
>> >> >> I'm
>> >> >> working with commit adb472083460bc175a0685133ead= b6a336f1a4a2 (22
>> >> >> Jul).
>> >> >>
>> >> >> ~/incubator-beam/runners/flink/examples$ mvn exe= c:java
>> >> >> -Dexec.mainClass=3Dorg.apache.beam.runners.flink= .examples.WordCount
>> >> >>
>> >> >> -Dexec.args=3D"--runner=3Dorg.apache.beam.r= unners.flink.FlinkRunner.class
>> >> >> --inputFile=3D/home/hadoop/kinglear.txt --output= =3Dwc-out.txt"
>> >> >> ...
>> >> >> [ERROR] Failed to execute goal
>> >> >> org.codehaus.mojo:exec-maven-plugin:1.4.0:java (= default-cli) on
>> >> >> project
>> >> >> beam-runners-flink_2.10-examples: Unable to pars= e configuration of
>> >> >> mojo
>> >> >> org.codehaus.mojo:exec-maven-plugin:1.4.0:java f= or parameter
>> >> >> arguments:
>> >> >> Cannot store value into array: ArrayStoreExcepti= on -> [Help 1]
>> >> >> ...
>> >> >>
>> >> >> However, I was able to run it in early June. If = I revert to, for
>> >> >> example,
>> >> >> commit c2146b9f9d6a1f39a5699725ccb51829d751b88a = (6 Jun) I'm not
>> >> >> getting
>> >> >> the
>> >> >> above exceptions. Maybe something changed in the= options (arguments)
>> >> >> handling code?
>> >> >>
>> >> >> Best regards,
>> >> >> Dumi
>> >> >>
>> >> >> On Wed, Jul 20, 2016 at 7:35 PM, Aljoscha Krette= k
>> >> >> <aljos= cha@apache.org>
>> >> >> wrote:
>> >> >>>
>> >> >>> I think it should work like this:
>> >> >>>
>> >> >>> mvn exec:java \
>> >> >>> -Dexec.mainClass=3Dorg.apache.beam.runners.f= link.examples.WordCount \
>> >> >>>
>> >> >>> -Dexec.args=3D"--runner=3Dorg.apache.be= am.runners.flink.FlinkRunner.class
>> >> >>> --inputFile=3D'"$input"' -= -output=3D'"$outfile_prefix"'"'
>> >> >>>
>> >> >>> On Wed, 20 Jul 2016 at 10:47 Dumi Loghin <= ;dumiloghin@gmail.com>
>> >> >>> wrote:
>> >> >>>>
>> >> >>>> Hi,
>> >> >>>>
>> >> >>>> I'm trying to run Wordcount example = on Flink single node but I'm
>> >> >>>> getting
>> >> >>>> this error:
>> >> >>>>
>> >> >>>> ~/incubator-beam/runners/flink/examples$= mvn exec:exec
>> >> >>>> -Dinput=3D/home/hadoop/kinglear.txt -Dou= tput=3Dwc-out.txt
>> >> >>>> -Drunner=3DFlinkRunner
>> >> >>>> ...
>> >> >>>> Exception in thread "main" jav= a.lang.IllegalArgumentException: No
>> >> >>>> Runner
>> >> >>>> was specified and the DirectRunner was n= ot found on the classpath.
>> >> >>>> Specify a runner by either:
>> >> >>>>=C2=A0 =C2=A0 =C2=A0Explicitly specifying= a runner by providing the 'runner'
>> >> >>>> property
>> >> >>>>=C2=A0 =C2=A0 =C2=A0Adding the DirectRunn= er to the classpath
>> >> >>>>=C2=A0 =C2=A0 =C2=A0Calling 'Pipeline= Options.setRunner(PipelineRunner)' directly
>> >> >>>> at
>> >> >>>>
>> >> >>>>
>> >> >>>> org.apache.beam.sdk.options.PipelineOpti= ons$DirectRunner.create(PipelineOptions.java:282)
>> >> >>>> at
>> >> >>>>
>> >> >>>>
>> >> >>>> org.apache.beam.sdk.options.PipelineOpti= ons$DirectRunner.create(PipelineOptions.java:273)
>> >> >>>> at
>> >> >>>>
>> >> >>>>
>> >> >>>> org.apache.beam.sdk.options.ProxyInvocat= ionHandler.getDefault(ProxyInvocationHandler.java:482)
>> >> >>>> at
>> >> >>>>
>> >> >>>>
>> >> >>>> org.apache.beam.sdk.options.ProxyInvocat= ionHandler.invoke(ProxyInvocationHandler.java:157)
>> >> >>>> at
>> >> >>>>
>> >> >>>>
>> >> >>>> org.apache.beam.sdk.options.PipelineOpti= onsValidator.validate(PipelineOptionsValidator.java:72)
>> >> >>>> at
>> >> >>>>
>> >> >>>>
>> >> >>>> org.apache.beam.sdk.options.PipelineOpti= onsFactory$Builder.as(PipelineOptionsFactory.java:306)
>> >> >>>> at
>> >> >>>>
>> >> >>>>
>> >> >>>> org.apache.beam.runners.flink.examples.W= ordCount.main(WordCount.java:106)
>> >> >>>> ...
>> >> >>>>
>> >> >>>>
>> >> >>>> I've tried with -Drunner=3DFlinkRunn= er and without it and I get the
>> >> >>>> same
>> >> >>>> error. Moreover, the runner is also set = in the source:
>> >> >>>>
>> >> >>>> options.setRunner(FlinkRunner.class); >> >> >>>>
>> >> >>>> Any suggestions?
>> >> >>>>
>> >> >>>> Best regards,
>> >> >>>> Dumi
>> >> >>
>> >> >>
>> >> >
>> >
>> >
>
>

--001a11444e94dec1b10538aaddc1--