diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestPipeline.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestPipeline.java index f2729e976a55..0955b4e42207 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestPipeline.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestPipeline.java @@ -350,12 +350,9 @@ public PipelineResult run(PipelineOptions options) { final PipelineResult pipelineResult; try { enforcement.get().beforePipelineExecution(); - PipelineOptions updatedOptions = - MAPPER.convertValue(MAPPER.valueToTree(options), PipelineOptions.class); - updatedOptions - .as(TestValueProviderOptions.class) + options.as(TestValueProviderOptions.class) .setProviderRuntimeValues(StaticValueProvider.of(providerRuntimeValues)); - pipelineResult = super.run(updatedOptions); + pipelineResult = super.run(options); verifyPAssertsSucceeded(this, pipelineResult); } catch (RuntimeException exc) { Throwable cause = exc.getCause();