阿里云 事件监控开源项目地址 https://github.com/AliyunContainerService/kube eventer 需要对一下变量进行修改 sink=dingtalk:[your_webhook_url]&label=[your_cluster_id]&level=[Norm ...
分类：
其他好文 时间：
2020-01-06 11:12:05
阅读次数：
139
10.9传输网(Transport network) 一些名词: 流量守恒(Conservation of flow) 除源点s(source)和宿点t(sink)之外，要求其他节点流入的流量和流出的流量相等 最大流(Maximal flow) 对于网络流图G，流量最大的可行流f，称为最大流 基本算 ...
分类：
Web程序 时间：
2020-01-05 18:29:17
阅读次数：
110
Flume采集的控制台提示：The channel is full or unexpected failure. The source will try again after 1000 ms 这个是因为当前被采集的文件过大，深层的原因是文件采集的速度和sink的速度没有匹配好。所以应该可以通过增大 ...
分类：
其他好文 时间：
2019-12-28 22:41:20
阅读次数：
335
详细代码及注释如下： xm=100;%设置区域为100*100 ym=100; sink.x=0.5*xm;%sink（汇聚）节点坐标 sink.y=1.75*ym; n=100 %区域内的节点数目 p=0.05;% 节点成为簇头的概率 Eo=0.5;%节点初始能量 ETX=50*0.0000000 ...
分类：
其他好文 时间：
2019-12-21 20:17:00
阅读次数：
94
topN功能是一个非常常见的功能，比如查看最近几分钟的阅读最高数，购买最高数。 flink实现topN的功能也非常方便，下面就开始构建一个flink topN的程序。 还是像上篇博客一样，从kafka读取数据，然后进行计算和数据转换，最后sink到mysql中。 假设有个需求，实现一个统计每5分钟最 ...
分类：
其他好文 时间：
2019-12-15 12:39:52
阅读次数：
136
0.官方网站 1.环境准备： 1.搭建单机版的ES环境 2.虚拟机上nc -l 9000方式产生数据 2.需求分析 通过socket的nc -l 9000方式产生数据，然后将数据存入到es中 3.代码实例 flink-sink-es-example ...
分类：
其他好文 时间：
2019-12-09 17:00:37
阅读次数：
576
1.环境准备： 1.搭建zookeeper和kafka 2.虚拟机上nc -l 9000方式产生数据 2.需求分析： 通过socket的nc -l 9000方式产生数据，然后将数据以字符串的形式存入到kafka中 3.代码实例 flink-kafka-example ...
分类：
其他好文 时间：
2019-11-26 17:49:18
阅读次数：
90
数据源Source RPC异构流数据交换 Avro Source Thrift Source 文件或目录变化监听 Exec Source Spooling Directory Source Taildir Source MQ或队列订阅数据持续监听 JMS Source SSL and JMS Sou ...
分类：
Web程序 时间：
2019-11-22 10:48:12
阅读次数：
84
SocketException: OS Error: Broken pipe, errno = 32 这个错误其实有点迷惑性，很多时候调用栈显示是在 的时机出的错，但实际是因为socket已经被对端关闭，而关闭的原因可能是因为发送了错误的数据。 解决： 发送数据时机检查socket连接状态及数据正确 ...
分类：
其他好文 时间：
2019-11-12 13:11:53
阅读次数：
114
