大家好，今天我将跟大家分享一下Flink里面的Checkpoint，共分为四个部分。首先讲一下Checkpoint与state的关系，然后介绍什么是state，第三部分介绍如何在Flink中使用state，第四部分则介绍Checkpoint的执行机制。Checkpoint是从source触发到下游所有节点完成的一次全局操作。下图可以有一个对Checkpoint的直观感受，红框里面可以看到一共触发了569K次Checkpoint，然后全部都成功完成，没有fail的。state其实就是Checkpoint所做的主要持久化备份的主要数据，看下图的具体数据统计，其state也就9kb大小。我们接下来看什么是state。先看一个非常经典的wordcount代码，这段代码会去监控本地的9000端口的数据并对网络端口输入进行词频统计，我们本地行动netcat，然后在终端输入helloworld，执行程序会输出什么？答案很明显，(hello,1) 和 (word,1)那么问题来了，如果再次在终端输入helloworld，程序会输入什么？答案其实也很明显，(hello,2) ...

Flink的API大体上可以划分为三个层次：处于最底层的ProcessFunction、中间一层的DataStreamAPI和最上层的SQL/TableAPI，这三层中的每一层都非常依赖于时间属性。时间属性是流处理中最重要的一个方面，是流处理系统的基石之一，贯穿这三层API。在DataStreamAPI这一层中因为封装方面的原因，我们能够接触到时间的地方不是很多，所以我们将重点放在底层的ProcessFunction和最上层的SQL/TableAPI。在不同的应用场景中时间语义是各不相同的，Flink作为一个先进的分布式流处理引擎，它本身支持不同的时间语义。其核心是ProcessingTime和EventTime（RowTime），这两类时间主要的不同点如下表所示：ProcessingTime是来模拟我们真实世界的时间，其实就算是处理数据的节点本地时间也不一定就是完完全全的我们真实世界的时间，所以说它是用来模拟真实世界的时间。而EventTime是数据世界的时间，就是我们要处理的数据流世界里面的时间。关于他们的获取方式，ProcessTime是通过直接去调用本地机器的时间，而Event...

  目前上云已经成为行业发展趋势，越来越多的企业级客户将业务系统和数据库迁移到云上。而传统的备份一体机/备份软件方式，并不适合云上ECS、RDS等产品的备份与容灾服务。阿里云块存储服务提供云原生的快照服务，通过针对关键业务系统的自动以及手工快照，确保用户业务系统在发生灾难时，也能够快速进行业务恢复。  阿里云快照服务采用ROW(RedirectOnWrite)模式。用户在首次创建快照时，复制一份完整的备份数据，此后所有的快照均采用“永久增量”模式。并将快照数据异步存储到同Region的OSS集群上。OSS集群与块存储集群物理隔离部署，并且提供11个9的数据可靠性。因此，能够确保快照数据的足够安全。如下阿里云快照服务的逻辑示意图：  在创建快照的时候，快照服务采用多线程机制，将云盘中变化的数据块（快照不备份空数据块），异步复制到同Region的OSS集群中。目前快照的备份速度能够达到35MB/S-40MB/S。  快照采用永久增量方式，每次仅保存变化的数据块。但是每个快照时间点都是完整的备份数据。在进行快照回滚或者基于快照创建云盘时，阿里云默认采用Lazyload方式，秒级回滚云盘，即刻...

关于前端框架系列的可以参考我我刚学Bootstrap时候写的LoT.UI http://www.cnblogs.com/dunitian/p/4822808.html#lotui bootstrap-select没有select2那么强大的api，但是胜在漂亮啊，配合自己写的脚本基本上也是够用了一般都是自己Ajax加载数据，然后字符串拼接。拼接完了之后用官网的方法刷新一下select就可以了  举个不成文的例子（有更好的方法可以留言）：包含optgroup前端HTML部分初始化（可有可无）后端代码：（我需要分类显示）JS部分：$('.lot-tagSelect').selectpicker('refresh'); $('.lot-tagSelect').selectpicker('show'); 做一记录，收工/ LoT.UI前后台通用框架分解系列汇总：01.LoT.UI前后台通用框架分解系列之——小图片背景全屏显示http://www.cnblogs.com/dunitian/p/5507306.html02.Lo...

 /<scripttype="text/javascript">$(function(){varfilename='/assets/css/main.css';varfileref=document.createElement("link");fileref.setAttribute("rel","stylesheet");fileref.setAttribute("type","text/css");fileref.setAttribute("href",filename);document.getElementsByTagName("head")[0].appendChild(fileref); varfilescript=document.createElement("script");filescript.type="text/javascript";filescript.src="/assets/js/main.js";document.getElementsByTagName('body')[0].appendChild(filescript...

网站部署之~WindowsServer|本地部署 http://www.cnblogs.com/dunitian/p/4822808.html#iis上次说了如何用ip来浏览网站（iis分配ip的时候可以不选ip，这样网站的ip地址就会跟着服务器变了【一般服务器都是固定ip】）添加一个角色（图片作为参考【之前做的图】）添加一下DNS服务器打开的时候，选择工具==>DNS新建一个域名输入域名自动生成添加一个子域名输入子域名的名称（www|dnt|xxx）新建一个主机（dns把域名解析到哪而去~）本地电脑设置一下DNS输入设置的域名==》收工~ 有人会问了，那外网的呢？如果你有独立的DNS服务器，那么可以在注册域名的地方设置一下自己的DNS服务器一般来说，我们都是绑定服务器，用域名提供商提供的DNS——-----------------------------------------------------------------------------------------------------参考文章：http://jingyan.baidu.com/ar...

Dapper的牛逼就不扯蛋了，答应群友做个入门Demo的，现有园友需要，那么公开分享一下：/完整Demo：http://pan.baidu.com/s/1i3TcEzj注意事项：http://www.cnblogs.com/dunitian/p/5221058.html平台之大势何人能挡？带着你的Net飞奔吧！http://www.cnblogs.com/dunitian/p/4822808.html#skill扩展篇：http://www.cnblogs.com/dunitian/p/5710382.html先安装一下Dapper（建议用nuget包来管理）连接字符串：/stringconnStr="DataSource=.;InitialCatalog=DapperDB;UserID=用户名;Password=密码";强类型：#region强类型//publicstaticIEnumerable<T>Query<T>(thisIDbConnectioncnn,stringsql,objectparam=null,SqlTransactiontransacti...

网站就必须用响应式布局吗？MVC视图展现模式之移动布局：http://www.cnblogs.com/dunitian/p/5213787.htmldemo:http://pan.baidu.com/s/1bnTUaKJ有人会疑问，为什么他能识别.mobile的后缀却不能识别例如：.mac.dnt等等后缀呢？这些又是放在哪里的呢？mobile这个后缀其实是存放在：DisplayModeProvider.Instance.Modes里面的，我们监视一下，发现里面就一个mobile，还有一个是默认的可以猜想，运行的时候是从上往下匹配的，“”的是通用匹配，那么我们加入一个自定义的后缀看看==>(可以思考一下，为什么用insert不用add)//添加一个自定义后缀DisplayModeProvider.Instance.Modes.Insert(0,newDefaultDisplayMode("dnt"){ContextCondition=(Context)=>Context.Request.UserAgent.Contains("dnt")});可能你不是很理解DefaultDi...

★3.1Netcraft：子域名查询 官网：http://searchdns.netcraft.com/输入要查询的域名，即可得知子域名   3.2Fierce：子域名查询概述：fierce是使用多种技术来扫描目标主机IP地址和主机名的一个DNS服务器枚举工具。运用递归的方式来工作。它的工作原理是先通过查询本地DNS服务器来查找目标DNS服务器，然后使用目标DNS服务器来查找子域名。fierce的主要特点就是可以用来定位独立IP空间对应域名和主机名。  参数：root@Kali:/home/dnt#fierce-hfierce.pl(C)Copywrite2006,2007-ByRSnakeathttp://ha.ckers.org/fierce/  Usage:perlfierce.pl[-dnsexample.com][OPTIONS]  Overview:Fierceisasemi-lightweightscannerthathelpslocatenon-contiguousIPs...

 Web地址：http://whois.chinaz.com/|http://www.whois.net/软件参数：whois   常用命令：whois域名（重点看whoisserver和ReferralURL）  ...

（又称：域名，主机，备案都配置好了，就是不能访问网站的解决方案--1.解析问题）网站部署之~阿里云系列汇总 http://www.cnblogs.com/dunitian/p/4958462.html直接访问网站发现===>进入管理页面：https://home.console.aliyun.com/ 还不可访问请参考：http://www.cnblogs.com/dunitian/p/4977244.html...

异常处理汇总~修正果带着你的Net飞奔吧！http://www.cnblogs.com/dunitian/p/4599258.html1.解析问题：参考这个文章：http://www.cnblogs.com/dunitian/p/4977261.html2.主机设置问题：主机管理 http://cp.aliyun.com/  主机里面绑一下www.xxx.xxx就ok了...

网站部署之~阿里云系列汇总 http://www.cnblogs.com/dunitian/p/4958462.html进入管理页面：https://home.console.aliyun.com/ 选择全部域名，选择你需要解析的域名选择cdn加速一般人用免费，土豪自己买新建一个BucketOSS提供ACL（AccessControlList）权限控制方法，OSSACL提供bucket级别的权限访问控制，bucket目前有三种访问权限：public-read-write，public-read和private，它们的含义如下：public-read-write：任何人（包括匿名访问）都可以对该bucket中的object进行PUT，Get和Delete操作；所有这些操作产生的费用由该bucket的创建者承担，请慎用该权限。public-read：只有该bucket的创建者可以对该bucket内的object进行写操作（包括Put和DeleteObject）；任何人（包括匿名访问）可以对该bucket中的object进行读操作（GetObject）。private：只...

 网站部署之~阿里云系列汇总 http://www.cnblogs.com/dunitian/p/4958462.html 1.购买域名（http://wanwang.aliyun.com/）2.加入购物车3.填写并结算4.管理域名 http://netcn.console.aliyun.com/core/domain/list 5.域名证书（后面备案会用到） ...

主要原因：在页面给元素注册点击事件的时候【 $(function(){ XXX}); 】，JS动态生成的元素还尚未生成，所以click事件就没有生效 解决方法： 方案一：js动态生成元素后再给其注册事件 【注册事件放在动态生成的js下面（js是从上往下执行的，当注册事件的时候元素已经生成了，就不会出现注册失效的现象了）】话比较抽象举个例子： 方案二：js动态生成元素的时候给他加上onClick之类的方法 举个例子：如果你又更好的方案，那小子受教了~~ ...