This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.15 by this push: new 6feaa440ffc [FLINK-29927][akka] Use singleton ExtensionId 6feaa440ffc is described below commit 6feaa440ffce2afc6b0222c49de598b94e60c825 Author: Chesnay Schepler <ches...@apache.org> AuthorDate: Tue Nov 8 11:19:06 2022 +0100 [FLINK-29927][akka] Use singleton ExtensionId --- .../src/main/java/org/apache/flink/runtime/rpc/akka/AkkaUtils.java | 2 +- .../org/apache/flink/runtime/rpc/akka/RemoteAddressExtension.java | 4 ++++ 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaUtils.java b/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaUtils.java index 5bcad68262d..65bf7a7f41b 100644 --- a/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaUtils.java +++ b/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaUtils.java @@ -518,7 +518,7 @@ class AkkaUtils { * @return {@link Address} of the given {@link ActorSystem} */ public static Address getAddress(ActorSystem system) { - return new RemoteAddressExtension().apply(system).getAddress(); + return RemoteAddressExtension.INSTANCE.apply(system).getAddress(); } /** diff --git a/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/RemoteAddressExtension.java b/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/RemoteAddressExtension.java index ce4947399c5..ff02d72d70c 100644 --- a/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/RemoteAddressExtension.java +++ b/flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/RemoteAddressExtension.java @@ -29,6 +29,10 @@ import akka.actor.Extension; public class RemoteAddressExtension extends AbstractExtensionId<RemoteAddressExtension.RemoteAddressExtensionImpl> { + public static final RemoteAddressExtension INSTANCE = new RemoteAddressExtension(); + + private RemoteAddressExtension() {} + @Override public RemoteAddressExtensionImpl createExtension(ExtendedActorSystem system) { return new RemoteAddressExtensionImpl(system);