一、State 在Flink中，按照基本类型，对State做了以下两类的划分： Keyed State，和Key有关的状态类型，它只能被基于KeyedStream之上的操作，方法所使用。我们可以从逻辑上理解这种状态是一个并行度操作实例和一种Key的对应， <parallel-operator-ins ...
分类：
其他好文 时间：
2019-12-11 12:57:38
阅读次数：
219
一、数据库全备，全备脚本如下： [root@leader script]# cat bak_all.sh #!/bin/bash#Date: 2019-12-08#Author: chan#Mail: chan#Function:This scripts function is More compl ...
分类：
数据库 时间：
2019-12-08 15:50:18
阅读次数：
142
tomcat启动时错误：Failed to start component [StandardEngine[Catalina].StandardHost[localhost].错误 Caused by: java.lang.IllegalStateException: Unable to compl ...
分类：
系统相关 时间：
2019-11-21 09:53:27
阅读次数：
76
1、从排序数组中删除重复项 给定一个排序数组，你需要在原地删除重复出现的元素，使得每个元素只出现一次，返回移除后数组的新长度。 不要使用额外的数组空间，你必须在原地修改输入数组并在使用 O(1) 额外空间的条件下完成。 题目解析： O(1) 额外空间是指空间复杂度。空间复杂度(Space Compl ...
分类：
其他好文 时间：
2019-11-16 19:20:32
阅读次数：
54
在Tensorflow下使用SSD模型训练自己的数据集时，经过查找很多博客资料，已经成功训练出来了自己的模型，但就是在测试自己模型效果的时候，出现了如下错误。 在查找资料的过程中，出现了很多波折，百度上基本没有同样的错误， 最开始使用的代码是： 尝试过很多种方法，比如下面这种方法，改了后还是报同样的 ...
分类：
其他好文 时间：
2019-10-27 19:01:51
阅读次数：
171
PANIC: could not locate a valid checkpoint record
日志：无效的主要检查点记录
postgres 集群故障修复
分类：
其他好文 时间：
2019-10-24 10:22:59
阅读次数：
122
checkpoint 文件夹 Tensorflow训练后的模型可以保存checkpoint文件，checkpoint文件是结构与权重分离的四个文件，便于训练。 1）checkpoint 文件 保存断点文件列表，可以用来迅速查找最近一次的断点文件； model_checkpoint_path: "mo ...
分类：
其他好文 时间：
2019-10-20 12:52:10
阅读次数：
84
模型保存后产生四个文件，分别是： |--models| |--checkpoint| |--.meta| |--.data| |--.index .meta保存的是图的结构 checkpoint文件是个文本文件，里面记录了保存的最新的checkpoint文件以及其它checkpoint文件列表。 . ...
分类：
其他好文 时间：
2019-10-16 18:15:14
阅读次数：
110
ReadFromJDQ3 1）消费JDQ的必要信息，通过参数传入，有6个参数 2）获取flink JDQ3的鉴权客户端 3）根据鉴权客户端获取消费属性的配置 4）构建应用环境ENV和checkpoint机制 5）构建JDQ3（基于kafka）对应的消费客户端，flink用来消费实时订单消息 6) 根 ...
分类：
其他好文 时间：
2019-10-12 11:06:54
阅读次数：
106
暂存模型（*.index为参数名称，*.meta为模型图，*.data*为参数） 暂存模型（同一模型多次保存可以不保存模型图节省时间） 恢复模型（手动生成网络则不需要*.meta文件） 恢复模型（从*.meta文件生成网络） 恢复模型（可以在一个文件夹下保存多次模型，checkpoint文件会自动记 ...
分类：
其他好文 时间：
2019-10-03 22:00:37
阅读次数：
138
