Github user yanghua commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6305#discussion_r201908022
  
    --- Diff: 
flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeWindowCheckpointingITCase.java
 ---
    @@ -871,19 +892,40 @@ public IntType(int value) {
                }
        }
     
    -   protected int numElementsPerKey() {
    -           return 300;
    +   private int numElementsPerKey() {
    +           switch (this.stateBackendEnum) {
    +                   case ROCKSDB_FULLY_ASYNC:
    +                   case ROCKSDB_INCREMENTAL:
    +                   case ROCKSDB_INCREMENTAL_ZK:
    +                           return 3000;
    --- End diff --
    
    change this to a const looks better~


---

Reply via email to