遇到相同的问题，希望博主回答一下(标签-flink)

问题：

flink cdc运行一段时间，都是到凌晨1点59分，再也读取不到数据

原因：
查看Oracle日志
LOGMINER: StartScn: 15636993750082 (0x0e38.c5753442)
LOGMINER: EndScn: 15636993850083 (0x0e38.c576bae3)
LOGMINER: StartScn: 15636993750082 (0x0e38.c5753442)
LOGMINER: EndScn: 15636993849083 (0x0e38.c576b6fb)
造成卡住的原因，一直从相同的StartScn开始读，一直读不出数据，一直读，造成死循环了。

目的：
看到博主提出的解决方案，但是由于刚毕业，代码真不会写，博主能否把最终实现的代码给我发一份

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除结题
收藏举报

1条回答默认最新

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
卑以自牧w 2023-04-26 10:18
关注
可以把你的代码贴出部分看一下

解决无用
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

报告相同问题？

关注问题

Java-flink的sum方法输出 flink
2022-06-05 15:31

回答 1 已采纳我的打印出来了，，，我代码是这样的 import org.apache.flink.api.common.RuntimeExecutionMode; import org.apache.flink.
flink-connector-jdbc 是否是开源的，在哪里可以下载到呢 flink java 大数据有问必答
2022-02-09 15:08

回答 2 已采纳在这里：https://github.com/apache/flink/tree/69d9fade5b0e3629c84548c06f0624e9e66fdefe/flink-connectors/f
Flink处理乱序数据，关于侧输出流的问题 flink scala 大数据
2022-05-27 11:19

回答 1 已采纳当10:14:51的数据来之前，流中最大的事件时间 >= 10:24:50(窗口结束时间) + watermark延迟时间 + 允许延迟时间，导致当前waterMark 的值更新为这个最大的
史上最详细大数据基础知识
2023-03-11 17:25

djyjx的博客 大数据知识详解
flinkSQL创建kafka源表，解析ogg-json失败 flink kafka oracle
2022-08-26 11:43

回答 1 已采纳不是大小写问题，你的json里面是大写，代码里面是小写，改一下试试
flink多jobmanager运行重复输出问题 flink java spark
2022-04-24 10:13

回答 1 已采纳多个节点，同时获取到了数据，几个节点就有几次
Flink on Yarn -- Session-cluster模式 flink hadoop
2022-04-08 17:24

回答 1 已采纳检查com.dylan.wc.StreamWordCount这个类路径是否正确
58同城离线计算平台设计与实践（大数据进阶）
2020-04-13 18:38

yyoc97的博客本次分享将聚焦大数据平台离线计算和大家一起系统的探讨58在离线计算平台建设实践的思路、方案和问题解决之道。分享嘉宾：余意 58同城高级架构师编辑整理：史士博内容来源：58大数据系列直播出品平台：...
flink两个流join的时候怎么解决数据延迟问题 flink 有问必答
2021-07-16 14:22

回答 1 已采纳 OutputTag获取迟到数据，二次消费
关于#flink整库同步#的问题，如何解决？ flink
2023-03-05 21:39

回答 1 已采纳你把全部报错复制到记事本发给我
关于#flink代码#的问题，如何解决？ eclipse flink java
2023-03-07 15:49

回答 4 已采纳 Flink 在启动任务的时候，创建输入分片时发生了错误，导致无法启动任务。你需要检查一下程序中读取文件的代码是否正确，文件路径是否正确，文件是否存在，并且当前用户是否有访问该文件的权限。如果需要，可以
java面试（持续更新）
2024-03-04 16:11

我就在晒太阳的博客 1.能讲一下AOP和IOC吗？ 2.Spring怎样解决循环依赖的问题的？ 3.能讲一下垃圾回收机制GC吗？ 4.新的任务提交到线程池，线程池是怎样处理 5.进程和线程有什么区别？进程之间怎么进行通信？线程之间怎么进行通信？ 6....
Flink的Watermark flink 大数据
2023-03-28 20:55

回答 2 已采纳对于时间窗口，开始时间和结束时间的计算方式如下：滚动时间窗口：按照固定的时间长度对数据进行分组，窗口的大小和滑动步长相同，例如，5秒的滚动窗口，每5秒钟计算一次。开始时间为当前窗口大小的整数倍，结束
左耳听风——笔记二：程序员练级攻略
2022-10-26 09:24

三角形代表重生的博客编程技能在系统地学习编程技能之前，我希望你能先看一下 " The Key To Accelerating Your Coding Skills"，这篇文章会告诉你如何有效地快速提高自己的编程能力。然后接下来是下面几大块内容，但还只是入门级的。...
基于Hadoop的58同城离线计算平台设计与实践
2020-04-24 00:03

浪尖聊大数据-浪尖的博客分享嘉宾：余意 58同城高级架构师编辑整理：史士博内容来源：58大数据系列直播出品平台：DataFun注：欢迎转载，转载请在留言区留言。导读：58离线计算平台基于 Hadoop 生态体...
没有解决我的问题, 去提问

问题事件

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
创建了问题 4月24日

悬赏问题

¥15 如何使用python 实现对串口/dev/ttyUSB0进行上锁，使得该串口只能在一个python脚本中使用，其他脚本不能操作这个串口
¥15 晶体塑性有限元——Damask求解
¥15 写出这个有没有人能写一下今天中午就要
¥30 设计一个图形用户界面来控制你机械臂的运动
¥30 3d打印机无法识别到SD卡，如何解决？（相关搜索：格式化）
¥15 RPG游戏架构设计和开发方法
¥15 前端返回pdf时不显示内容
¥50 如何在不能联网影子模式下的电脑解决usb锁
¥20 服务器redhat5.8网络问题
¥15 如何利用c++ MFC绘制复杂网络多层图

遇到相同的问题，希望博主回答一下(标签-flink)

1条回答 默认 最新

问题事件

悬赏问题

1条回答默认最新