[flink] branch master updated: [FLINK-12299][streaming] Reject negative auto watermark interval

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 66d9270  [FLINK-12299][streaming] Reject negative auto watermark 
interval
66d9270 is described below

commit 66d9270bc726d75a81ad75b7140dcd929f650aba
Author: 时无两丶 <442367...@qq.com>
AuthorDate: Fri May 24 15:33:15 2019 +0800

    [FLINK-12299][streaming] Reject negative auto watermark interval
---
 .../src/main/java/org/apache/flink/api/common/ExecutionConfig.java       | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java 
b/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
index e53efee..027a544 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
@@ -220,6 +220,7 @@ public class ExecutionConfig implements Serializable, 
Archiveable<ArchivedExecut
         */
        @PublicEvolving
        public ExecutionConfig setAutoWatermarkInterval(long interval) {
+               Preconditions.checkArgument(interval >= 0, "Auto watermark 
interval must not be negative.");
                this.autoWatermarkInterval = interval;
                return this;
        }