@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 getConfigDirectoryFallbackToPodConfDir() {
        final String confDirInPod = flinkConfig.get(KubernetesConfigOptions.FLINK_CONF_DIR);
        assertThat(testingKubernetesParameters.getConfigDirectory()).isEqualTo(confDirInPod);
    }