Operator Chains(操作链) Flink出于分布式执行的目的,将operator的subtask链接在一起形成task(类似spark中的管道)。 每个task在一个线程中执行。 将operators链接成task是非常有效的优化:它可以减少线程与线程间的切换和数据缓冲的开销,并在降低延 ...
分类:
其他好文 时间:
2019-11-13 22:27:32
阅读次数:
504
解决办法:File-->Setting...-->Build,Execution,Deployment-->Compiler-->Java Compiler 设置相应Module的target bytecode version的合适版本(跟你jdk版本一致就行),这里我改成8版本的。 ...
分类:
编程语言 时间:
2019-11-13 17:55:11
阅读次数:
93
k8s 1.10群集配置过程 #####k8s 1.10 cnetos 7 ######基础配置 所有节点 ##################################################### ########################################## ...
分类:
其他好文 时间:
2019-11-12 12:51:53
阅读次数:
84
就以netty example中的EchoServer这个经典例子作为楔子吧 // 创建bossGroup和workerGroup,reactor模式的实现 EventLoopGroup bossGroup = new NioEventLoopGroup(1); EventLoopGroup wor ...
分类:
Web程序 时间:
2019-11-11 23:06:10
阅读次数:
173
手写SpringMVC框架 细嗅蔷薇 心有猛虎 背景:Spring 想必大家都听说过,可能现在更多流行的是Spring Boot 和Spring Cloud 框架;但是SpringMVC 作为一款实现了MVC 设计模式的web (表现层) 层框架,其高开发效率和高性能也是现在很多公司仍在采用的框架; ...
分类:
编程语言 时间:
2019-11-10 10:02:07
阅读次数:
89
1、概述 切入点(execution ):可以对指定的方法进行拦截,从而给指定的类生成代理对象。(拦截谁,就是去执行谁) 格式: execution(modifiers-pattern? ret-type-pattern declaring-type-pattern? name-pattern(pa ...
分类:
编程语言 时间:
2019-11-09 00:42:35
阅读次数:
105
cannot assign instance of scala.collection.immutable.List$SerializationProxy to field org.apache.spark.sql.execution.aggregate.SortAggregateExec.aggre ...
分类:
编程语言 时间:
2019-11-07 17:41:34
阅读次数:
113
出现这个问题的原因可能是:PowerShell执行策略的问题 解决: 1. 右击VSCode图标,选择以管理员身份运行;2. 在终端中执行get-ExecutionPolicy,显示Restricted,表示状态是禁止的;3. 这时执行set-ExecutionPolicy RemoteSigned ...
分类:
其他好文 时间:
2019-11-04 11:55:10
阅读次数:
248
1、切点指示器 类型如下: 1、execution: *用来匹配连接点方法的,用的最多的一种指示器,可以匹配多个类,必须要写返回类型,方法名,方法参数,可以写通配符。 2、within: 用来匹配符合条件的所有类的连接点方法,不可以指定返回类型和方法参数,可以用通配符。expression="wit ...
分类:
编程语言 时间:
2019-11-03 21:56:01
阅读次数:
172