@Override
    public String getConfigDirectory() {
        final String configDir =
                flinkConfig
                        .getOptional(DeploymentOptionsInternal.CONF_DIR)
                        .orElse(flinkConfig.get(KubernetesConfigOptions.FLINK_CONF_DIR));

        checkNotNull(configDir);
        return configDir;
    }
@Test
    void getConfigDirectory() {
        final String confDir = "/path/of/flink-conf";
        flinkConfig.set(DeploymentOptionsInternal.CONF_DIR, confDir);
        assertThat(testingKubernetesParameters.getConfigDirectory()).isEqualTo(confDir);
    }