Merge pull request #14898 from boyuanzz/fix

[BEAM-12416] Populate use_sdf_read in ExpansionService.
apache · May 28, 2021 · 31988c8 · 31988c8
2 parents eafa48d + 1fd191d
commit 31988c8
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...pansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java b/...pansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java
@@ -394,6 +394,9 @@ private Map<String, TransformProvider> loadRegisteredTransforms() {
     Pipeline pipeline = Pipeline.create();
     ExperimentalOptions.addExperiment(
         pipeline.getOptions().as(ExperimentalOptions.class), "beam_fn_api");
+    // TODO(BEAM-10670): Remove this when we address performance issue.
+    ExperimentalOptions.addExperiment(
+        pipeline.getOptions().as(ExperimentalOptions.class), "use_sdf_read");
 
     ClassLoader classLoader = Environments.class.getClassLoader();
     if (classLoader == null) {