Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1103
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1103#issuecomment-138922680
Testing my patch, then merging this...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your projec
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1103#issuecomment-138868908
Thanks for clarifying. I added a commit for the manual test.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1103#issuecomment-138868121
Okay, the issue is that this mock execution never reaches a "FAILED" state
in time, because the canceling of the other vertices (after one failed) is
never acknowled
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1103#issuecomment-138862613
Okay, let me merge your code and try to fix this test on the way...
---
If your project is set up for it, you can reply to this email and have your
reply appea
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1103#issuecomment-138497195
@StephanEwen Do you mean `ExecutionGraphRestartTest`? When I increased
slots in test instance, I got another exception. Exception log is following:
```
or
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1103#issuecomment-138489873
Looks, good, but one of the tests seems to be actually in error. I think
that the instance created in the test simply does not have enough slots, so the
test executi
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1103#discussion_r38904456
--- Diff:
flink-tests/src/test/scala/org/apache/flink/api/scala/misc/MassiveCaseClassSortingITCase.scala
---
@@ -35,11 +35,13 @@ import
org.apache.flink
GitHub user chiwanpark opened a pull request:
https://github.com/apache/flink/pull/1103
[FLINK-2619] [tests] Fix for some unexecuted Scala tests
This PR includes to resolve FLINK-2619. The changes are following:
* Add JUnitRunner(`@RunWith(classOf[JUnitRunner])`) for unexecu
