[
https://issues.apache.org/jira/browse/FLINK-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14634902#comment-14634902
]
ASF GitHub Bot commented on FLINK-2371:
---------------------------------------
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/925#discussion_r35087953
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/FlinkMiniCluster.scala
---
@@ -51,10 +51,13 @@ import scala.concurrent.{ExecutionContext, Future,
Await}
abstract class FlinkMiniCluster(
val userConfiguration: Configuration,
val singleActorSystem: Boolean,
+ val synchronousDispatcher: Boolean,
val streamingMode: StreamingMode) {
- def this(userConfiguration: Configuration, singleActorSystem: Boolean)
- = this(userConfiguration, singleActorSystem,
StreamingMode.BATCH_ONLY)
+ def this(userConfiguration: Configuration,
+ singleActorSystem: Boolean,
+ synchronousDispatcher: Boolean)
+ = this(userConfiguration, singleActorSystem, synchronousDispatcher,
StreamingMode.BATCH_ONLY)
--- End diff --
Good catch. I noticed that as well and already changed that before I saw
your answer. Now only the `TestingCluster` is affected by the changes.
> AccumulatorLiveITCase fails
> ---------------------------
>
> Key: FLINK-2371
> URL: https://issues.apache.org/jira/browse/FLINK-2371
> Project: Flink
> Issue Type: Bug
> Components: Tests
> Reporter: Matthias J. Sax
> Assignee: Maximilian Michels
>
> AccumulatorLiveITCase fails regularly (however, not in each run). The tests
> relies on timing (via sleep) which does not work well on Travis.
> See dev-list for more details:
> https://mail-archives.apache.org/mod_mbox/flink-dev/201507.mbox/browser
> AccumulatorLiveITCase.testProgram:106->access$1100:68->checkFlinkAccumulators:189
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
