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 testGetBlobServerPortException2() {
        flinkConfig.set(BlobServerOptions.PORT, "0");
        assertThatThrownBy(
                        () -> kubernetesJobManagerParameters.getBlobServerPort(),
                        "Should fail with an exception.")
                .satisfies(
                        cause ->
                                assertThat(cause)
                                        .isInstanceOf(IllegalArgumentException.class)
                                        .hasMessageMatching(
                                                BlobServerOptions.PORT.key()
                                                        + " should not be 0."));
    }