static Type stringMapType = new TypeToken<Map<String, String>>() { }.getType();
static Type objectMapType = new TypeToken<Map<String, Object>>() { }.getType();
@Test
public void testWordCount() throws Exception {
ApplicationManager appManager = deployApplication(WordCount.class);
<BUG>appManager.startFlow("WordCounter");
</BUG>
StreamManager streamManager = getStreamManager("wordStream");
streamManager.send("hello world");
streamManager.send("a wonderful world");

static Type stringMapType = new TypeToken<Map<String, String>>() { }.getType();
static Type objectMapType = new TypeToken<Map<String, Object>>() { }.getType();
@Test
public void testWordCount() throws Exception {
ApplicationManager appManager = deployApplication(WordCount.class);
appManager.getFlowManager("WordCounter").start();
StreamManager streamManager = getStreamManager("wordStream");
streamManager.send("hello world");
streamManager.send("a wonderful world");
