jeff-zou/flink-connector-redis

Issues

• 测试里有个flushdb操作, 跑了一下测试case，测试redis数据全没了，差点要收拾包裹走人了

  #42 opened a year ago by lyBigdata
  2

• 能否支持下ssl 加密

  #58 opened 5 months ago by Sunninsky
  0

• datastream sink的时候怎么设置hash key

  #57 opened 5 months ago by ncc0706
  1

• redis 维表是否可以增加 metric 监控呢？维表导致的延迟问题目前比较难定位

  #21 opened 2 years ago by qiunanx
  2

• 支持 redis 异步维表关联

  #55 opened 8 months ago by qiunanx
  1

• 报错java.lang.ClassNotFoundException: io.netty.channel.ChannelHandler类找不到

  #53 opened 10 months ago by WhiteLie98
  4

• io.lettuce.core.RedisConnectionException: Unable to connect to host:port

  #51 opened a year ago by chenbodeng719
  3

• Flink 1.13 & 1.14 版本是哪个分支或者tag?

  #52 opened a year ago by pyscala
  3

• datastream sink的时候怎么设置ttl

  #50 opened a year ago by ancientMuse
  1

• 1.3.1 版本 能写入数据，但是读取不到数据 要怎么处理

  #49 opened a year ago by linjinen
  2

• 适配flink 1.17.0

  #48 opened a year ago by DemoLu
  1

• Flink CDC同步MySQL数据到Redis时，Redis不能同步删除数据

  #35 opened a year ago by hziling
  5

• hset命令下ttl不断重置的问题

  #45 opened a year ago by ancientMuse
  4

• Setting `command` option in TableDescriptor leads to Java error

  #46 opened a year ago by kphan102
  6

• [flink1.16.0]java.lang.UnsatisfiedLinkError: 'int io.netty.channel.unix.Socket.sendAddress(int, long, int, int)'

  #47 opened a year ago by ulnit
  5

• How to implement exactly once in redis sink function?

  #44 opened a year ago by awakelee
  1

• hash结构怎么查询

  #43 opened a year ago by traveller6168
  1

• sink.parallelism 参数无效

  #33 opened a year ago by MingYu-Deng
  1

• 对于redis消费相关问题

  #39 opened a year ago by dazhao10046
  1

• Lettuce API Implicit Failure

  #34 opened a year ago by zmzeng
  1

• 异常问题

  #37 opened a year ago by zhaoSir-bin
  6

• 导入依赖运行test示例报错

  #41 opened a year ago by G337-BeiJing-Ratel
  3

• 报错 no match redis

  #38 opened 2 years ago by gaoyan1998
  4

• 哨兵模式下连接失败

  #36 opened 2 years ago by liwanyu
  3

• 支持 Flink 1.15.x 下作为Lookup Table

  #30 opened 2 years ago by MingYu-Deng
  2

• Caused by: java.lang.ClassNotFoundException: io.netty.channel.ChannelHandler

  #32 opened 2 years ago by tx991020
  5

• 能在入redis中增加支持原始BYTES入redis的方法么？

  #31 opened 2 years ago by yycoolsam
  5

• 请问下不支持redis sentinel模式吗

  #29 opened 2 years ago by wushangqiao1
  5

• 连接器不支持连接哨兵模式集群？

  #28 opened 2 years ago by zhanghairui521
  3

• 请问可以java jdbc connection调用呢吗?

  #26 opened 2 years ago by cloudAndMonkey
  3

• Flink sql表关联redis维表，redis中的数据更新了，但是flink计算时好像没有实时感知到

  #27 opened 2 years ago by lbj2016
  1

• 1.2.1版本sql-client查询数据报错

  #25 opened 2 years ago by Fivice
  1

• hset-column模型下创建表用了多个字段 只有前三个有效吗？

  #24 opened 2 years ago by maskainv
  1

• 直接使用redis数据 查询语句出错。报： Cannot generate a valid execution plan for the given query

  #23 opened 2 years ago by maskainv
  1

• How to use HSET with table format like this

  #22 opened 2 years ago by noomanee
  3

• sink 不支持设置过期时间？

  #20 opened 2 years ago by qiunanx
  1

• 这个支持redis source吗

  #19 opened 2 years ago by waywtdcc
  2

• Redis Sink 支持批量提交和刷新提交吗？

  #6 opened 2 years ago by liuhongyao24
  1

• redis 维表，同步关联性能不行。可以支持异步关联。

  #18 opened 2 years ago by qiunanx
  2

• Use redis pipeline instead of JedisPool

  #10 opened 2 years ago by shadibch
  4

• Compatible between save on flink and spark

  #9 opened 2 years ago by shadibch
  1

• Sink 类型为 HINCRBY 不支持 double 累加

  #17 opened 2 years ago by qiunanx
  4

• java.lang.VerifyError: Bad return type

  #14 opened 2 years ago by Leijingwen
  4

• 版本兼容

  #7 opened 2 years ago by Francis-X
  14

• sql-client执行hget的问题

  #11 opened 2 years ago by Tsao-zy
  6

• 设置ttl无效

  #15 opened 2 years ago by wqxs
  1

• 支持flink 1.10吗

  #16 opened 2 years ago by hai125698
  1

• 这个jar包能上传到maven**仓库吗？

  #8 opened 2 years ago by waywtdcc
  2

• sink redis 找不到 connector

  #13 opened 2 years ago by heyzeng
  3

• batch模式支持吗

  #12 opened 2 years ago by JALEMEI
  3