Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6120
---
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r203605524
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
---
@@ -545,15 +543,15 @@ public IntervalJoined(
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r203083498
--- Diff:
flink-core/src/test/java/org/apache/flink/api/java/typeutils/LambdaExtractionTest.java
---
@@ -271,19 +214,20 @@ public void
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r203060212
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/util/JarFileCreatorTest.java
---
@@ -102,15 +104,62 @@ public void
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r203040441
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/util/JarFileCreatorTest.java
---
@@ -102,15 +104,62 @@ public void
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r203021961
--- Diff:
flink-core/src/test/java/org/apache/flink/api/java/typeutils/LambdaExtractionTest.java
---
@@ -50,12 +41,12 @@
import static
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r203002928
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/util/JarFileCreatorTest.java
---
@@ -102,15 +104,62 @@ public void
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r203001399
--- Diff:
flink-core/src/test/java/org/apache/flink/api/java/typeutils/LambdaExtractionTest.java
---
@@ -271,19 +214,20 @@ public void
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r203003680
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
---
@@ -237,19 +248,81 @@ private boolean
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r203001023
--- Diff:
flink-core/src/test/java/org/apache/flink/api/java/typeutils/LambdaExtractionTest.java
---
@@ -50,12 +41,12 @@
import static
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r202553410
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -584,21 +581,6 @@ private static void registerFactory(Type
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r202552984
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -584,21 +581,6 @@ private static void registerFactory(Type
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r201662934
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -119,19 +120,15 @@ public boolean filter(Event value) throws
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r201655890
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -584,21 +581,6 @@ private static void
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r201657797
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -695,29 +678,14 @@ private static void
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6120#discussion_r201655466
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -584,21 +581,6 @@ private static void
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/6120
[FLINK-7251] [types] Remove the flink-java8 module and improve lambda type
extraction
## What is the purpose of the change
This PR merge the `flink-java8` module into
17 matches
Mail list logo
