如何以编程方式优雅终止Statefun Harness？（Cucumber测试场景）

核心问题拆解 #

问题出在测试harness默认终止逻辑可能触发System.exit()或JVM异常退出，导致Surefire判定VM崩溃。下面的方案既能保留动态Ingress（支持消息延迟、多Ingress复杂场景），又能解决优雅终止的问题：

方案1：重写Harness终止逻辑，避免强制退出JVM #

扩展StatefulFunctionsTestHarness类，替换默认的终止逻辑，手动关闭内部组件而非直接终止JVM。在Cucumber的@After钩子中执行自定义清理：

@After
public void tearDown() {
    // 先停掉所有动态Ingress的消息发送线程（比如延迟消息的调度线程）
    dynamicIngressScheduler.shutdownNow();
    // 优雅关闭Flink MiniCluster
    testHarness.getMiniCluster().close();
    // 清空资源引用，帮助GC回收
    testHarness = null;
}

这样能确保所有Flink内部线程、组件正常结束，不会触发Surefire的崩溃误判。

方案2：调整Surefire插件配置，放宽退出判定 #

如果无法修改harness代码，直接在pom.xml中配置Surefire，给JVM留足清理时间并允许正常退出：

<plugin>
    <groupId>org.apache.maven.plugins</groupId>
    <artifactId>maven-surefire-plugin</artifactId>
    <version>你的插件版本</version>
    <configuration>
        <forkCount>1</forkCount>
        <reuseForks>false</reuseForks>
        <!-- 允许JVM有5秒时间完成退出前的清理 -->
        <argLine>-Dsurefire.exitTimeout=5</argLine>
        <redirectTestOutputToFile>true</redirectTestOutputToFile>
    </configuration>
</plugin>

方案3：用内存队列解耦动态Ingress与测试流程 #

用内存消息队列（比如LinkedBlockingQueue）作为Ingress的消息缓冲区，测试步骤中发送的延迟、多Ingress消息先入队，再由独立线程消费并发送到Flink：

• 测试启动时启动消费线程，负责从队列取消息并推送到Ingress
• 测试结束时先中断消费线程，再关闭harness
  这种方式既保留了动态消息的灵活性，又能完全控制线程生命周期，避免残留线程导致JVM异常退出。

方案4：用Flink工具类辅助优雅终止 #

部分Flink版本提供TestHarnessUtil工具类，包含标准化的资源关闭方法：

TestHarnessUtil.stopExecutorServices(testHarness.getExecutorService());
TestHarnessUtil.shutdownMiniCluster(testHarness.getMiniCluster());

调用这些方法能确保Flink内部线程池、MiniCluster等资源被正确释放，避免强制退出。

内容的提问来源于stack exchange，提问作者Gray