<BUG>RuntimeMetrics terminalMetrics = RuntimeStats.getFlowletMetrics("JoinMulti", "JoinMultiFlow", "Terminal");terminalMetrics.waitForProcessed(3, 5, TimeUnit.SECONDS);</BUG><CONTEXT>StreamWriter s2 = applicationManager.getStreamWriter("s2");StreamWriter s3 = applicationManager.getStreamWriter("s3");s1.send("testing 1");s2.send("testing 2");s3.send("testing 3");<extra_id_0>TimeUnit.SECONDS.sleep(1);ProcedureManager queryManager = applicationManager.startProcedure("Query");</CONTEXT>
RuntimeMetrics terminalMetrics = RuntimeStats.getFlowletMetrics(testSpace.getId(), "JoinMulti",terminalMetrics.waitForProcessed(3, 5, TimeUnit.SECONDS);