重新搞了一下,找到原因了
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,希望后续如果可能的话,把相关的报错的信息提高级别就更好识别啦
--
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
,是能够输出数据,
但是一旦加上关联条件,就无法输出了。