search

jeff-zou / flink-connector-redis

Asynchronous flink connector based on the Lettuce, supporting sql join and sink, query caching and debugging.
Apache License 2.0
220 stars 80 forks source link

java.lang.VerifyError: Bad return type #14

Closed Leijingwen closed 2 years ago

Leijingwen commented 2 years ago

create table sink_redis( name string, level string, age string) with ( 'connector'='redis', 'host'='192.168.90.104', 'port'='6379', 'redis-mode'='single', 'password'='123456', 'command'='hset');

select * from sink_redis;

[ERROR] Could not execute SQL statement. Reason: java.lang.VerifyError: Bad return type Exception Details: Location: org/apache/flink/streaming/connectors/redis/common/mapper/row/sink/RowRedisSinkMapper.getCommandDescription()Lorg/apache/flink/streaming/connectors/redis/common/mapper/RedisCommandBaseDescription; @4: areturn Reason: Type 'org/apache/flink/streaming/connectors/redis/common/mapper/RedisCommandDescription' (current frame, stack[0]) is not assignable to 'org/apache/flink/streaming/connectors/redis/common/mapper/RedisCommandBaseDescription' (from method signature) Current Frame: bci: @4 flags: { } locals: { 'org/apache/flink/streaming/connectors/redis/common/mapper/row/sink/RowRedisSinkMapper' } stack: { 'org/apache/flink/streaming/connectors/redis/common/mapper/RedisCommandDescription' } Bytecode: 0x0000000: 2ab6 0013 b0

I used sql-client,Flink version is 1.13.6.

jeff-zou commented 2 years ago

do not support redis source table,just join or sink.

jeff-zou commented 2 years ago

close

jeff-zou commented 2 years ago

close

Leijingwen commented 2 years ago

do not support redis source table,just join or sink.

thanks