1. java.io.IOException: Failed to deserialize JSON ‘{“age”:867,“sex”:“fba8c074f9”,“t_insert_time”:“2024-03-04 14:12:24.821”}’

解决方式
修改数据类型。将TIMESTAMP_LTZ改为TIMESTAMP。

2. java. lang,classNotFoundException: org,apache.flink,streaming,api,functions,sink,filesystem.BucketAssigner请添加图片描述

增加包放在dlink即可。
在这里插入图片描述

3. org.apache.kafka.common.network.lnvaliaReceiveException-.Invalid receive(size=-720899)

解决方式:在这里插入图片描述
将地址给正确的ip

4. 往hive写数据报错

  1. 报错信息
    在这里插入图片描述
    解决方式:
    增加jar包
    在这里插入图片描述

5. 报错

在这里插入图片描述
jar包版本
https://repo.maven.apache.org/maven2/org/apache/flink/

Logo

北京人形旗下天工造物具身智能开源社区,聚焦具身天工与慧思开物两大平台

更多推荐