[beam] branch master updated: Populate use_sdf_read in ExpansionService.

[heejong]

This is an automated email from the ASF dual-hosted git repository.

heejong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 1fd191d  Populate use_sdf_read in ExpansionService.
     new 31988c8  Merge pull request #14898 from boyuanzz/fix
1fd191d is described below

commit 1fd191d3195ae7c9e00545977ebfbdcc05f13e20
Author: Boyuan Zhang <boyu...@google.com>
AuthorDate: Thu May 27 14:23:36 2021 -0700

    Populate use_sdf_read in ExpansionService.
---
 .../java/org/apache/beam/sdk/expansion/service/ExpansionService.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java
 
b/sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java
index 72e7384..d4f0e6a 100644
--- 
a/sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java
+++ 
b/sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java
@@ -394,6 +394,9 @@ public class ExpansionService extends 
ExpansionServiceGrpc.ExpansionServiceImplB
     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) {