You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2017/06/22 09:41:06 UTC
[1/5] flink git commit: [FLINK-6874] [docs] Static and transient
fields ignored for POJOs
Repository: flink
Updated Branches:
refs/heads/master 0c4f7988d -> 87e1e8fc3
[FLINK-6874] [docs] Static and transient fields ignored for POJOs
Note that static and transient fields are ignored when TypeExtrator
validates a POJO.
This closes #4091.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/20838efc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/20838efc
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/20838efc
Branch: refs/heads/master
Commit: 20838efc5dfe0a4be917682f936f447d8df37986
Parents: 0c4f798
Author: Greg Hogan <co...@greghogan.com>
Authored: Thu Jun 8 10:51:49 2017 -0400
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Thu Jun 22 17:06:21 2017 +0800
----------------------------------------------------------------------
docs/dev/types_serialization.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/20838efc/docs/dev/types_serialization.md
----------------------------------------------------------------------
diff --git a/docs/dev/types_serialization.md b/docs/dev/types_serialization.md
index 053a839..0d68a51 100644
--- a/docs/dev/types_serialization.md
+++ b/docs/dev/types_serialization.md
@@ -111,7 +111,7 @@ conditions are fulfilled:
* The class is public and standalone (no non-static inner class)
* The class has a public no-argument constructor
-* All fields in the class (and all superclasses) are either public (and non-final)
+* All non-static, non-transient fields in the class (and all superclasses) are either public (and non-final)
or have a public getter- and a setter- method that follows the Java beans
naming conventions for getters and setters.
[3/5] flink git commit: [hotfix] [docs] Fix typo in docs (Souce ->
Source)
Posted by tz...@apache.org.
[hotfix] [docs] Fix typo in docs (Souce -> Source)
Includes such typos in:
1. docs/fig/state_partitioning.svg
2. docs/dev/table_api.md
This closes #4119.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9385b548
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9385b548
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9385b548
Branch: refs/heads/master
Commit: 9385b54812d2f3a367efa663a33d37fc16d0e7d6
Parents: 2324a8e
Author: Gary Yao <gy...@garyyao.com>
Authored: Tue Jun 13 21:09:35 2017 +0200
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Thu Jun 22 17:21:26 2017 +0800
----------------------------------------------------------------------
docs/dev/table/sourceSinks.md | 2 +-
docs/fig/state_partitioning.svg | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/9385b548/docs/dev/table/sourceSinks.md
----------------------------------------------------------------------
diff --git a/docs/dev/table/sourceSinks.md b/docs/dev/table/sourceSinks.md
index 266ab3b..58049c8 100644
--- a/docs/dev/table/sourceSinks.md
+++ b/docs/dev/table/sourceSinks.md
@@ -40,7 +40,7 @@ Currently, Flink provides the `CsvTableSource` to read CSV files and a few table
A custom `TableSource` can be defined by implementing the `BatchTableSource` or `StreamTableSource` interface. See section on [defining a custom TableSource](#define-a-tablesource) for details.
| **Class name** | **Maven dependency** | **Batch?** | **Streaming?** | **Description**
-| `CsvTableSouce` | `flink-table` | Y | Y | A simple source for CSV files.
+| `CsvTableSource` | `flink-table` | Y | Y | A simple source for CSV files.
| `Kafka08JsonTableSource` | `flink-connector-kafka-0.8` | N | Y | A Kafka 0.8 source for JSON data.
| `Kafka08AvroTableSource` | `flink-connector-kafka-0.8` | N | Y | A Kafka 0.8 source for Avro data.
| `Kafka09JsonTableSource` | `flink-connector-kafka-0.9` | N | Y | A Kafka 0.9 source for JSON data.
http://git-wip-us.apache.org/repos/asf/flink/blob/9385b548/docs/fig/state_partitioning.svg
----------------------------------------------------------------------
diff --git a/docs/fig/state_partitioning.svg b/docs/fig/state_partitioning.svg
index 4d75ca3..8df3a66 100644
--- a/docs/fig/state_partitioning.svg
+++ b/docs/fig/state_partitioning.svg
@@ -111,7 +111,7 @@ under the License.
y="271.23022"
id="text3013"
xml:space="preserve"
- style="font-size:12.45310211px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Souce</text>
+ style="font-size:12.45310211px;font-style:normal;font-weight:normal;text-align:start;text-anchor:start;fill:#000000;font-family:Verdana">Source</text>
<text
x="56.959515"
y="286.23395"
[2/5] flink git commit: [FLINK-6806] [docs] Add RocksDB to listed
state backends in doc
Posted by tz...@apache.org.
[FLINK-6806] [docs] Add RocksDB to listed state backends in doc
This closes #4045.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2324a8e1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2324a8e1
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2324a8e1
Branch: refs/heads/master
Commit: 2324a8e1d2082452bfdb92053f80eb63ce04f3a1
Parents: 20838ef
Author: Bowen Li <bo...@gmail.com>
Authored: Thu Jun 1 15:40:30 2017 -0700
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Thu Jun 22 17:06:43 2017 +0800
----------------------------------------------------------------------
docs/ops/state_backends.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/2324a8e1/docs/ops/state_backends.md
----------------------------------------------------------------------
diff --git a/docs/ops/state_backends.md b/docs/ops/state_backends.md
index 781b2c5..85a34a9 100644
--- a/docs/ops/state_backends.md
+++ b/docs/ops/state_backends.md
@@ -151,7 +151,7 @@ env.setStateBackend(new FsStateBackend("hdfs://namenode:40010/flink/checkpoints"
A default state backend can be configured in the `flink-conf.yaml`, using the configuration key `state.backend`.
-Possible values for the config entry are *jobmanager* (MemoryStateBackend), *filesystem* (FsStateBackend), or the fully qualified class
+Possible values for the config entry are *jobmanager* (MemoryStateBackend), *filesystem* (FsStateBackend), *rocksdb* (RocksDBStateBackend), or the fully qualified class
name of the class that implements the state backend factory [FsStateBackendFactory](https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackendFactory.java),
such as `org.apache.flink.contrib.streaming.state.RocksDBStateBackendFactory` for RocksDBStateBackend.
[4/5] flink git commit: [FLINK-6932] [doc] Update inaccessible
Dataflow Model paper link
Posted by tz...@apache.org.
[FLINK-6932] [doc] Update inaccessible Dataflow Model paper link
This closes #4131.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d1ee819a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d1ee819a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d1ee819a
Branch: refs/heads/master
Commit: d1ee819ac4a45a2165854ec7750a33b00e67848e
Parents: 9385b54
Author: zhangminglei <zm...@163.com>
Authored: Fri Jun 16 10:00:19 2017 +0800
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Thu Jun 22 17:26:57 2017 +0800
----------------------------------------------------------------------
docs/dev/event_time.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/d1ee819a/docs/dev/event_time.md
----------------------------------------------------------------------
diff --git a/docs/dev/event_time.md b/docs/dev/event_time.md
index 0d3acaf..0118f15 100644
--- a/docs/dev/event_time.md
+++ b/docs/dev/event_time.md
@@ -146,7 +146,7 @@ to use timestamp assignment and watermark generation in the Flink DataStream API
*Note: Flink implements many techniques from the Dataflow Model. For a good introduction to event time and watermarks, have a look at the articles below.*
- [Streaming 101](https://www.oreilly.com/ideas/the-world-beyond-batch-streaming-101) by Tyler Akidau
- - The [Dataflow Model paper](https://static.googleusercontent.com/media/research.google.com/en/pubs/archive/43864.pdf)
+ - The [Dataflow Model paper](https://research.google.com/pubs/archive/43864.pdf)
A stream processor that supports *event time* needs a way to measure the progress of event time.
[5/5] flink git commit: [FLINK-6937] [docs] Fix broken link in
Production Readiness Checklist
Posted by tz...@apache.org.
[FLINK-6937] [docs] Fix broken link in Production Readiness Checklist
This closes #4134.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/87e1e8fc
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/87e1e8fc
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/87e1e8fc
Branch: refs/heads/master
Commit: 87e1e8fc350544d81b751efd87f725a1413da1f9
Parents: d1ee819
Author: Juan Paulo Gutierrez <ju...@gmail.com>
Authored: Tue Jun 13 14:31:40 2017 +0900
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Thu Jun 22 17:40:04 2017 +0800
----------------------------------------------------------------------
docs/ops/production_ready.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/87e1e8fc/docs/ops/production_ready.md
----------------------------------------------------------------------
diff --git a/docs/ops/production_ready.md b/docs/ops/production_ready.md
index e3e6353..2cce8d0 100644
--- a/docs/ops/production_ready.md
+++ b/docs/ops/production_ready.md
@@ -64,7 +64,7 @@ parallelism as a function of the parallelism when the job is first started:
### Set UUIDs for operators
-As mentioned in the documentation for [savepoints]({{ site.baseurl }}/setup/savepoints.html, users should set uids for
+As mentioned in the documentation for [savepoints]({{ site.baseurl }}/setup/savepoints.html), users should set uids for
operators. Those operator uids are important for Flink's mapping of operator states to operators which, in turn, is
essential for savepoints. By default operator uids are generated by traversing the JobGraph and hashing certain operator
properties. While this is comfortable from a user perspective, it is also very fragile, as changes to the JobGraph (e.g.
@@ -85,4 +85,4 @@ very important for large states because they do not block the operators and Flin
stream processing. However, RocksDB can have worse performance than, for example, the memory-based state backends. If
you are sure that your state will never exceed main memory and blocking the stream processing to write it is not an issue,
you **could consider** to not use the RocksDB backends. However, at this point, we **strongly recommend** using RocksDB
-for production.
\ No newline at end of file
+for production.