public int getRPCPort() {
        return flinkConfig.get(JobManagerOptions.PORT);
    }
@Test
    void testGetRpcPort() {
        flinkConfig.set(JobManagerOptions.PORT, 1234);
        assertThat(kubernetesJobManagerParameters.getRPCPort()).isEqualTo(1234);
    }