Fetching
专注于大数据、机器学习、网络安全及美食
Flink RemoteRpcInvocation Exception
2019-04-01 16:07
259
0
目前在Flink里用了29个CEP规则，并行度设置为了10。当taskmanager slot的数目为1，taskmanager number的数目为10时，总是容易fail，而且报的错是apache
Blink的一个bug
2019-01-30 17:59
616
4
目前在使用过程中，发现在application在yarn上运行时，如果table转为stream，且并行度大于1时。代码如下： 就会出问题，报出的错误如下： org.apache.flink.clie
Blink编译及使用
2019-01-28 12:24
3898
2
阿里巴巴在2019年1月27日左右开源了Blink，Blink目前的版本是基于Flink1.5.1修改的，然后增加了一些比较好的特性。github地址为：https://github.com/apac
Flink debug
2019-01-15 13:50
437
0
Flink是可以支持本地调试的，本地调试的方式非常简单，就是在创建environment时创建localEnvironment即可。 代码如下所示： 创建localEnvironent之后，在IDEA
Flink事件时间和水印
2019-01-14 10:50
959
0
1.概览 处理时间/系统时间/进入时间 Flink在Streaming程序中，提供了不同的时间概念。 处理时间：处理时间代表着在执行相应操作时的系统时间。 当一个Streaming程序以处理时间运行时
Flink连接Kafka的实现原理
2019-01-10 17:54
1017
0
Apache Flink Streaming支持多种数据源，第三方连接器列表如下： Apache Kafka Amazon Kinesis Streams RabbitMQ Apache NiFi T