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