开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

大佬们 我Flink用一个流建立了两个表 将这两个表写入oracle 但是只有第一个表写入了 ?

大佬们 我Flink用一个流建立了两个表 将这两个表写入oracle 但是只有第一个表写入了 第二个表始终是空的 这咋回事呀?0a9c1dc61c07ec17d6f96f3ee1ad6436.png

展开
收起
真的很搞笑 2023-08-13 11:13:03 107 0
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    在Flink中将两个表写入Oracle时,只有第一个表成功写入而第二个表为空的情况可能有多种原因。以下是一些常见的可能原因和相应的解决方法:

    数据源问题:首先,请确保第二个表的数据源正确,并且有数据生成或输入到该表中。检查第二个表的数据源是否正确配置,并且数据确实存在。

    数据处理逻辑:检查数据处理逻辑是否正确。确保在将数据写入到第二个表之前,已经对数据进行了正确的转换、处理和过滤。检查相关的Flink代码逻辑,确保数据能够正确地流经流处理任务并被写入到第二个表中。

    Oracle连接问题:验证Flink与Oracle之间的连接是否正确配置。确保连接参数、用户名、密码、表名等信息都正确,并且Flink能够成功连接到Oracle数据库。

    事务提交问题:在将数据写入Oracle时,Flink默认使用了事务来保证数据的一致性和可靠性。确保第二个表的写入操作在事务内进行,并且事务能够正常提交。如果事务没有正确提交,数据可能无法持久化到Oracle中。

    并发度配置:检查Flink任务的并发度设置。如果第二个表的写入操作的并发度设置过低,可能会导致写入操作无法及时完成,从而导致表为空。尝试增加并发度,看是否能够解决该问题。

    日志调试:查看Flink任务的日志,特别是与第二个表写入相关的日志信息,以便确定具体的错误或异常情况。日志可以提供更多的细节,帮助定位问题所在。

    2023-08-13 22:52:53
    赞同 展开评论 打赏
  • 对呢 然后将视图insert into 了oracle表,此回答整理自钉群“【②群】Apache Flink China社区”

    2023-08-13 12:04:28
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    PostgresChina2018_樊文凯_ORACLE数据库和应用异构迁移最佳实践 立即下载
    PostgresChina2018_王帅_从Oracle到PostgreSQL的数据迁移 立即下载
    Oracle云上最佳实践 立即下载

    相关镜像