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