开发者社区> 问答> 正文

flink1.10.0设置状态后端env.setStateBackend(new #Flink

flink1.10.0设置状态后端env.setStateBackend(new FsStateBackend("hdfs://91.85.daily.com:9000/user/www/flinkState", true)) 启动报错, 是需要导包吗? #Flink image.png

展开
收起
黄一刀 2020-05-18 13:58:35 1953 0
1 条回答
写回答
取消 提交回答
  • 少了flink-shaded-hadoop包

    2020-05-19 10:52:58
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Apache Flink 案例集(2022版) 立即下载
十分钟上线-使用函数计算构建支付宝小程序服务 立即下载
机器学习在互联网后端技术中的应用 立即下载