You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2018/09/19 06:05:49 UTC
[flink] branch master updated (cc37d7a -> 3292dc5)
This is an automated email from the ASF dual-hosted git repository.
gary pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from cc37d7a [FLINK-10079] [table] Look up sink tables in external catalogs.
new 2e2299d [hotfix][flink-streaming-java] Fix typo in variable name in StreamingJobGraphGenerator.
new 3292dc5 [hotfix][flink-streaming-java] Fix typo in OperatorChain.
The 2 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:
.../flink/streaming/api/graph/StreamingJobGraphGenerator.java | 8 ++++----
.../org/apache/flink/streaming/runtime/tasks/OperatorChain.java | 2 +-
2 files changed, 5 insertions(+), 5 deletions(-)
[flink] 01/02: [hotfix][flink-streaming-java] Fix typo in variable
name in StreamingJobGraphGenerator.
Posted by ga...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 2e2299db76ccb5fec2c3aef5900e4a5e46921ec2
Author: unknown <ma...@ad1-zwt.corp.qihoo.net>
AuthorDate: Tue Aug 21 16:36:23 2018 +0800
[hotfix][flink-streaming-java] Fix typo in variable name in StreamingJobGraphGenerator.
This closes #6593.
---
.../flink/streaming/api/graph/StreamingJobGraphGenerator.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
index e905eac..0ce5225 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
@@ -440,12 +440,12 @@ public class StreamingJobGraphGenerator {
config.setTimeCharacteristic(streamGraph.getEnvironment().getStreamTimeCharacteristic());
- final CheckpointConfig ceckpointCfg = streamGraph.getCheckpointConfig();
+ final CheckpointConfig checkpointCfg = streamGraph.getCheckpointConfig();
config.setStateBackend(streamGraph.getStateBackend());
- config.setCheckpointingEnabled(ceckpointCfg.isCheckpointingEnabled());
- if (ceckpointCfg.isCheckpointingEnabled()) {
- config.setCheckpointMode(ceckpointCfg.getCheckpointingMode());
+ config.setCheckpointingEnabled(checkpointCfg.isCheckpointingEnabled());
+ if (checkpointCfg.isCheckpointingEnabled()) {
+ config.setCheckpointMode(checkpointCfg.getCheckpointingMode());
}
else {
// the "at-least-once" input handler is slightly cheaper (in the absence of checkpoints),
[flink] 02/02: [hotfix][flink-streaming-java] Fix typo in
OperatorChain.
Posted by ga...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3292dc5a5fb8ab589f17f90192931fd224936358
Author: unknown <ma...@ad1-zwt.corp.qihoo.net>
AuthorDate: Mon Aug 27 21:14:33 2018 +0800
[hotfix][flink-streaming-java] Fix typo in OperatorChain.
This closes #6619.
---
.../java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
index 015b7db..d49b023 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
@@ -315,7 +315,7 @@ public class OperatorChain<OUT, OP extends StreamOperator<OUT>> implements Strea
return allOutputs.get(0).f0;
}
else {
- // send to N outputs. Note that this includes teh special case
+ // send to N outputs. Note that this includes the special case
// of sending to zero outputs
@SuppressWarnings({"unchecked", "rawtypes"})
Output<StreamRecord<T>>[] asArray = new Output[allOutputs.size()];