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
