Github user klion26 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6305#discussion_r202269405
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java
---
@@ -99,11 +110,21 @@
private AbstractStateBackend stateBackend;
+ @Parameterized.Parameter
+ public StateBackendEnum stateBackendEnum;
+
enum StateBackendEnum {
MEM, FILE, ROCKSDB_FULLY_ASYNC, ROCKSDB_INCREMENTAL,
ROCKSDB_INCREMENTAL_ZK, MEM_ASYNC, FILE_ASYNC
}
- protected abstract StateBackendEnum getStateBackend();
+ @Parameterized.Parameters(name = "statebackend type ={0}")
+ public static Collection<StateBackendEnum> parameter() {
+ return Arrays.asList(MEM, FILE, ROCKSDB_FULLY_ASYNC,
ROCKSDB_INCREMENTAL, ROCKSDB_INCREMENTAL_ZK, MEM_ASYNC, FILE_ASYNC);
--- End diff --
Ok, changed it.
---