flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dwysakow...@apache.org
Subject flink git commit: [hotfix] Removed lamba indices for type extraction for abstract classes
Date Sat, 17 Jun 2017 10:33:09 GMT
Repository: flink
Updated Branches:
  refs/heads/master f27cb2ac9 -> afb0b630c


[hotfix] Removed lamba indices for type extraction for abstract classes


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/afb0b630
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/afb0b630
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/afb0b630

Branch: refs/heads/master
Commit: afb0b630c5fc14196001bbb98db6a510e4c0ff4c
Parents: f27cb2a
Author: Dawid Wysakowicz <dwysakowicz@apache.org>
Authored: Sat Jun 17 12:00:49 2017 +0200
Committer: Dawid Wysakowicz <dwysakowicz@apache.org>
Committed: Sat Jun 17 12:00:49 2017 +0200

----------------------------------------------------------------------
 .../apache/flink/streaming/api/datastream/AllWindowedStream.java | 4 ++--
 .../org/apache/flink/streaming/api/datastream/DataStream.java    | 4 ++--
 .../org/apache/flink/streaming/api/datastream/KeyedStream.java   | 4 ++--
 .../apache/flink/streaming/api/datastream/WindowedStream.java    | 4 ++--
 4 files changed, 8 insertions(+), 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/afb0b630/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java
index ae97109..b0f31e1 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java
@@ -533,8 +533,8 @@ public class AllWindowedStream<T, W extends Window> {
 			ProcessAllWindowFunction.class,
 			0,
 			1,
-			new int[]{1, 0},
-			new int[]{2, 0},
+			TypeExtractor.NO_INDEX,
+			TypeExtractor.NO_INDEX,
 			inType,
 			null,
 			false);

http://git-wip-us.apache.org/repos/asf/flink/blob/afb0b630/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
index 66cd8e6..d0769c6 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
@@ -578,8 +578,8 @@ public class DataStream<T> {
 			ProcessFunction.class,
 			0,
 			1,
-			new int[]{0},
-			new int[]{2, 0},
+			TypeExtractor.NO_INDEX,
+			TypeExtractor.NO_INDEX,
 			getType(),
 			Utils.getCallLocationName(),
 			true);

http://git-wip-us.apache.org/repos/asf/flink/blob/afb0b630/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
----------------------------------------------------------------------
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 851e614..55b2d45 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
@@ -271,8 +271,8 @@ public class KeyedStream<T, KEY> extends DataStream<T> {
 			ProcessFunction.class,
 			0,
 			1,
-			new int[]{0},
-			new int[]{2, 0},
+			TypeExtractor.NO_INDEX,
+			TypeExtractor.NO_INDEX,
 			getType(),
 			Utils.getCallLocationName(),
 			true);

http://git-wip-us.apache.org/repos/asf/flink/blob/afb0b630/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
index a795064..348861f 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
@@ -1005,8 +1005,8 @@ public class WindowedStream<T, K, W extends Window> {
 			ProcessWindowFunction.class,
 			0,
 			1,
-			new int[]{2, 0},
-			new int[]{3, 0},
+			TypeExtractor.NO_INDEX,
+			TypeExtractor.NO_INDEX,
 			inType,
 			functionName,
 			false);


Mime
View raw message