You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/04/10 09:50:58 UTC
[flink] 05/05: [hotfix] Update CoreOptions JVM options to use
stringType
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 95716a62af9a2a30fe07a59e7c7b59d47521a549
Author: Till Rohrmann <tr...@apache.org>
AuthorDate: Thu Apr 9 17:43:28 2020 +0200
[hotfix] Update CoreOptions JVM options to use stringType
---
.../src/main/java/org/apache/flink/configuration/CoreOptions.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java b/flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java
index 92e2f90..f313257 100644
--- a/flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java
+++ b/flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java
@@ -160,21 +160,25 @@ public class CoreOptions {
public static final ConfigOption<String> FLINK_JVM_OPTIONS = ConfigOptions
.key("env.java.opts")
+ .stringType()
.defaultValue("")
.withDescription(Description.builder().text("Java options to start the JVM of all Flink processes with.").build());
public static final ConfigOption<String> FLINK_JM_JVM_OPTIONS = ConfigOptions
.key("env.java.opts.jobmanager")
+ .stringType()
.defaultValue("")
.withDescription(Description.builder().text("Java options to start the JVM of the JobManager with.").build());
public static final ConfigOption<String> FLINK_TM_JVM_OPTIONS = ConfigOptions
.key("env.java.opts.taskmanager")
+ .stringType()
.defaultValue("")
.withDescription(Description.builder().text("Java options to start the JVM of the TaskManager with.").build());
public static final ConfigOption<String> FLINK_HS_JVM_OPTIONS = ConfigOptions
.key("env.java.opts.historyserver")
+ .stringType()
.defaultValue("")
.withDescription(Description.builder().text("Java options to start the JVM of the HistoryServer with.").build());