#watermark

ORA-26876: invalid processed low-watermark (current position=string; new position=string)

文档解释ORA-26876:invalidprocessedlow-watermark(currentposition=string;newposition=string)Cause:Anattemptwasmadetosettheprocessedlow-watermarktoavaluethatwaslesstha...

ORA-23388: replication parallel push watermark error

文档解释ORA-23388:replicationparallelpushwatermarkerrorCause:Anerroroccurredduringparallelpushwhiletryingtoupdatethehigh-water-markinformationinsystem.def$_destinat...

flink 如何实现对watermark 的checkpoint,防止数据复写

finkslink后的数据被复写了???生产环境总会遇到各种各样的莫名其名的数据,一但考虑不周便是车毁人亡啊。 线上sink流是es,es的文档id是自定义的id+windowSatarTime设windowsize=10min,watermark最大延迟时间是10s,.数据中的eventtime是乱序到达的...