You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by bl...@apache.org on 2022/05/30 15:44:28 UTC
[iceberg] branch master updated: Flink: Add option to set monitorInterval (#4887)
This is an automated email from the ASF dual-hosted git repository.
blue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/master by this push:
new 0a1c4e3ed Flink: Add option to set monitorInterval (#4887)
0a1c4e3ed is described below
commit 0a1c4e3ed8ec81be4d9ae71443e99a37f9943db3
Author: Chen, Junjie <ji...@tencent.com>
AuthorDate: Mon May 30 23:44:22 2022 +0800
Flink: Add option to set monitorInterval (#4887)
---
.../src/main/java/org/apache/iceberg/flink/source/FlinkSource.java | 6 ++++++
.../src/main/java/org/apache/iceberg/flink/source/FlinkSource.java | 6 ++++++
.../src/main/java/org/apache/iceberg/flink/source/FlinkSource.java | 6 ++++++
3 files changed, 18 insertions(+)
diff --git a/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java b/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
index f0ce128a1..36bcc2bb1 100644
--- a/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
+++ b/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
@@ -21,6 +21,7 @@ package org.apache.iceberg.flink.source;
import java.io.IOException;
import java.io.UncheckedIOException;
+import java.time.Duration;
import java.util.List;
import java.util.Map;
import java.util.Set;
@@ -178,6 +179,11 @@ public class FlinkSource {
return this;
}
+ public Builder monitorInterval(Duration interval) {
+ contextBuilder.monitorInterval(interval);
+ return this;
+ }
+
public Builder flinkConf(ReadableConfig config) {
this.readableConfig = config;
return this;
diff --git a/flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java b/flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
index ba2082ea5..3feafc137 100644
--- a/flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
+++ b/flink/v1.14/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
@@ -21,6 +21,7 @@ package org.apache.iceberg.flink.source;
import java.io.IOException;
import java.io.UncheckedIOException;
+import java.time.Duration;
import java.util.List;
import java.util.Map;
import java.util.Set;
@@ -178,6 +179,11 @@ public class FlinkSource {
return this;
}
+ public Builder monitorInterval(Duration interval) {
+ contextBuilder.monitorInterval(interval);
+ return this;
+ }
+
public Builder flinkConf(ReadableConfig config) {
this.readableConfig = config;
return this;
diff --git a/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java b/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
index ba2082ea5..3feafc137 100644
--- a/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
+++ b/flink/v1.15/flink/src/main/java/org/apache/iceberg/flink/source/FlinkSource.java
@@ -21,6 +21,7 @@ package org.apache.iceberg.flink.source;
import java.io.IOException;
import java.io.UncheckedIOException;
+import java.time.Duration;
import java.util.List;
import java.util.Map;
import java.util.Set;
@@ -178,6 +179,11 @@ public class FlinkSource {
return this;
}
+ public Builder monitorInterval(Duration interval) {
+ contextBuilder.monitorInterval(interval);
+ return this;
+ }
+
public Builder flinkConf(ReadableConfig config) {
this.readableConfig = config;
return this;