[FLINK-28404] Annotation @InjectClusterClient does not work correctly with RestClusterClient

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.16.0, 1.15.2
• Component/s: Tests
• Labels: pull-request-available
• Assignee: Chesnay Schepler
• Reporter: zhouli
• Created: 05/Jul/22 11:28
• Updated: 06/Jul/22 08:56
• Resolved: 06/Jul/22 08:54

Description

test code:

public class Test {

    @RegisterExtension
    private static final MiniClusterExtension MINI_CLUSTER_RESOURCE =
            new MiniClusterExtension(
                    new MiniClusterResourceConfiguration.Builder()
                            .setNumberTaskManagers(1)
                            .setNumberSlotsPerTaskManager(4)
                            .build());

    @org.junit.jupiter.api.Test
    void test(@InjectClusterClient RestClusterClient<?> restClusterClient) throws Exception {
        Object clusterId = restClusterClient.getClusterId();
    }
} 

error info:

org.junit.jupiter.api.extension.ParameterResolutionException: No ParameterResolver registered for parameter [org.apache.flink.client.program.rest.RestClusterClient<?> arg0] in method... 

this problem occurs because MiniClusterExtension#supportsParameter does not support RestClusterClient parameterType. 

Issue Links

• links to: GitHub Pull Request #20171