前言1.安装环境依赖运行所需Java、 scala 环境。1.1 安装scala先创建需要下载scala的目录mkdir scala下载scalawget https://downloads.lightbend.com/scala/2.11.8/scala-2.11.8.tgz解压安装tar -zxvf scala-2.11.8.tgzvi /etc/profile添加对应的配置，根据你安装sca

flink连接mysql 的一些问题解决办法

前言学习一门语言,之前的java 因为学习的周期比较久,自己也是做java开发的,所以对这写较简单的没有记录.但是要学习大数据相关的东西,会用到scala,所以抽一些零散时间整理记录,学习一下这门语言.1. scala sdk的安装windows 安装scala 的 sdk官网下载进入页面 拉到页面最下面 选择自己喜欢的版本设置 parh (我电脑–>高级设置–>环境变量设置)注意：安

Mysql Error:The user specified as a definer (‘mysql.infoschema’@’localhost’) does not exist

mysql 的执行计划1.mysql 是使用 explain +sql 语句 查看执行计划的.EXPLAIN SELECT * FROM user WHERE nid = 3;table : 正在访问的表名possible_keys : 可能使用的索引key : 真实使用的key_len : MySQL中使用索引字节长度rows : mysql 预估为了找到所需的行而要读取的行数limitlimi

tsdb 时空时序数据库 中的 几个关键词mertic: mertic 类似 关系型数据库 的一张 表名。fields 就是 其中 的字段 类似于column 字段。tags ： 是 能作为查询tsdb 的字段。 设置成tags 的 是固定不变化的，维度查询的字段。至于 说 为什么tags 这样设定。 下边引出一个 时间线的概念。tsdb 的中时间线的概念点击看详情从图中可以看出...

mysql 锁表和查询超时解决办法

使用发link tableApi 进行表和流转换报错Exception in thread "main" java.lang.IllegalStateException: No operators defined in streaming topology. Cannot generate StreamGraph.at org.apache.flink.table.planner.utils.Ex

三种udf：(SQL里可解释的Function)ScalarFunctionTableFunctionAggregateFunction一、Scalar Functions 标量函数标量函数，是指返回一个值的函数。标量函数是实现将0，1，或者多个标量值转化为一个新值。标量函数的行为就是通过evaluation方法来实现的。evaluation方法必须定义为public，命名为eval。evalua

前言1. 运行状态和数字的含义方块上的数字6，是串行执行的task数量(从输入task一直到输出task),6具体的含义如下这里运行的 数字 ，表示整个流程从头到尾总共有6个task。2. 运行的状态和颜色...