For integration tests, copy function logs out of container on shutdown for...

For integration tests, copy function logs out of container on shutdown for debugging purposes (#3529)

tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/WorkerContainer.java

@@ -18,6 +18,8 @@
  */
 package org.apache.pulsar.tests.integration.containers;
 
+import org.apache.pulsar.tests.integration.utils.DockerUtils;
+
 /**
  * A pulsar container that runs functions worker.
  */
@@ -35,4 +37,16 @@ public class WorkerContainer extends PulsarContainer<WorkerContainer> {
             BROKER_HTTP_PORT,
             "/admin/v2/worker/cluster");
     }
+
+    @Override
+    protected void beforeStop() {
+        super.beforeStop();
+        if (null != containerId) {
+            DockerUtils.dumpContainerDirToTargetCompressed(
+                    getDockerClient(),
+                    containerId,
+                    "/pulsar/logs/functions"
+            );
+        }
+    }
 }

tests/integration/src/test/java/org/apache/pulsar/tests/integration/utils/DockerUtils.java

@@ -24,6 +24,7 @@ import com.github.dockerjava.api.DockerClient;
 import com.github.dockerjava.api.async.ResultCallback;
 import com.github.dockerjava.api.command.InspectContainerResponse;
 import com.github.dockerjava.api.command.InspectExecResponse;
+import com.github.dockerjava.api.exception.NotFoundException;
 import com.github.dockerjava.api.model.ContainerNetwork;
 import com.github.dockerjava.api.model.Frame;
 import com.github.dockerjava.api.model.StreamType;
@@ -140,7 +141,9 @@ public class DockerUtils {
                 read = dockerStream.read(block, 0, READ_BLOCK_SIZE);
             }
         } catch (RuntimeException|IOException e) {
-            LOG.error("Error reading dir from container {}", containerName, e);
+            if (!(e instanceof NotFoundException)) {
+                LOG.error("Error reading dir from container {}", containerName, e);
+            }
         }
     }