| commit | 99d1f94a0ed714ba0df1e83f01f354d266c7cc1f | [log] [tgz] |
|---|---|---|
| author | Heejong Lee <heejong@gmail.com> | Thu May 27 22:22:00 2021 -0700 |
| committer | GitHub <noreply@github.com> | Thu May 27 22:22:00 2021 -0700 |
| tree | 22ce2b37d0284f4e938cb0ea621698940e577c37 | |
| parent | 898d1ac45f72ccf56e483f5e98ac662c0657bb74 [diff] | |
| parent | 626c3efec2002d44841b766d5ddf34030332a6ef [diff] |
Merge pull request #14901 from ihji/cherry-pick-expansion-fix [release-2.30.0][BEAM-12416] Populate use_sdf_read in ExpansionService.
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 @@ 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) {