双流数据有些没有merge上,不确定是否是回撤原因引起,在建结果表的时候不能设置ignoredelete属性,出现”The provided value for option ignoredelete
is true, which is not as same as the value false inferred by catalog. You can use the inferred value by removing the specified option from the DDL”
后面就换成创建临时表,设置该属性,但是还是出现没有merge的流,双流都建了同样的主键
flink+hologres实时数仓 宽表merge问题[阿里云]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!
Flink 和 Hologres 结合构建实时数仓时,如果在宽表合并(merge)过程中遇到双流数据没有完全 merge 的问题,可能是由于多种原因导致的。以下是一些可能的原因和相应的解决方案:
事件时间不一致:
主键冲突:
回撤数据处理:
sideOutputLateData
或者在 Hologres 中设置合适的 TTL 来处理过期数据。并发控制:
检查点一致性:
临时表与结果表的问题:
网络延迟和连接问题:
Hologres 版本兼容性:
Link+Hologres实时数仓在宽表merge时遇到的问题,根据你的描述,可能是由于数据流的回撤或主键设置不正确导致的。
对于”The provided value for option ignoredelete is true, which is not as same as the value false inferred by catalog. You can use the inferred value by removing the specified option from the DDL“这个错误,这是因为你在创建结果表的时候设置了ignoredelete属性为true,而catalog推断出的值为false。你可以尝试移除DDL中的ignoredelete选项,使用catalog推断出的值。
另外,你也可以考虑使用Hologres的CDC(Change Data Capture)功能来处理数据流中的增删改操作,这样可以更准确地处理数据流的变化。
这个问题可能是由于在创建结果表时,没有正确设置
ignoredelete
属性导致的。你可以尝试以下方法解决这个问题:IGNOREDELETE
关键字来设置该属性。例如:ignoredelete
属性。例如: