flink sql 2.12 kafka 双流join 写es b表属性总为null

1单独运行两个流报错数据到es 没问题
2为了确保数据没收到
2.1kafka生产者我循环每30毫秒发一条

2.2 另外开一个消费者 看到了数据

3代码如下

3.1 sink的sql

3.2 创建es sink表

3.3 kafka流表
a表

b表

3.4 代码运行无错误

3.5 es sink结果

请问：我哪写的有问题？

执行sql的时候，把sql打印出来看看

提供相关的表结构和几行数据以及输出你的SQL便于我本地调试，请不要截图，直接复制粘贴