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

Flink CDC里为什么我用静态变量在main方法初始化值,为什么在其他地方有错?

Flink CDC里为什么我用静态变量在main方法初始化值,到KeyedProcessFunction中用:类名.静态变量拿出来的是null,但是在本地运行就不会。855616af0795e395990dfff5937219ad.png

展开
收起
小小鹿鹿鹿 2024-01-17 23:30:51 46 0
2 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    在Flink CDC中,您可能在KeyedProcessFunction中使用静态变量时遇到了问题。首先,需要明确Flink作业的运行环境。如果您在本地环境中运行并且没有问题,但是在集群环境中遇到问题,那么可能与并行度或作业的部署方式有关。

    在KeyedProcessFunction中,每个key都会启动一个线程来处理数据,这意味着静态变量在每个线程中都有自己的副本。因此,如果您在main方法中初始化了一个静态变量并在KeyedProcessFunction中使用它,可能会出现线程间访问不一致的问题。为了解决这个问题,您可以考虑使用ThreadLocal来存储静态变量的值,这样每个线程都可以访问到相同的值 。

    另外,建议您检查KeyedProcessFunction的实现,确保在处理数据时不会出现任何错误或异常。您可以查看Flink的官方文档和示例,以了解如何在KeyedProcessFunction中正确地处理数据 。

    2024-01-18 14:44:45
    赞同 展开评论 打赏
  • 因为main进程体检在启动服务器,然后申请taskmanager服务,要传参数方式,传值。参数建议从配置文件读取,写一个propertiesUtil类就可以。dbc9dbab8216c2a4306881001c930904.pngd23ef558133617e3a91e95b38d20f8d9.png此回答来自钉群Flink CDC 社区。

    2024-01-18 10:38:11
    赞同 展开评论 打赏

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

相关产品

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

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载