This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit c4dde346b7bc464b5c550deda36b8a4a3f769ac6 Author: Chesnay Schepler <[email protected]> AuthorDate: Wed Jun 15 13:23:07 2022 +0200 [hotfix][tests] Clarify interface These 2 methods were never used via the gateway, but are called directly on the instance. This was misleading because I couldn't figure out why the serialization didn't fail for these methods. --- .../flink/runtime/rpc/akka/ContextClassLoadingSettingTest.java | 6 ------ 1 file changed, 6 deletions(-) diff --git a/flink-rpc/flink-rpc-akka/src/test/java/org/apache/flink/runtime/rpc/akka/ContextClassLoadingSettingTest.java b/flink-rpc/flink-rpc-akka/src/test/java/org/apache/flink/runtime/rpc/akka/ContextClassLoadingSettingTest.java index 265adf5f074..68c10067f3e 100644 --- a/flink-rpc/flink-rpc-akka/src/test/java/org/apache/flink/runtime/rpc/akka/ContextClassLoadingSettingTest.java +++ b/flink-rpc/flink-rpc-akka/src/test/java/org/apache/flink/runtime/rpc/akka/ContextClassLoadingSettingTest.java @@ -359,10 +359,6 @@ class ContextClassLoadingSettingTest { CompletableFuture<Void> doSomethingAsync(); - CompletableFuture<ClassLoader> doCallAsync(); - - CompletableFuture<ClassLoader> doRunAsync(); - void doSomethingWithoutReturningAnything(); CompletableFuture<PickyObject> getPickyObject(); @@ -414,13 +410,11 @@ class ContextClassLoadingSettingTest { return rpcResponseFuture; } - @Override public CompletableFuture<ClassLoader> doCallAsync() { return callAsync( () -> Thread.currentThread().getContextClassLoader(), Duration.ofSeconds(10)); } - @Override public CompletableFuture<ClassLoader> doRunAsync() { final CompletableFuture<ClassLoader> contextClassLoader = new CompletableFuture<>(); runAsync(
