[
https://issues.apache.org/jira/browse/FLINK-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14634756#comment-14634756
]
ASF GitHub Bot commented on FLINK-2371:
---------------------------------------
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/925#discussion_r35079360
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/accumulators/AccumulatorLiveITCase.java
---
@@ -109,125 +123,157 @@ public void testProgram() throws Exception {
ExecutionEnvironment env = new PlanExtractor();
DataSet<String> input = env.fromCollection(inputData);
input
- .flatMap(new Tokenizer())
.flatMap(new WaitingUDF())
.output(new WaitingOutputFormat());
env.execute();
- /** Extract job graph **/
+ // Extract job graph and set job id for the task to
notify of accumulator changes.
JobGraph jobGraph = getOptimizedPlan(((PlanExtractor)
env).plan);
+ jobID = jobGraph.getJobID();
+
+ // register for accumulator changes
+ jobManager.tell(new
TestingJobManagerMessages.NotifyWhenAccumulatorChange(jobID), getRef());
+ expectMsgEquals(true);
+ // submit job
jobManager.tell(new
JobManagerMessages.SubmitJob(jobGraph, false), getRef());
expectMsgClass(Status.Success.class);
--- End diff --
Same here. Best if you nest all actor interaction in a `within` block.
> 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)
