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写数据报错
- 报错信息
解决方式：
增加jar包
