commit 50b4d1cea6de9fcc49e7a376b200dab56f61af3c
author Tzu-Li (Gordon) Tai <tzulitai@apache.org> Fri May 15 18:56:38 2020 +0800
committer Tzu-Li (Gordon) Tai <tzulitai@apache.org> Fri May 15 18:56:38 2020 +0800
tree 475849e0881040de724845de41a9480aab7a8727
parent c49de86e946e1b1d46aa36cce22f61fa2e638198

[hotfix] Avoid raw types in UnboundedFeedbackLoggerTest

statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/logger/UnboundedFeedbackLoggerTest.java

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 @@
 
   @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 @@
 
   @Test(expected = IllegalStateException.class)
   public void commitWithoutStartLoggingShouldBeIllegal() {
-    UnboundedFeedbackLogger logger = instanceUnderTest(128, 1);
+    UnboundedFeedbackLogger<Integer> logger = instanceUnderTest(128, 1);
 
     logger.commit();
   }