You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gr...@apache.org on 2017/02/06 19:43:15 UTC
[1/2] flink git commit: [FLINK-5680] [docs] Document env.ssh.opts
Repository: flink
Updated Branches:
refs/heads/master 1f464c27e -> 11ebf4842
[FLINK-5680] [docs] Document env.ssh.opts
Document env.ssh.opts in setup/config.html.
This closes #3247
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/327ff060
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/327ff060
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/327ff060
Branch: refs/heads/master
Commit: 327ff060a7b64862aa6a33b6c8b07bbef05bde76
Parents: 1f464c2
Author: Greg Hogan <co...@greghogan.com>
Authored: Wed Feb 1 09:48:31 2017 -0500
Committer: Greg Hogan <co...@greghogan.com>
Committed: Mon Feb 6 14:40:09 2017 -0500
----------------------------------------------------------------------
docs/setup/config.md | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/327ff060/docs/setup/config.md
----------------------------------------------------------------------
diff --git a/docs/setup/config.md b/docs/setup/config.md
index 6bde26a..2872cfa 100644
--- a/docs/setup/config.md
+++ b/docs/setup/config.md
@@ -526,6 +526,8 @@ Previously this key was named `recovery.mode` and the default value was `standal
- `env.log.dir`: (Defaults to the `log` directory under Flink's home) Defines the directory where the Flink logs are saved. It has to be an absolute path.
+- `env.ssh.opts`: Additional command line options passed to SSH clients when starting or stopping JobManager, TaskManager, and Zookeeper services (start-cluster.sh, stop-cluster.sh, start-zookeeper-quorum.sh, stop-zookeeper-quorum.sh).
+
### Queryable State
#### Server
[2/2] flink git commit: [FLINK-2883] [docs] Add documentation to
forbid key-modifying ReduceFunction
Posted by gr...@apache.org.
[FLINK-2883] [docs] Add documentation to forbid key-modifying ReduceFunction
This closes #3256
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/11ebf484
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/11ebf484
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/11ebf484
Branch: refs/heads/master
Commit: 11ebf484280314231d146dcfb0b973934448f00b
Parents: 327ff06
Author: Greg Hogan <co...@greghogan.com>
Authored: Thu Feb 2 16:15:52 2017 -0500
Committer: Greg Hogan <co...@greghogan.com>
Committed: Mon Feb 6 14:40:10 2017 -0500
----------------------------------------------------------------------
docs/dev/batch/dataset_transformations.md | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/11ebf484/docs/dev/batch/dataset_transformations.md
----------------------------------------------------------------------
diff --git a/docs/dev/batch/dataset_transformations.md b/docs/dev/batch/dataset_transformations.md
index 1bfb87c..1f942d4 100644
--- a/docs/dev/batch/dataset_transformations.md
+++ b/docs/dev/batch/dataset_transformations.md
@@ -279,6 +279,10 @@ element using a user-defined reduce function.
For each group of input elements, a reduce function successively combines pairs of elements into one
element until only a single element for each group remains.
+Note that for a `ReduceFunction` the keyed fields of the returned object should match the input
+values. This is because reduce is implicitly combinable and objects emitted from the combine
+operator are again grouped by key when passed to the reduce operator.
+
#### Reduce on DataSet Grouped by Key Expression
Key expressions specify one or more fields of each element of a DataSet. Each key expression is