twalthr commented on a change in pull request #14103:
URL: https://github.com/apache/flink/pull/14103#discussion_r530250712
##########
File path: docs/_includes/generated/pipeline_configuration.html
##########
@@ -86,6 +86,12 @@
<td>Integer</td>
<td>The program-wide maximum parallelism used for operators which
haven't specified a maximum parallelism. The maximum parallelism specifies the
upper limit for dynamic scaling and the number of key groups used for
partitioned state.</td>
</tr>
+ <tr>
+ <td><h5>pipeline.name</h5></td>
+ <td style="word-wrap: break-word;">(none)</td>
+ <td>String</td>
+ <td>The name to display for the job.</td>
Review comment:
nit: change this to `The job name used for printing and logging.`
##########
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/StreamExecutionEnvironmentTest.java
##########
@@ -269,6 +271,27 @@ public void testGetStreamGraph() {
}
}
+ @Test
+ public void testDefaultJobName() {
+ StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
+
+ env.fromCollection(new DummySplittableIterator<>(),
BasicTypeInfo.INT_TYPE_INFO).addSink(new DiscardingSink<>());
Review comment:
nit: simplify the test here and below to just use `env.fromElements(1,
2, 3).print()`
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java
##########
@@ -1778,7 +1778,7 @@ private StateBackend loadStateBackend(ReadableConfig
configuration, ClassLoader
* @throws Exception which occurs during job execution.
*/
public JobExecutionResult execute() throws Exception {
Review comment:
Update `StreamExecutionEnvironment#configure` as well.
----------------------------------------------------------------
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]
