From 6b77bc892ea44758c1ef1e3188f3803c41f5bbdc Mon Sep 17 00:00:00 2001 From: Eugene Kirpichov Date: Thu, 25 May 2017 13:43:20 -0700 Subject: [PATCH] Fixes build after #3199 --- .../beam/runners/core/construction/CombineTranslation.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java index e0b6d5c9abf8..855fba740a02 100644 --- a/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java +++ b/runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java @@ -105,7 +105,7 @@ private static SdkFunctionSpec toProto(GlobalCombineFn combineFn) { public static Coder getAccumulatorCoder( CombinePayload payload, RunnerApi.Components components) throws IOException { String id = payload.getAccumulatorCoderId(); - return Coders.fromProto(components.getCodersOrThrow(id), components); + return CoderTranslation.fromProto(components.getCodersOrThrow(id), components); } public static GlobalCombineFn getCombineFn(CombinePayload payload)