diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestServerEndpointITCase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestServerEndpointITCase.java index bcc1ee07f0e2a..779da4ff7b170 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestServerEndpointITCase.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestServerEndpointITCase.java @@ -154,6 +154,9 @@ public static Collection data() throws Exception { final Configuration sslConfig = new Configuration(config); sslConfig.set(SecurityOptions.SSL_REST_ENABLED, true); + sslConfig.set( + SecurityOptions.SSL_ALGORITHMS, + "TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256,TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384"); sslConfig.set(SecurityOptions.SSL_REST_TRUSTSTORE, truststorePath); sslConfig.set(SecurityOptions.SSL_REST_TRUSTSTORE_PASSWORD, "password"); sslConfig.set(SecurityOptions.SSL_REST_KEYSTORE, keystorePath); diff --git a/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientSSLTest.java b/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientSSLTest.java index 627361edaf941..4b44f05536230 100644 --- a/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientSSLTest.java +++ b/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientSSLTest.java @@ -76,6 +76,9 @@ void testGatewayMode() throws Exception { private static void withSSL(Configuration configuration) { configuration.set(SecurityOptions.SSL_REST_ENABLED, true); + configuration.set( + SecurityOptions.SSL_ALGORITHMS, + "TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256,TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384"); configuration.set(SecurityOptions.SSL_REST_TRUSTSTORE, truststorePath); configuration.set(SecurityOptions.SSL_REST_TRUSTSTORE_PASSWORD, "password"); configuration.set(SecurityOptions.SSL_REST_KEYSTORE, keystorePath);