Внедрение асинхронного ввода-вывода Flink с помощью клиента Redisson Redis вызвало ошибку «достигнуто максимальное колич ⇐ JAVA

[Anonymous]

У меня развернуто приложение Flink в AWS Managed Flink, но при попытке реализовать асинхронный ввод-вывод с помощью Redisson (клиент Redis) для подключения к AWS MemoryDB (кластер Redis) я получил ошибку (см. ниже). Мне неясно, как Redisson создает новые сокеты и как AWS Managed Flink настраивает максимальное количество сокетов. Может ли кто-нибудь пролить свет на то, как решить эту проблему? Спасибо.
java.lang.IllegalStateException: failed to create a new resolver
at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:72)
at org.redisson.client.RedisClient.resolveAddr(RedisClient.java:203)
at org.redisson.client.RedisClient.connectAsync(RedisClient.java:220)
at org.redisson.connection.MasterSlaveConnectionManager.connectToNode(MasterSlaveConnectionManager.java:125)
at org.redisson.connection.MasterSlaveConnectionManager.connectToNode(MasterSlaveConnectionManager.java:111)
at org.redisson.cluster.ClusterConnectionManager.doConnect(ClusterConnectionManager.java:91)
at org.redisson.connection.MasterSlaveConnectionManager.connect(MasterSlaveConnectionManager.java:192)
at org.redisson.config.ConfigSupport.createConnectionManager(ConfigSupport.java:220)
at org.redisson.Redisson.(Redisson.java:69)
at org.redisson.Redisson.create(Redisson.java:114)
at com.amazon.otf.etl.MyAsyncMap.open(MyAsyncMap.java:40)
at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34)
at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100)
at org.apache.flink.streaming.api.operators.async.AsyncWaitOperator.open(AsyncWaitOperator.java:163)
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:700)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:676)
at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:643)
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:953)
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:922)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:746)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:568)
at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: io.netty.channel.ChannelException: Unable to create Channel from class class io.netty.channel.socket.nio.NioDatagramChannel
at io.netty.channel.ReflectiveChannelFactory.newChannel(ReflectiveChannelFactory.java:46)
at io.netty.bootstrap.AbstractBootstrap.initAndRegister(AbstractBootstrap.java:310)
at io.netty.bootstrap.AbstractBootstrap.register(AbstractBootstrap.java:227)
at io.netty.resolver.dns.DnsNameResolver.(DnsNameResolver.java:517)
at io.netty.resolver.dns.DnsNameResolverBuilder.build(DnsNameResolverBuilder.java:527)
at io.netty.resolver.dns.DnsAddressResolverGroup.newNameResolver(DnsAddressResolverGroup.java:114)
at io.netty.resolver.dns.DnsAddressResolverGroup.newResolver(DnsAddressResolverGroup.java:92)
at io.netty.resolver.dns.DnsAddressResolverGroup.newResolver(DnsAddressResolverGroup.java:77)
at io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:70)
... 23 more
Caused by: java.lang.reflect.InvocationTargetException
at jdk.internal.reflect.GeneratedConstructorAccessor247.newInstance(Unknown Source)
at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490)
at io.netty.channel.ReflectiveChannelFactory.newChannel(ReflectiveChannelFactory.java:44)
... 31 more
Caused by: io.netty.channel.ChannelException: Failed to open a socket.
at io.netty.channel.socket.nio.NioDatagramChannel.newSocket(NioDatagramChannel.java:91)
at io.netty.channel.socket.nio.NioDatagramChannel.(NioDatagramChannel.java:120)
... 35 more
Caused by: java.net.SocketException: maximum number of DatagramSockets reached
at java.base/sun.net.ResourceManager.beforeUdpCreate(ResourceManager.java:72)
at java.base/sun.nio.ch.DatagramChannelImpl.(DatagramChannelImpl.java:132)
at java.base/sun.nio.ch.SelectorProviderImpl.openDatagramChannel(SelectorProviderImpl.java:42)
at io.netty.channel.socket.nio.NioDatagramChannel.newSocket(NioDatagramChannel.java:89)
... 36 more


Подробнее здесь: https://stackoverflow.com/questions/773 ... ror-maximu