Re: flink 1.11.1 使用sql ,使用hbase作为维表进行temporal join时无法获取数据

2020-11-11 文章 鱼子酱
重新搞了一下,找到原因了 1、没有配置hbase的host Reading reply sessionid:0x3000484bfd0001d, packet:: clientPath:null serverPath:null finish 2、protobuf-java版本过高 java.lang.NoClassDefFoundError: com/google/protobuf/LiteralByteString 这个2个问题一直没发现,是因为报错的信息只有debug级别里面有,我之前的日志级别是info,希望后续如果可能的话,把相关的报错的信息提高级别就更好识别啦 --

flink 1.11.1 使用sql ,使用hbase作为维表进行temporal join时无法获取数据

2020-11-10 文章 鱼子酱
Hi,社区的各位大家好: 我在使用Hbase作为维表,进行temporal join时无法获取数据, 具体表现就是任务可以运行,但是没有符合条件的数据输出。 flink版本是1.11.1,Hbase版本是1.2.0-cdh5.15.1 1、我测试了,如果去掉关联条件只读取kafka源: insert into testhbase select cast(applog.terminalNo as varchar) from applog ,是能够输出数据, 但是一旦加上关联条件,就无法输出了。