Add async

AmateurEvents · Jan 20, 2020 · 987529f · 987529f
1 parent 96b4aa0
commit 987529f
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...tion/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java b/...tion/src/test/java/org/apache/pulsar/tests/integration/functions/PulsarFunctionsTest.java
@@ -1002,9 +1002,10 @@ public void testWindowFunction(String type, String[] expectedResults) throws Exc
         ContainerExecResult containerExecResult = pulsarCluster.getAnyWorker().execCmd(commands);
         assertTrue(containerExecResult.getStdout().contains("\"Created successfully\""));
 
-        pulsarCluster.getAnyWorker().execCmdAsync("find", ".", "-name", "*.log");
+        pulsarCluster.getAnyWorker().execCmdAsync("find", ".", "-name", "/tmp/functions");
 
-        pulsarCluster.getAnyWorker().execCmdAsync("tail", "-f", "/pulsar/logs/functions/public/default/" + functionName + "/" + functionName + "-0" + ".log");
+        // /tmp/functions/public/default/test-sliding-window-fn-shstbkai
+        pulsarCluster.getAnyWorker().execCmdAsync("tail", "-f", "/tmp/functions/public/default/" + functionName + "/" + functionName + "-0" + ".log");
         // get function info
         getFunctionInfoSuccess(functionName);