I don't think this will require Beam to have its own configuration option. You should be able to set the property "pipeline.closure-cleaner-level" in your flink.conf and then pass it to Beam using Beam's "--flink-conf-dir" pipeline option.
On Tue, Apr 6, 2021 at 2:28 PM Raman Gupta <[email protected]> wrote: > Hello all: I created https://issues.apache.org/jira/browse/BEAM-12055 > because I'm having an issue with using the Flink runner locally, due to > https://issues.apache.org/jira/browse/FLINK-15773. > > Does anyone see any reason why Beam's Flink runner should not provide a > configuration option that can disable the Flink closure cleaner? I'm not > familiar with this myself, and the only reason I would use it is as a > work-around for FLINK-15773 in my local dev environment. > > Regards, > Raman > >
