我在1.13.2 版本flink-jdbc源码种增加了关于oracle的处理。两种方案测试都没有生效。第一种:读取oracle源表,写入oralce目标表。(表结构相同)执行成功,但是结果表并没有写入数据。
第二种:用维表的方式读取(依旧没有任何打印)
因为没有任何报错,所以不清楚是哪里的问题,麻烦能指点下,谢谢
你似乎误解了flink的执行流程,算子的执行是流式惰性执行,不会应为你的print输出了就是算子执行了,而且你没配置日志,也许你的程序报错了但是没打印