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 2019/08/26 11:22:30 UTC
[flink] branch release-1.9 updated (2391a88 -> 7f8933f)
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 2391a88 [FLINK-13362][docs] Add DDL documentation for Kafka, ElasticSearch, FileSystem and formats
new ccb36ee [hotfix][docs] Correct method name in KeyedStateReaderFunction example
new 680c87c [hotfix][JavaDocs] Correct comment in KeyedStream
new ad6c46e [hotfix][table api] Fix logger arguments in CatalogManager
new 9ba0a89 [FLINK-13728][docs] Fix wrong closing tag order in sidenav
new 4fc755e [hotfix][docs] Add documentation regarding path style access for s3
new 7f8933f [hotfix][docs] Update local setup tutorials to fit new log messages
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/_includes/sidenav.html | 2 +-
docs/dev/libs/state_processor_api.md | 2 +-
docs/dev/libs/state_processor_api.zh.md | 2 +-
docs/getting-started/tutorials/local_setup.md | 2 +-
docs/getting-started/tutorials/local_setup.zh.md | 2 +-
docs/ops/filesystems/s3.md | 8 ++++++++
docs/ops/filesystems/s3.zh.md | 8 ++++++++
.../org/apache/flink/streaming/api/datastream/KeyedStream.java | 2 +-
.../main/java/org/apache/flink/table/catalog/CatalogManager.java | 4 ++--
9 files changed, 24 insertions(+), 8 deletions(-)
[flink] 04/06: [FLINK-13728][docs] Fix wrong closing tag order in
sidenav
Posted by se...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9ba0a8906e24fa864a89df65edbc95c25ec3f6dd
Author: Nico Kruber <ni...@ververica.com>
AuthorDate: Wed Aug 14 15:59:50 2019 +0200
[FLINK-13728][docs] Fix wrong closing tag order in sidenav
This closes #9439
[ci skip]
---
docs/_includes/sidenav.html | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/_includes/sidenav.html b/docs/_includes/sidenav.html
index 73edab1..cc787d9 100644
--- a/docs/_includes/sidenav.html
+++ b/docs/_includes/sidenav.html
@@ -88,7 +88,7 @@ level is determined by 'nav-pos'.
{% else %}
{% assign elementsPos = elementsPosStack | last %}
{% assign pos = posStack | last %}
-</li></ul></div>
+</ul></div></li>
{% assign elementsPosStack = elementsPosStack | pop %}
{% assign posStack = posStack | pop %}
{% endif %}
[flink] 03/06: [hotfix][table api] Fix logger arguments in
CatalogManager
Posted by se...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit ad6c46eb1321dfc4319d012f1a116ead85f3b25a
Author: Jeff Zhang <zj...@apache.org>
AuthorDate: Fri Aug 9 14:42:58 2019 +0800
[hotfix][table api] Fix logger arguments in CatalogManager
This closes #9401
---
.../src/main/java/org/apache/flink/table/catalog/CatalogManager.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java
index 5933487..aef90cc 100644
--- a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java
+++ b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java
@@ -294,8 +294,8 @@ public class CatalogManager {
LOG.info(
"Set the current default database as [{}] in the current default catalog [{}].",
- currentCatalogName,
- currentDatabaseName);
+ currentDatabaseName,
+ currentCatalogName);
}
}
[flink] 02/06: [hotfix][JavaDocs] Correct comment in KeyedStream
Posted by se...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 680c87cc557e2b71b654a79a3dd2050e41df7691
Author: stayhsfLee <yu...@gmail.com>
AuthorDate: Thu Aug 8 21:42:46 2019 +0800
[hotfix][JavaDocs] Correct comment in KeyedStream
This closes #9395
[ci skip]
---
.../java/org/apache/flink/streaming/api/datastream/KeyedStream.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
index 84df716..8c7937d 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
@@ -793,7 +793,7 @@ public class KeyedStream<T, KEY> extends DataStream<T> {
* per key.
*
* @param positionToMax
- * The field position in the data points to minimize. This is applicable to
+ * The field position in the data points to maximize. This is applicable to
* Tuple types, Scala case classes, and primitive types (which is considered
* as having one field).
* @return The transformed DataStream.
[flink] 05/06: [hotfix][docs] Add documentation regarding path
style access for s3
Posted by se...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4fc755e9f0f17ac7bdab2f645cfc24f319a5b298
Author: Achyuth Samudrala <ac...@ing.com>
AuthorDate: Mon Aug 19 08:29:13 2019 +0200
[hotfix][docs] Add documentation regarding path style access for s3
This closes #9479
[ci skip]
---
docs/ops/filesystems/s3.md | 8 ++++++++
docs/ops/filesystems/s3.zh.md | 8 ++++++++
2 files changed, 16 insertions(+)
diff --git a/docs/ops/filesystems/s3.md b/docs/ops/filesystems/s3.md
index f601b46..9794723 100644
--- a/docs/ops/filesystems/s3.md
+++ b/docs/ops/filesystems/s3.md
@@ -109,6 +109,14 @@ To do so, configure your endpoint in `flink-conf.yaml`.
s3.endpoint: your-endpoint-hostname
{% endhighlight %}
+## Configure Path Style Access
+
+Some of the S3 compliant object stores might not have virtual host style addressing enabled by default. In such cases, you will have to provide the property to enable path style access in in `flink-conf.yaml`.
+
+{% highlight yaml %}
+s3.path.style.access: true
+{% endhighlight %}
+
## Entropy injection for S3 file systems
The bundled S3 file systems (`flink-s3-fs-presto` and `flink-s3-fs-hadoop`) support entropy injection. Entropy injection is
diff --git a/docs/ops/filesystems/s3.zh.md b/docs/ops/filesystems/s3.zh.md
index f601b46..9794723 100644
--- a/docs/ops/filesystems/s3.zh.md
+++ b/docs/ops/filesystems/s3.zh.md
@@ -109,6 +109,14 @@ To do so, configure your endpoint in `flink-conf.yaml`.
s3.endpoint: your-endpoint-hostname
{% endhighlight %}
+## Configure Path Style Access
+
+Some of the S3 compliant object stores might not have virtual host style addressing enabled by default. In such cases, you will have to provide the property to enable path style access in in `flink-conf.yaml`.
+
+{% highlight yaml %}
+s3.path.style.access: true
+{% endhighlight %}
+
## Entropy injection for S3 file systems
The bundled S3 file systems (`flink-s3-fs-presto` and `flink-s3-fs-hadoop`) support entropy injection. Entropy injection is
[flink] 01/06: [hotfix][docs] Correct method name in
KeyedStateReaderFunction example
Posted by se...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit ccb36ee312f2c13618b74c54024a25cf91edf36c
Author: David Anderson <da...@alpinegizmo.com>
AuthorDate: Fri Aug 23 10:29:23 2019 +0200
[hotfix][docs] Correct method name in KeyedStateReaderFunction example
This closes #9520
[ci skip]
---
docs/dev/libs/state_processor_api.md | 2 +-
docs/dev/libs/state_processor_api.zh.md | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/dev/libs/state_processor_api.md b/docs/dev/libs/state_processor_api.md
index 676ac49..75a6f12 100644
--- a/docs/dev/libs/state_processor_api.md
+++ b/docs/dev/libs/state_processor_api.md
@@ -290,7 +290,7 @@ class ReaderFunction extends KeyedStateReaderFunction<Integer, KeyedState> {
}
@Override
- public void processKey(
+ public void readKey(
Integer key,
Context ctx,
Collector<KeyedState> out) throws Exception {
diff --git a/docs/dev/libs/state_processor_api.zh.md b/docs/dev/libs/state_processor_api.zh.md
index 676ac49..75a6f12 100644
--- a/docs/dev/libs/state_processor_api.zh.md
+++ b/docs/dev/libs/state_processor_api.zh.md
@@ -290,7 +290,7 @@ class ReaderFunction extends KeyedStateReaderFunction<Integer, KeyedState> {
}
@Override
- public void processKey(
+ public void readKey(
Integer key,
Context ctx,
Collector<KeyedState> out) throws Exception {
[flink] 06/06: [hotfix][docs] Update local setup tutorials to fit
new log messages
Posted by se...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7f8933f516ec507b03549c0108559a6070dad030
Author: tison <wa...@gmail.com>
AuthorDate: Tue Aug 20 09:59:06 2019 +0800
[hotfix][docs] Update local setup tutorials to fit new log messages
This closes #9488
[ci skip]
---
docs/getting-started/tutorials/local_setup.md | 2 +-
docs/getting-started/tutorials/local_setup.zh.md | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/getting-started/tutorials/local_setup.md b/docs/getting-started/tutorials/local_setup.md
index 799d390..a3331f2 100644
--- a/docs/getting-started/tutorials/local_setup.md
+++ b/docs/getting-started/tutorials/local_setup.md
@@ -111,7 +111,7 @@ INFO ... - ResourceManager akka.tcp://flink@localhost:6123/user/resourcemanager
INFO ... - Starting the SlotManager.
INFO ... - Dispatcher akka.tcp://flink@localhost:6123/user/dispatcher was granted leadership ...
INFO ... - Recovering all persisted jobs.
-INFO ... - Registering TaskManager ... under ... at the SlotManager.
+INFO ... - Registering TaskManager ... at ResourceManager
{% endhighlight %}
## Read the Code
diff --git a/docs/getting-started/tutorials/local_setup.zh.md b/docs/getting-started/tutorials/local_setup.zh.md
index e8ef56c..dba36df 100644
--- a/docs/getting-started/tutorials/local_setup.zh.md
+++ b/docs/getting-started/tutorials/local_setup.zh.md
@@ -111,7 +111,7 @@ INFO ... - ResourceManager akka.tcp://flink@localhost:6123/user/resourcemanager
INFO ... - Starting the SlotManager.
INFO ... - Dispatcher akka.tcp://flink@localhost:6123/user/dispatcher was granted leadership ...
INFO ... - Recovering all persisted jobs.
-INFO ... - Registering TaskManager ... under ... at the SlotManager.
+INFO ... - Registering TaskManager ... at ResourceManager
{% endhighlight %}
## Read the Code