@Override
    public void killProcess(final String processId) throws SQLException {
        Process process = ProcessRegistry.getInstance().get(processId);
        if (null == process) {
            return;
        }
        for (Statement each : process.getProcessStatements().values()) {
            each.cancel();
        }
    }
@Test
    void assertKillProcess() throws SQLException {
        ProcessRegistry processRegistry = mock(ProcessRegistry.class);
        when(ProcessRegistry.getInstance()).thenReturn(processRegistry);
        Process process = mock(Process.class);
        Statement statement = mock(Statement.class);
        when(process.getProcessStatements()).thenReturn(Collections.singletonMap(1, statement));
        when(processRegistry.get(any())).thenReturn(process);
        processPersistService.killProcess("foo_process_id");
        verify(statement).cancel();
    }