美文网首页
引入问题:

引入问题:

作者: yayooo | 来源:发表于2019-08-25 15:42 被阅读0次

读文件每一行,sink输出的顺序和原文件不一致原因是什么?
原因是:我们在keyBy操作会进行rebalance操作并且是并行计算,所以顺序就乱了。
有什么办法呢?
将全局并行度设置为1

val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
env.setParallelism(1)

相关文章

  • 引入问题:

    读文件每一行,sink输出的顺序和原文件不一致原因是什么?原因是:我们在keyBy操作会进行rebalance操作...

  • CSS引入问题

    CSS使用问题 在单文件组件中,编写的样式可以保证只对当前组件的模板具有效果,添加scoped属性到style标签...

  • 引入scss问题

    两个插件cnpm install node-sass sass-loader --save-dev引入sas...

  • AFN引入问题

    1.首先要把AFNETWORK 导入到你的工程中 就是那19个文件afnetworking 文件夹 2.然后还要在...

  • js 使用jquery

    1. 引入jQuery 问题 引入下载好的jQuery文件 引入谷歌 引入Microsoft CDN: 2. 点击...

  • 1.angular rxjs of 引入问题

    1.angular rxjs of 引入问题(1)出现问题:在同时引入"Observable, of " 会报错,...

  • Android 引入ktx问题

    由于项目中使用了kotlin,所以想引入ktx库,是代码更简洁。 但是报错: 百度后:https://blog.c...

  • SDK引入问题

    如果打开AndroidStudio,提示找不到SDK,请不要尝试去配置下载的proxy,因为系统会默认执行“自寻路...

  • 引入Jquery报错问题

    今天引入jQuery3.3.1报错jQuery Syntax error on token "catch", Id...

  • Vue引入失败问题

    在做最基础的引入后vue并进行数据绑定测试是否引入vue成功时失败n次,报错有如下两种:1.Uncaught Re...

网友评论

      本文标题:引入问题:

      本文链接:https://www.haomeiwen.com/subject/iwrxectx.html