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/10/24 17:19:35 UTC
[1/3] flink git commit: [FLINK-7849] [hcatalog] Remove
unnecessary/ineffective gauva shading
Repository: flink
Updated Branches:
refs/heads/master 5ebe3fb55 -> 512b9c478
[FLINK-7849] [hcatalog] Remove unnecessary/ineffective gauva shading
This closes #4836
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/512b9c47
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/512b9c47
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/512b9c47
Branch: refs/heads/master
Commit: 512b9c47880368017efcd79f39cae013d6f8bdf3
Parents: 90fc20f
Author: zentol <ch...@apache.org>
Authored: Mon Oct 16 14:34:24 2017 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Tue Oct 24 19:19:05 2017 +0200
----------------------------------------------------------------------
flink-connectors/flink-hcatalog/pom.xml | 26 --------------------------
1 file changed, 26 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/512b9c47/flink-connectors/flink-hcatalog/pom.xml
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-hcatalog/pom.xml b/flink-connectors/flink-hcatalog/pom.xml
index 1e77d7d..10ca36d 100644
--- a/flink-connectors/flink-hcatalog/pom.xml
+++ b/flink-connectors/flink-hcatalog/pom.xml
@@ -70,32 +70,6 @@ under the License.
<build>
<plugins>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-shade-plugin</artifactId>
- <executions>
- <execution>
- <id>shade-flink</id>
- <configuration>
- <artifactSet>
- <includes>
- <include>com.google.guava:guava</include>
- </includes>
- </artifactSet>
- <relocations>
- <relocation>
- <pattern>com.google</pattern>
- <shadedPattern>org.apache.flink.hcatalog.shaded.com.google</shadedPattern>
- <excludes>
- <exclude>com.google.protobuf.**</exclude>
- <exclude>com.google.inject.**</exclude>
- </excludes>
- </relocation>
- </relocations>
- </configuration>
- </execution>
- </executions>
- </plugin>
<!-- Scala Compiler -->
<plugin>
<groupId>net.alchim31.maven</groupId>
[3/3] flink git commit: [hotfix] [docs] Fix typos in documentation
Posted by se...@apache.org.
[hotfix] [docs] Fix typos in documentation
This closes #4885
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1e7d5bee
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1e7d5bee
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1e7d5bee
Branch: refs/heads/master
Commit: 1e7d5bee3221083e3150d3c1c657b60a0cdd3872
Parents: 5ebe3fb
Author: yew1eb <ye...@gmail.com>
Authored: Mon Oct 23 17:42:25 2017 +0800
Committer: Stephan Ewen <se...@apache.org>
Committed: Tue Oct 24 19:19:05 2017 +0200
----------------------------------------------------------------------
docs/dev/connectors/cassandra.md | 2 +-
docs/dev/connectors/kafka.md | 2 +-
docs/dev/event_timestamps_watermarks.md | 4 ++--
docs/dev/java8.md | 4 ++--
docs/dev/stream/state/queryable_state.md | 2 +-
docs/quickstart/scala_api_quickstart.md | 4 ++--
6 files changed, 9 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/1e7d5bee/docs/dev/connectors/cassandra.md
----------------------------------------------------------------------
diff --git a/docs/dev/connectors/cassandra.md b/docs/dev/connectors/cassandra.md
index 5a104ac..dd8a775 100644
--- a/docs/dev/connectors/cassandra.md
+++ b/docs/dev/connectors/cassandra.md
@@ -96,7 +96,7 @@ database in an inconsistent state since part of the first attempt may already be
The write-ahead log guarantees that the replayed checkpoint is identical to the first attempt.
Note that that enabling this feature will have an adverse impact on latency.
-<p style="border-radius: 5px; padding: 5px" class="bg-danger"><b>Note</b>: The write-ahead log functionality is currently experimental. In many cases it is sufficent to use the connector without enabling it. Please report problems to the development mailing list.</p>
+<p style="border-radius: 5px; padding: 5px" class="bg-danger"><b>Note</b>: The write-ahead log functionality is currently experimental. In many cases it is sufficient to use the connector without enabling it. Please report problems to the development mailing list.</p>
### Checkpointing and Fault Tolerance
With checkpointing enabled, Cassandra Sink guarantees at-least-once delivery of action requests to C* instance.
http://git-wip-us.apache.org/repos/asf/flink/blob/1e7d5bee/docs/dev/connectors/kafka.md
----------------------------------------------------------------------
diff --git a/docs/dev/connectors/kafka.md b/docs/dev/connectors/kafka.md
index 5785ceb..5d3e66d 100644
--- a/docs/dev/connectors/kafka.md
+++ b/docs/dev/connectors/kafka.md
@@ -648,7 +648,7 @@ we retrieved and emitted successfully. The `committed-offsets` is the last commi
The Kafka Consumers in Flink commit the offsets back to Zookeeper (Kafka 0.8) or the Kafka brokers (Kafka 0.9+). If checkpointing
is disabled, offsets are committed periodically.
With checkpointing, the commit happens once all operators in the streaming topology have confirmed that they've created a checkpoint of their state.
-This provides users with at-least-once semantics for the offsets committed to Zookeer or the broker. For offsets checkpointed to Flink, the system
+This provides users with at-least-once semantics for the offsets committed to Zookeeper or the broker. For offsets checkpointed to Flink, the system
provides exactly once guarantees.
The offsets committed to ZK or the broker can also be used to track the read progress of the Kafka consumer. The difference between
http://git-wip-us.apache.org/repos/asf/flink/blob/1e7d5bee/docs/dev/event_timestamps_watermarks.md
----------------------------------------------------------------------
diff --git a/docs/dev/event_timestamps_watermarks.md b/docs/dev/event_timestamps_watermarks.md
index 961948f..802a079 100644
--- a/docs/dev/event_timestamps_watermarks.md
+++ b/docs/dev/event_timestamps_watermarks.md
@@ -61,7 +61,7 @@ There are two ways to assign timestamps and generate watermarks:
2. Via a timestamp assigner / watermark generator: in Flink timestamp assigners also define the watermarks to be emitted
<span class="label label-danger">Attention</span> Both timestamps and watermarks are specified as
-millliseconds since the Java epoch of 1970-01-01T00:00:00Z.
+milliseconds since the Java epoch of 1970-01-01T00:00:00Z.
### Source Functions with Timestamps and Watermarks
@@ -338,7 +338,7 @@ Kafka consumer, per Kafka partition, and the per-partition watermarks are merged
For example, if event timestamps are strictly ascending per Kafka partition, generating per-partition watermarks with the
[ascending timestamps watermark generator](event_timestamp_extractors.html#assigners-with-ascending-timestamps) will result in perfect overall watermarks.
-The illustrations below show how to use ther per-Kafka-partition watermark generation, and how watermarks propagate through the
+The illustrations below show how to use the per-Kafka-partition watermark generation, and how watermarks propagate through the
streaming dataflow in that case.
http://git-wip-us.apache.org/repos/asf/flink/blob/1e7d5bee/docs/dev/java8.md
----------------------------------------------------------------------
diff --git a/docs/dev/java8.md b/docs/dev/java8.md
index df1e088..eb9a290 100644
--- a/docs/dev/java8.md
+++ b/docs/dev/java8.md
@@ -46,8 +46,8 @@ env.fromElements(1, 2, 3)
~~~
The next two examples show different implementations of a function that uses a `Collector` for output.
-Functions, such as `flatMap()`, require a output type (in this case `String`) to be defined for the `Collector` in order to be type-safe.
-If the `Collector` type can not be inferred from the surrounding context, it need to be declared in the Lambda Expression's parameter list manually.
+Functions, such as `flatMap()`, require an output type (in this case `String`) to be defined for the `Collector` in order to be type-safe.
+If the `Collector` type can not be inferred from the surrounding context, it needs to be declared in the Lambda Expression's parameter list manually.
Otherwise the output will be treated as type `Object` which can lead to undesired behaviour.
~~~java
http://git-wip-us.apache.org/repos/asf/flink/blob/1e7d5bee/docs/dev/stream/state/queryable_state.md
----------------------------------------------------------------------
diff --git a/docs/dev/stream/state/queryable_state.md b/docs/dev/stream/state/queryable_state.md
index 4bbc043..8012f67 100644
--- a/docs/dev/stream/state/queryable_state.md
+++ b/docs/dev/stream/state/queryable_state.md
@@ -261,7 +261,7 @@ val keySerializer = createTypeInformation[Long]
.createSerializer(new ExecutionConfig)
```
-If you don't do this, you can run into mismatches between the serializers used in the Flink job and in your client code, because types like `scala.Long` cannot be caputured at runtime.
+If you don't do this, you can run into mismatches between the serializers used in the Flink job and in your client code, because types like `scala.Long` cannot be captured at runtime.
## Configuration
http://git-wip-us.apache.org/repos/asf/flink/blob/1e7d5bee/docs/quickstart/scala_api_quickstart.md
----------------------------------------------------------------------
diff --git a/docs/quickstart/scala_api_quickstart.md b/docs/quickstart/scala_api_quickstart.md
index 601ce24..378038e 100644
--- a/docs/quickstart/scala_api_quickstart.md
+++ b/docs/quickstart/scala_api_quickstart.md
@@ -41,7 +41,7 @@ These templates help you to set up the project structure and to create the initi
### Create Project
-You can scafold a new project via either of the following two methods:
+You can scaffold a new project via either of the following two methods:
<ul class="nav nav-tabs" style="border-bottom: none;">
<li class="active"><a href="#sbt_template" data-toggle="tab">Use the <strong>sbt template</strong></a></li>
@@ -53,7 +53,7 @@ You can scafold a new project via either of the following two methods:
{% highlight bash %}
$ sbt new tillrohrmann/flink-project.g8
{% endhighlight %}
- This will will prompt you for a couple of parameters (project name, flink version...) and then create a Flink project from the <a href="https://github.com/tillrohrmann/flink-project.g8">flink-project template</a>.
+ This will prompt you for a couple of parameters (project name, flink version...) and then create a Flink project from the <a href="https://github.com/tillrohrmann/flink-project.g8">flink-project template</a>.
You need sbt >= 0.13.13 to execute this command. You can follow this <a href="http://www.scala-sbt.org/download.html">installation guide</a> to obtain it if necessary.
</div>
<div class="tab-pane" id="quickstart-script-sbt">
[2/3] flink git commit: [hotfix] [docs] Fix typo in monitoring REST
API documentation
Posted by se...@apache.org.
[hotfix] [docs] Fix typo in monitoring REST API documentation
This closes #4854
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/90fc20f3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/90fc20f3
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/90fc20f3
Branch: refs/heads/master
Commit: 90fc20f3af123f05282290c73929b3f86d2dba4f
Parents: 1e7d5be
Author: Mike Kobit <mk...@gmail.com>
Authored: Wed Oct 18 12:33:36 2017 -0500
Committer: Stephan Ewen <se...@apache.org>
Committed: Tue Oct 24 19:19:05 2017 +0200
----------------------------------------------------------------------
docs/monitoring/rest_api.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/90fc20f3/docs/monitoring/rest_api.md
----------------------------------------------------------------------
diff --git a/docs/monitoring/rest_api.md b/docs/monitoring/rest_api.md
index 4202886..e74d8b7 100644
--- a/docs/monitoring/rest_api.md
+++ b/docs/monitoring/rest_api.md
@@ -134,7 +134,7 @@ Sample Result:
**`/joboverview`**
-Jobs, groupes by status, each with a small summary of its status.
+Jobs, grouped by status, each with a small summary of its status.
Sample Result: