You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/05/24 07:33:30 UTC
[flink] branch master updated: [FLINK-12299][streaming] Reject
negative auto watermark interval
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: 时无两丶 <44...@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;
}