You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mb...@apache.org on 2015/04/14 15:02:14 UTC
[2/2] flink git commit: [FLINK-1866] [streaming] StreamConfig key
bugfix
[FLINK-1866] [streaming] StreamConfig key bugfix
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/54d5662f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/54d5662f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/54d5662f
Branch: refs/heads/master
Commit: 54d5662f353c19d96a4241cf9b7d7703ac2d01f8
Parents: f50d754
Author: Gyula Fora <gy...@apache.org>
Authored: Mon Apr 13 11:21:37 2015 +0200
Committer: mbalassi <mb...@apache.org>
Committed: Tue Apr 14 15:01:22 2015 +0200
----------------------------------------------------------------------
.../org/apache/flink/streaming/api/StreamConfig.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/54d5662f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamConfig.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamConfig.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamConfig.java
index c1e9606..152d489 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamConfig.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/StreamConfig.java
@@ -44,20 +44,20 @@ public class StreamConfig implements Serializable {
private static final String OUTPUT_NAME = "outputName_";
private static final String VERTEX_NAME = "vertexID";
private static final String OPERATOR_NAME = "operatorName";
- private static final String ITERATION_ID = "iteration-id";
+ private static final String ITERATION_ID = "iterationId";
private static final String OUTPUT_SELECTOR_WRAPPER = "outputSelectorWrapper";
- private static final String SERIALIZEDUDF = "serializedudf";
- private static final String USER_FUNCTION = "userfunction";
+ private static final String SERIALIZEDUDF = "serializedUDF";
+ private static final String USER_FUNCTION = "userFunction";
private static final String BUFFER_TIMEOUT = "bufferTimeout";
private static final String TYPE_SERIALIZER_IN_1 = "typeSerializer_in_1";
private static final String TYPE_SERIALIZER_IN_2 = "typeSerializer_in_2";
private static final String TYPE_SERIALIZER_OUT_1 = "typeSerializer_out_1";
private static final String TYPE_SERIALIZER_OUT_2 = "typeSerializer_out_2";
private static final String ITERATON_WAIT = "iterationWait";
- private static final String NONCHAINED_OUTPUTS = "NONCHAINED_OUTPUTS";
- private static final String EDGES_IN_ORDER = "rwOrder";
- private static final String OUT_STREAM_EDGES = "out stream edges";
- private static final String IN_STREAM_EDGES = "out stream edges";
+ private static final String NONCHAINED_OUTPUTS = "nonChainedOutputs";
+ private static final String EDGES_IN_ORDER = "edgesInOrder";
+ private static final String OUT_STREAM_EDGES = "outStreamEdges";
+ private static final String IN_STREAM_EDGES = "inStreamEdges";
// DEFAULT VALUES
private static final long DEFAULT_TIMEOUT = 100;