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 <[email protected]> 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 > <[email protected]> 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 >
