开发者社区> 问答> 正文

大佬们,我在启动Flink的JOB时,将job的启动参数保存到了某个常量,但当我在si #Flink

大佬们,我在启动Flink的JOB时,将job的启动参数保存到了某个常量,但当我在sink中的invoke方法里,我获取时为Null,这个怎么处理啊? 我本地开发运行没问题,发布到Flink环境有问题。#Flink

展开
收起
黄一刀 2021-01-31 17:59:52 5873 0
1 条回答
写回答
取消 提交回答
  • 我感觉应该是分布式的问题,有些类里的值并没有发送到所有的节点上,大概率是 配置字段是transient 序列化的时候丢失了

    2021-01-31 18:00:48
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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