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:50 UTC
[flink] 01/02: [hotfix][flink-streaming-java] Fix typo in variable
name in StreamingJobGraphGenerator.
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),