public int getBlobServerPort() {
        final int blobServerPort = KubernetesUtils.parsePort(flinkConfig, BlobServerOptions.PORT);
        checkArgument(blobServerPort > 0, "%s should not be 0.", BlobServerOptions.PORT.key());
        return blobServerPort;
    }
@Test
    void testGetBlobServerPortException1() {
        flinkConfig.set(BlobServerOptions.PORT, "1000-2000");
        String errMsg =
                BlobServerOptions.PORT.key()
                        + " should be specified to a fixed port. Do not support a range of ports.";
        assertThatThrownBy(
                        () -> kubernetesJobManagerParameters.getBlobServerPort(),
                        "Should fail with an exception.")
                .satisfies(
                        cause ->
                                assertThat(cause)
                                        .isInstanceOf(FlinkRuntimeException.class)
                                        .hasMessageMatching(errMsg));
    }