This is an automated email from the ASF dual-hosted git repository. tzulitai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-statefun.git
commit 50b4d1cea6de9fcc49e7a376b200dab56f61af3c Author: Tzu-Li (Gordon) Tai <[email protected]> AuthorDate: Fri May 15 18:56:38 2020 +0800 [hotfix] Avoid raw types in UnboundedFeedbackLoggerTest --- .../flink/statefun/flink/core/logger/UnboundedFeedbackLoggerTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/logger/UnboundedFeedbackLoggerTest.java b/statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/logger/UnboundedFeedbackLoggerTest.java index 75c4c55..dd7088f 100644 --- a/statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/logger/UnboundedFeedbackLoggerTest.java +++ b/statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/logger/UnboundedFeedbackLoggerTest.java @@ -50,7 +50,7 @@ public class UnboundedFeedbackLoggerTest { @Test public void sanity() { - UnboundedFeedbackLogger logger = instanceUnderTest(128, 1); + UnboundedFeedbackLogger<Integer> logger = instanceUnderTest(128, 1); ByteArrayOutputStream output = new ByteArrayOutputStream(); logger.startLogging(output); @@ -61,7 +61,7 @@ public class UnboundedFeedbackLoggerTest { @Test(expected = IllegalStateException.class) public void commitWithoutStartLoggingShouldBeIllegal() { - UnboundedFeedbackLogger logger = instanceUnderTest(128, 1); + UnboundedFeedbackLogger<Integer> logger = instanceUnderTest(128, 1); logger.commit(); }
