You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2020/09/04 15:49:50 UTC
[flink] branch master updated (5cce765 -> 6b9cdd4)
This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5cce765 [FLINK-19036][docs-zh] Translate page 'Application Profiling & Debugging' of 'Debugging & Monitoring' into Chinese
new 12b9f7f [hotfix][runtime] Remove never thrown IOException for ContinuousFileMonitoringFunction#listEligibleFiles
new e016804 [hotfix][docs] Fix typo
new 9647481 [hotfix][docs] Fix ExecutionEnvironment.scala doc error
new 6b9cdd4 [hotfix] fix typo in the javadoc
The 4 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/dev/event_timestamps_watermarks.md | 2 +-
.../src/main/java/org/apache/flink/optimizer/plan/PlanNode.java | 2 +-
.../main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala | 2 +-
.../api/functions/source/ContinuousFileMonitoringFunction.java | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
[flink] 03/04: [hotfix][docs] Fix ExecutionEnvironment.scala doc
error
Posted by rm...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9647481d5d4550635687a28db0318992b914aa30
Author: shaokan.cao <fl...@gmail.com>
AuthorDate: Fri Sep 4 10:28:43 2020 +0800
[hotfix][docs] Fix ExecutionEnvironment.scala doc error
This closes #13324
---
.../main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala b/flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala
index 309794b..951f2c9 100644
--- a/flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala
+++ b/flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala
@@ -233,7 +233,7 @@ class ExecutionEnvironment(javaEnv: JavaEnv) {
*
* @param filePath The path of the file, as a URI (e.g., "file:///some/local/file" or
* "hdfs://host:port/file/path").
- * @param charsetName The name of the character set used to read the file. Default is UTF-0
+ * @param charsetName The name of the character set used to read the file. Default is UTF-8
*/
def readTextFileWithValue(
filePath: String,
[flink] 04/04: [hotfix] fix typo in the javadoc
Posted by rm...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 6b9cdd41743edd24a929074d62a57b84e7b2dd97
Author: zhushang <zh...@qutoutiao.net>
AuthorDate: Fri Sep 4 16:39:05 2020 +0800
[hotfix] fix typo in the javadoc
This closes #13329
---
.../src/main/java/org/apache/flink/optimizer/plan/PlanNode.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/PlanNode.java b/flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/PlanNode.java
index 723c532..d39d81a 100644
--- a/flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/PlanNode.java
+++ b/flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/PlanNode.java
@@ -41,7 +41,7 @@ import java.util.Map;
import java.util.Set;
/**
- * The representation of a data exchange between to operators. The data exchange can realize a shipping strategy,
+ * The representation of a data exchange between two operators. The data exchange can realize a shipping strategy,
* which established global properties, and a local strategy, which establishes local properties.
* <p>
* Because we currently deal only with plans where the operator order is fixed, many properties are equal
[flink] 01/04: [hotfix][runtime] Remove never thrown IOException
for ContinuousFileMonitoringFunction#listEligibleFiles
Posted by rm...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 12b9f7f785995f1c3bbbffe3e7a99f39703acf3f
Author: felixzheng <fe...@gmail.com>
AuthorDate: Wed May 6 17:54:57 2020 +0800
[hotfix][runtime] Remove never thrown IOException for ContinuousFileMonitoringFunction#listEligibleFiles
This closes #12005
---
.../api/functions/source/ContinuousFileMonitoringFunction.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
index f73c23d..c6de6f1 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
@@ -297,7 +297,7 @@ public class ContinuousFileMonitoringFunction<OUT>
* Returns the paths of the files not yet processed.
* @param fileSystem The filesystem where the monitored directory resides.
*/
- private Map<Path, FileStatus> listEligibleFiles(FileSystem fileSystem, Path path) throws IOException {
+ private Map<Path, FileStatus> listEligibleFiles(FileSystem fileSystem, Path path) {
final FileStatus[] statuses;
try {
[flink] 02/04: [hotfix][docs] Fix typo
Posted by rm...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit e016804589806994092ea755d14e10b0d43e7768
Author: Alexander Fedulov <14...@users.noreply.github.com>
AuthorDate: Tue Aug 25 16:30:35 2020 +0200
[hotfix][docs] Fix typo
This closes #13241
---
docs/dev/event_timestamps_watermarks.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/dev/event_timestamps_watermarks.md b/docs/dev/event_timestamps_watermarks.md
index 3b8d766..fcb32bd 100644
--- a/docs/dev/event_timestamps_watermarks.md
+++ b/docs/dev/event_timestamps_watermarks.md
@@ -235,7 +235,7 @@ public interface WatermarkGenerator<T> {
There are two different styles of watermark generation: *periodic* and
*punctuated*.
-A periodic generator usually observes to the incoming events via `onEvent()`
+A periodic generator usually observes the incoming events via `onEvent()`
and then emits a watermark when the framework calls `onPeriodicEmit()`.
A puncutated generator will look at events in `onEvent()` and wait for special