你这个是什么代码？
安卓10获取剪贴板内容Android 10 限制 了应用的后台剪贴板内容获取行为,只有当前界面获得焦点后（onResume）才能获取到剪切板内容 我们创造一个有焦点的悬浮窗, 就可以获取剪贴板内容...
发简信
IP属地：安徽
-
-
@一支铅笔_fc35 问题找到了吗？
flink整合spring boot
Flink框架：Flink整合springboot 首先说一下， 为什么flink 需要集成flink， spring boot给我们带来了更好的框架整合， 同时使用spri...
-
我没有在生产上面使用过flink + spring boot ， 不过 storm 集成spring boot，我们在生产环境里面使用过中没有问题的 。 你可以自己看看是不是自己哪儿代码顺序错了， 再结合日志排查一下问题。
flink整合spring boot
Flink框架：Flink整合springboot 首先说一下， 为什么flink 需要集成flink， spring boot给我们带来了更好的框架整合， 同时使用spri...
-
山间草夫 ·这种实现方式，在集群中通过flink run 命令执行的时候会报ClassNotFoundException org.springframework.boot.env.EnvironmentPostProcessor错误。好像是flink类加载默认采用child-first，而java采用双亲委派。不知道您有没有遇到这种问题？
-
@正为疯狂 你说得没错。 范围不一定使用索引。
mysql 联合索引 复合索引（abc）如何索引命中规则实测
鉴于读者们评论,但平时较忙用不到回来看笔记时也看不到评论,今天有时间再补充下实测图片吧 可以略过 最近找工作面试时，被问及了mysql联合索引的一些问题，之前看过‘高性能my...
-
你的这个测试结果好像不对.
a > 1 AND b = 2 AND c = 3 未使用索引
a < 1 AND b = 2 AND c = 3 未使用索引
a > 1 ; 未使用索引
a <> 1 AND b = 2 AND c = 3 未使用索引
这个我用我的8.0 版本的mysql 测试了, 发现只有第4条不走索引, 前面三条是走range索引的.mysql 联合索引 复合索引（abc）如何索引命中规则实测
鉴于读者们评论,但平时较忙用不到回来看笔记时也看不到评论,今天有时间再补充下实测图片吧 可以略过 最近找工作面试时，被问及了mysql联合索引的一些问题，之前看过‘高性能my...
-
生产环境redis 推荐配置
持久化配置 RDB AOF bind 配置redis本身无法限制【只有指定主机】连接到redis中，就像我上面说的一样，bind指定只是用来设置接口地址（interfaces...
-
elasticsearch 布尔表达式在竞价广告中的检索使用
Elasticsearch 在竞价广告中的检索使用 一、广告定向简述 1.1 在竞价广告中的定向条件往往如下所示 ad1 定向为地域北京,上海,广州,深圳,18~28岁的旅...
-
其实我个人是不建议使用spring boot 集成的。 主要是因为我可能有多个flink job。 a flink job 可能使用redis， 但是b flink Job 不使用redis. 那这个时候实在说不过去， 当然， 如果你将flink job 分成多个项目使用spring boot 集成也是可以的。
flink整合spring boot
Flink框架：Flink整合springboot 首先说一下， 为什么flink 需要集成flink， spring boot给我们带来了更好的框架整合， 同时使用spri...
-
山间草夫 ·
这种方法应该是有问题的.行不通,原因如下:
1)在beginTransaction在恢复或者做快照之前调用,这里返回的是一个mysql的connection对象,在这里事务的载体就是这个connection对象
2)precommit是第一次预提交,如果你看过两阶段的源码你就会发现,这个是在给你传入的那个事物的载体对象做快照,对应你这里的就是mysql的connection,,接下来flink会将这个connection存储到状态后端,connection可不是一个普通对象,是一个数据库的连接,能序列化成功?
3)commit,这个是快照成功了.flink内部已经将你上次的事务的载体对象给保存完毕了,在notifyCheckpointComplete里回调用户的commit方法,通知用户checkpoint成功了
connection根本就不能序列化,这是其一,
其二:即便这种方式可行,也会非常不稳定,因为每一次commit的提交都是一个checkpoin的过程,checkpoint的时间有长有短,如果遇到数据量大,checkpoint的时间长，那就意味着你在beginTransaction创建的这个链接得一直是打开的状态,只到checkpoin完成才可以,那你得设置足够长的connectionTimeOut时间和socketTimeOut时间
其三:.如果flink某次任务失败了,你是从checkpoint中恢复上一个mysql的连接? -
flink整合spring boot
Flink框架：Flink整合springboot 首先说一下， 为什么flink 需要集成flink， spring boot给我们带来了更好的框架整合， 同时使用spri...
-
keyBy 出来的过多会影响 效率吗 ?
用两阶段聚合法解决Flink keyBy()算子倾斜
这是上周出现的问题了，简单做个记录。 有一个按平台类型实时统计用户活跃的程序，代码框架如下。 就是水印→开窗→聚合→输出的经典套路。程序正常运行一段时间之后，连续报检查点超时...
-
@凌凌漆_ce87 周末有空会发出来
webflux + kakfa + redis + protostuff 高并发/吞吐量数据采集方案
在虚拟机 8c32g ,一个tomcat 实现400~500 的并发, 3000QPS 已经快是极限, 由于是阻塞式编程, 导致响应时长的的均值和最值差距相当的大. 通过...
-
没放出来
webflux + kakfa + redis + protostuff 高并发/吞吐量数据采集方案
在虚拟机 8c32g ,一个tomcat 实现400~500 的并发, 3000QPS 已经快是极限, 由于是阻塞式编程, 导致响应时长的的均值和最值差距相当的大. 通过...
-
如果是自己整的ProcessFunction 可以保证幂等性. 如果是普通算子, 那不是数据重复计算了 ?
Flink Checkpoint机制
checkpoint是啥 简单点说，就是将正在运行的任务的状态保存下来。这个状态包括任务中每个算子的state，缓存的数据（比如processFunction）等。可以保存在...