You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2017/11/02 13:02:46 UTC
[1/3] flink git commit: [hotfix] [docs] Fix typos in types
serialization documentation
Repository: flink
Updated Branches:
refs/heads/master 250adfd2b -> 1ac3e05f9
[hotfix] [docs] Fix typos in types serialization documentation
This closes #4914
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1ac3e05f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1ac3e05f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1ac3e05f
Branch: refs/heads/master
Commit: 1ac3e05f904f3a42ea20c43aaad4c45543c55ec1
Parents: 51acd2c
Author: gyao <ga...@data-artisans.com>
Authored: Fri Oct 27 14:55:39 2017 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Thu Nov 2 14:02:02 2017 +0100
----------------------------------------------------------------------
docs/dev/types_serialization.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/1ac3e05f/docs/dev/types_serialization.md
----------------------------------------------------------------------
diff --git a/docs/dev/types_serialization.md b/docs/dev/types_serialization.md
index 00d0363..1f0c466 100644
--- a/docs/dev/types_serialization.md
+++ b/docs/dev/types_serialization.md
@@ -38,7 +38,7 @@ Think about it like a database that infers the schema of tables. In most cases,
by itself. Having the type information allows Flink to do some cool things:
* Using POJOs types and grouping / joining / aggregating them by referring to field names (like `dataSet.keyBy("username")`).
- The type information allows Flink to check (for typos and type compatibility) early rather than failing later ar runtime.
+ The type information allows Flink to check (for typos and type compatibility) early rather than failing later at runtime.
* The more Flink knows about data types, the better the serialization and data layout schemes are.
That is quite important for the memory usage paradigm in Flink (work on serialized data inside/outside the heap where ever possible
@@ -330,7 +330,7 @@ Type information factories can be used in both the Java and Scala API.
In a hierarchy of types the closest factory
will be chosen while traversing upwards, however, a built-in factory has highest precedence. A factory has
-also higher precendence than Flink's built-in types, therefore you should know what you are doing.
+also higher precedence than Flink's built-in types, therefore you should know what you are doing.
The following example shows how to annotate a custom type `MyTuple` and supply custom type information for it using a factory in Java.
[3/3] flink git commit: [hotfix] [docs] Fix broken downloads page url
Posted by se...@apache.org.
[hotfix] [docs] Fix broken downloads page url
This closes #4912
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b5189957
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b5189957
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b5189957
Branch: refs/heads/master
Commit: b518995790f63b7faeaa9971099261f95af71290
Parents: 250adfd
Author: gyao <ga...@data-artisans.com>
Authored: Fri Oct 27 14:44:32 2017 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Thu Nov 2 14:02:02 2017 +0100
----------------------------------------------------------------------
docs/ops/deployment/aws.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/b5189957/docs/ops/deployment/aws.md
----------------------------------------------------------------------
diff --git a/docs/ops/deployment/aws.md b/docs/ops/deployment/aws.md
index dd9b6c4..709ecd1 100644
--- a/docs/ops/deployment/aws.md
+++ b/docs/ops/deployment/aws.md
@@ -55,7 +55,7 @@ when creating an EMR cluster.
After creating your cluster, you can [connect to the master node](http://docs.aws.amazon.com/ElasticMapReduce/latest/ManagementGuide/emr-connect-master-node.html) and install Flink:
-1. Go the [Downloads Page]({{ download_url}}) and **download a binary version of Flink matching the Hadoop version** of your EMR cluster, e.g. Hadoop 2.7 for EMR releases 4.3.0, 4.4.0, or 4.5.0.
+1. Go the [Downloads Page]({{ site.download_url }}) and **download a binary version of Flink matching the Hadoop version** of your EMR cluster, e.g. Hadoop 2.7 for EMR releases 4.3.0, 4.4.0, or 4.5.0.
2. Extract the Flink distribution and you are ready to deploy [Flink jobs via YARN](yarn_setup.html) after **setting the Hadoop config directory**:
```bash
[2/3] flink git commit: [hotfix] [javadoc] Fix typo in Javadoc of
ManagedSnapshotContext#getCheckpointId()
Posted by se...@apache.org.
[hotfix] [javadoc] Fix typo in Javadoc of ManagedSnapshotContext#getCheckpointId()
This closes #4913
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/51acd2cc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/51acd2cc
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/51acd2cc
Branch: refs/heads/master
Commit: 51acd2cc9740cd3609983b7f9641d69324557774
Parents: b518995
Author: gyao <ga...@data-artisans.com>
Authored: Fri Oct 27 14:48:21 2017 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Thu Nov 2 14:02:02 2017 +0100
----------------------------------------------------------------------
.../org/apache/flink/runtime/state/ManagedSnapshotContext.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/51acd2cc/flink-runtime/src/main/java/org/apache/flink/runtime/state/ManagedSnapshotContext.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/ManagedSnapshotContext.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/ManagedSnapshotContext.java
index de65c5d..3109521 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/ManagedSnapshotContext.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/ManagedSnapshotContext.java
@@ -33,7 +33,7 @@ public interface ManagedSnapshotContext {
*
* <p>The checkpoint ID is guaranteed to be strictly monotonously increasing across checkpoints.
* For two completed checkpoints <i>A</i> and <i>B</i>, {@code ID_B > ID_A} means that checkpoint
- * <i>B</i> subsumes checkpoint <i>A</i>, i.e., checkpoint <i>B</i>it contains a later state
+ * <i>B</i> subsumes checkpoint <i>A</i>, i.e., checkpoint <i>B</i> contains a later state
* than checkpoint <i>A</i>.
*/
long getCheckpointId();