It was removed because many of the fields stored in PipelineOptions were
not really cloneable but used as a way to pass around items such as an
ExecutorService or Credentials for dependency injection reasons.

With the above caveat that your not getting a true clone, feel free to copy
the code shown in either of:
https://github.com/apache/beam/blob/master/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/utils/SerializedPipelineOptions.java
https://github.com/apache/beam/blob/master/runners/apex/src/main/java/org/apache/beam/runners/apex/translation/utils/SerializablePipelineOptions.java


On Fri, Apr 21, 2017 at 5:40 PM, Ankur Chauhan <[email protected]> wrote:

> Hi
>
> I am attempting to build a sort of a supervisor process for dataflow
> pipelines that starts up dataflow jobs based on some inputs combined with
> some common presets. I used to use the cloneAs method on the
> pipelineoptions class but noticed that if has been removed and wanted to
> ask if there was a way to sort of "serialize", "deserialize" and clone
> existing option instances for easy reusability.
>
> -- AC
>
> Sent from my iPhone

Reply via email to