taegeonum commented on a change in pull request #129: [NEMO-8] Implement
PipeManagerMaster/Worker
URL: https://github.com/apache/incubator-nemo/pull/129#discussion_r228421084
##########
File path:
examples/beam/src/test/java/org/apache/nemo/examples/beam/WindowedWordCountITCase.java
##########
@@ -84,4 +81,45 @@ public void testSlidingWindow() throws Exception {
ExampleTestUtil.deleteOutputFile(fileBasePath, outputFileName);
}
}
+
+ @Test (timeout = TIMEOUT)
+ public void testStreamingFixedWindow() throws Exception {
Review comment:
The method name is awkward to me because it is not actually process
streaming data. This just uses streaming scheduler that holds all Tasks and it
just tests whether holding all tasks returns the same result of scheduling each
stage (batch).
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
