Github user pnowojski closed the pull request at:
https://github.com/apache/flink/pull/4851
---
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r146551851
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java
---
@@ -370,6 +371,10 @@ public void endIn
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145921473
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145921058
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/AcknowledgeStreamMockEnvironment.java
---
@@ -0,0 +1,65 @@
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145920720
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145902939
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/AcknowledgeStreamMockEnvironment.java
---
@@ -0,0 +1,65 @@
+/*
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145903567
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+ * Lic
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145917932
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+ * Lic
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145903139
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+ * Lic
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145915808
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+ * Lic
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145917513
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+ * Lic
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145885868
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145879846
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145879772
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145878649
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145878457
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145878181
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145877990
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145877847
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/RestoreStreamTaskTest.java
---
@@ -0,0 +1,325 @@
+/*
+
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r145877337
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/AcknowledgeStreamMockEnvironment.java
---
@@ -0,0 +1,65 @@
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/4851
[FLINK-7623][tests] Add tests to make sure operator is never restored when
using new operator id
## What is the purpose of the change
This PR adds tests coverage for correct behaviour of
21 matches
Mail list logo