aljoscha commented on a change in pull request #10217:
[FLINK-14786][configuration] Add configure method to ExecutionConfig
URL: https://github.com/apache/flink/pull/10217#discussion_r347496425
##########
File path:
flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java
##########
@@ -19,35 +19,191 @@
package org.apache.flink.configuration;
import org.apache.flink.annotation.PublicEvolving;
+import org.apache.flink.api.common.ExecutionConfig;
+import org.apache.flink.configuration.description.Description;
+import org.apache.flink.configuration.description.TextElement;
+import java.time.Duration;
import java.util.List;
+import java.util.Map;
import static org.apache.flink.configuration.ConfigOptions.key;
+import static org.apache.flink.configuration.description.TextElement.code;
+import static org.apache.flink.configuration.description.TextElement.text;
/**
* The {@link ConfigOption configuration options} for job execution.
*/
@PublicEvolving
public class PipelineOptions {
-
/**
* A list of jar files that contain the user-defined function (UDF)
classes and all classes used from within the UDFs.
*/
public static final ConfigOption<List<String>> JARS =
- key("pipeline.jars")
- .stringType()
- .asList()
- .noDefaultValue()
- .withDescription("A semicolon-separated
list of the jars to package with the job jars to be sent to the cluster. These
have to be valid paths.");
-
+ key("pipeline.jars")
+ .stringType()
+ .asList()
+ .noDefaultValue()
+ .withDescription("A semicolon-separated list of the
jars to package with the job jars to be sent to the" +
+ " cluster. These have to be valid paths.");
/**
* A list of URLs that are added to the classpath of each user code
classloader of the program.
* Paths must specify a protocol (e.g. file://) and be accessible on
all nodes
*/
public static final ConfigOption<List<String>> CLASSPATHS =
- key("pipeline.classpaths")
- .stringType()
- .asList()
- .noDefaultValue()
- .withDescription("A semicolon-separated
list of the classpaths to package with the job jars to be sent to the cluster.
These have to be valid URLs.");
+ key("pipeline.classpaths")
+ .stringType()
+ .asList()
+ .noDefaultValue()
+ .withDescription("A semicolon-separated list of the
classpaths to package with the job jars to be sent to" +
+ " the cluster. These have to be valid URLs.");
+
+ public static final ConfigOption<Boolean> AUTO_GENERATE_UIDS =
+ key("pipeline.auto-generate-uids")
+ .booleanType()
+ .defaultValue(true)
+ .withDescription(Description.builder()
+ .text(
+ "When auto-generated UIDs are disabled,
users are forced to manually specify UIDs on DataStream applications.")
+ .linebreak()
+ .linebreak()
+ .text("It is highly recommended that users
specify UIDs before deploying to" +
+ "production since they are used to
match state in savepoints to operators" +
+ "in a job. Because auto-generated ID's
are likely to change when modifying" +
+ "a job, specifying custom IDs allow an
application to evolve overtime" +
Review comment:
```suggestion
"a job, specifying custom IDs allow an
application to evolve over time" +
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
