A heads-up if anybody else sees this, we have removed the flag: https://jira.apache.org/jira/browse/BEAM-9900
Further contributions are very welcome :) -Max On 11.05.20 17:05, Sruthi Sree Kumar wrote: > I have opened a PR with the documentation change. > https://github.com/apache/beam/pull/11662 > > Regards, > Sruthi > > On 2020/04/21 20:22:17, Ismaël Mejía <ieme...@gmail.com> wrote: >> You need to instruct the Flink runner to shutdown the the source >> otherwise it will stay waiting. >> You can this by adding the extra >> argument`--shutdownSourcesOnFinalWatermark=true` >> And if that works and you want to open a PR to update our >> documentation that would be greatly appreciated. >> >> Regards, >> Ismaël >> >> >> On Tue, Apr 21, 2020 at 10:04 PM Sruthi Sree Kumar >> <sruthisreekumar2...@gmail.com> wrote: >>> >>> Hello, >>> >>> I am trying to run nexmark queries using flink runner streaming. Followed >>> the documentation and used the command >>> ./gradlew :sdks:java:testing:nexmark:run \ >>> >>> -Pnexmark.runner=":runners:flink:1.10" \ >>> -Pnexmark.args=" >>> --runner=FlinkRunner >>> --suite=SMOKE >>> --streamTimeout=60 >>> --streaming=true >>> --manageResources=false >>> --monitorJobs=true >>> --flinkMaster=[local]" >>> >>> >>> But after the events are read from the source, there is no further progress >>> and the job is always stuck at 99%. Is there any configuration that I am >>> missing? >>> >>> Regards, >>> Sruthi >>
