On the documentation, the version of Flink runner is changed to 1.9 which was 1.10(latest) before https://github.com/apache/beam/commit/1d2700818474c008eaa324ac1b5c49c9d2857298#diff-0e75160f4b09a1a300671557930589d9 .
Is this an accidental change or is there any particular reason for this downgrade of version? Regards, Sruthi On Tue, May 12, 2020 at 7:21 PM Maximilian Michels <m...@apache.org> wrote: > 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 > >> >
