import java.util.concurrent.TimeUnit;
public class WebAnalyticsTest extends TestBase {
@Test
public void testWebAnalytics() throws Exception {
ApplicationManager appManager = deployApplication(WebAnalytics.class);
<BUG>appManager.startFlow("WebAnalyticsFlow");
</BUG>
StreamManager streamManager = getStreamManager("log");
BufferedReader reader = new BufferedReader(new InputStreamReader(getClass().getResourceAsStream("/access.log"),
"UTF-8"));

import java.util.concurrent.TimeUnit;
public class WebAnalyticsTest extends TestBase {
@Test
public void testWebAnalytics() throws Exception {
ApplicationManager appManager = deployApplication(WebAnalytics.class);
appManager.getFlowManager("WebAnalyticsFlow").start();
StreamManager streamManager = getStreamManager("log");
BufferedReader reader = new BufferedReader(new InputStreamReader(getClass().getResourceAsStream("/access.log"),
"UTF-8"));
