[flink1.16.0]java.lang.UnsatisfiedLinkError: 'int io.netty.channel.unix.Socket.sendAddress(int, long, int, int)' about flink-connector-redis HOT 5 CLOSED

Please provide the configuration to connect to redis.

from flink-connector-redis.

Please provide the configuration to connect to redis.
) WITH (
'connector' = 'redis',
'host' = '192.168.X.X',
'port' = '6379',
'database' = '9',
'password' = '******',
'redis-mode' = 'single',
'command' = 'hset',
'value.data.structure' = 'row',
'ttl' = '259200'
);

from flink-connector-redis.

Please provide the configuration to connect to redis.

The sendAddress method about netty v4.1 looks like this :

from flink-connector-redis.

The configuration is look like fine. It could be a version issue.Please try to connect to redis directly by Lettuce like this:

RedisClient client = RedisClient.create("redis://localhost"); StatefulRedisConnection<String, String> connection = client.connect(); RedisStringCommands sync = connection.sync(); String value = sync.get("key");

from flink-connector-redis.

The configuration is look like fine. It could be a version issue.Please try to connect to redis directly by Lettuce like this:

RedisClient client = RedisClient.create("redis://localhost"); StatefulRedisConnection<String, String> connection = client.connect(); RedisStringCommands sync = connection.sync(); String value = sync.get("key");

Tks, it's been resolved. Probably the reason is that my local machine is an m1 chip, so I added the netty-transport-native-epoll dependency to linux-x86_64 and everything worked fine.

from flink-connector-redis.