diff --git a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamBuiltinAggregations.java b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamBuiltinAggregations.java index 2800edfbb99a..ce4219adda1b 100644 --- a/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamBuiltinAggregations.java +++ b/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamBuiltinAggregations.java @@ -90,7 +90,7 @@ public class BeamBuiltinAggregations { .put("COUNTIF", typeName -> CountIf.combineFn()) .build(); - private static MathContext mc = new MathContext(10, RoundingMode.HALF_UP); + private static MathContext mc = new MathContext(34, RoundingMode.HALF_UP); public static CombineFn create(String functionName, Schema.FieldType fieldType) {