[FLINK-7045] [tests] Reduce element count of UdfStreamOperatorCheckpo…

…intingITCase This closes #4230
apache · Jul 5, 2017 · 2a3ab2b · 2a3ab2b
1 parent 57c675e
commit 2a3ab2b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...c/test/java/org/apache/flink/test/checkpointing/UdfStreamOperatorCheckpointingITCase.java b/...c/test/java/org/apache/flink/test/checkpointing/UdfStreamOperatorCheckpointingITCase.java
@@ -52,7 +52,7 @@
 @SuppressWarnings("serial")
 public class UdfStreamOperatorCheckpointingITCase extends StreamFaultToleranceTestBase {
 
- final private static long NUM_INPUT = 2_500_000L;
+ final private static long NUM_INPUT = 500_000L;
  final private static int NUM_OUTPUT = 1_000;
 
  /**