You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "zl (Jira)" <ji...@apache.org> on 2022/07/05 11:29:00 UTC
[jira] [Created] (FLINK-28404) Annotation @InjectClusterClient do not work correctly
zl created FLINK-28404:
--------------------------
Summary: Annotation @InjectClusterClient do not work correctly
Key: FLINK-28404
URL: https://issues.apache.org/jira/browse/FLINK-28404
Project: Flink
Issue Type: Bug
Components: Tests
Reporter: zl
*test code:*
{code:java}
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();
}
} {code}
*error info:*
{code:java}
org.junit.jupiter.api.extension.ParameterResolutionException: No ParameterResolver registered for parameter [org.apache.flink.client.program.rest.RestClusterClient<?> arg0] in method... {code}
this problem occurs because [MiniClusterExtension#supportsParameter|https://github.com/apache/flink/blob/master/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/junit5/MiniClusterExtension.java#L168] does not support *_RestClusterClient_* parameterType.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)