[
https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16025221#comment-16025221
]
ASF GitHub Bot commented on FLINK-6719:
---------------------------------------
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3989#discussion_r118558312
--- Diff:
flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java ---
@@ -369,68 +372,87 @@ public static void main(String[] args) throws
Exception {
.fieldDelimiter("\t").types(Long.class,
Long.class);
DataSet<Tuple2<Long, Long>> result = input.map(
- new MapFunction<Tuple2<Long,Long>,
Tuple2<Long,Long>>() {
+ new MapFunction<Tuple2<Long, Long>,
Tuple2<Long, Long>>() {
public Tuple2<Long, Long>
map(Tuple2<Long, Long> value){
- return new Tuple2<Long,
Long>(value.f0, value.f1+1);
+ return new Tuple2<Long,
Long>(value.f0, value.f1 + 1);
}
});
result.writeAsCsv(args[1], "\n", "\t");
env.execute();
}
+
@Override
public String getDescription() {
return "TestOptimizerPlan <input-file-path>
<output-file-path>";
}
}
+ /**
+ * That job that calls {@link ExecutionEnvironment#execute()} twice.
--- End diff --
will fix it while merging.
> Add details about fault-tolerance of timers to ProcessFunction docs
> -------------------------------------------------------------------
>
> Key: FLINK-6719
> URL: https://issues.apache.org/jira/browse/FLINK-6719
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
> Reporter: Tzu-Li (Gordon) Tai
>
> The fault-tolerance of timers is a frequently asked questions on the mailing
> lists. We should add details about the topic in the {{ProcessFunction}} docs.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
