diff --git a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/VarianceFnTest.java b/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/VarianceFnTest.java index 4b72fca933eb..f7a8ad1fa06b 100644 --- a/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/VarianceFnTest.java +++ b/sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/VarianceFnTest.java @@ -92,12 +92,12 @@ public void testAddsInputToAccumulator() { } @Test - public void testCeatesAccumulatorCoder() { + public void testCreatesAccumulatorCoder() { assertNotNull(varianceFn.getAccumulatorCoder(CoderRegistry.createDefault(), VarIntCoder.of())); } @Test - public void testReturnsOutput() { + public void testExtractsOutput() { assertEquals(expectedExtractedResult, varianceFn.extractOutput(testAccumulatorInput)); } }