阿里云开发者社区-阿里云支持与服务-问答-第37页-阿里云

1

回答

Flink向下取整函数

已解决

阿里云服务支持 2022-12-19 245浏览量回答数 1

Flink计算numeric向下取整的值需使用FLOOR函数，详情请参考官方文档。

阿里云服务支持赞 0 评论 0

1

回答

Flink计算小数部分以截断方式取整函数

已解决

阿里云服务支持 2022-12-19 330浏览量回答数 1

Flink对numeric1的小数部分以截断的方式取整，取整的位数由numeric2决定，需使用TRUNCATE函数，详情请参考官方文档。

● 如果参数为 NULL，则结果也是 NULL。

● 如果 numeric2 为0或不填，则结果没有小数部分。numeric2 可为负数，此时对整数部分取整。

○ 例如 TRUNCATE(41.231, 2) 返回41.23；TRUNCATE(41.231) 返回41.0；TRUNCATE(41.231, -1) 返回40.0。

阿里云服务支持赞 0 评论 0

1

回答

Flink余弦值函数

已解决

阿里云服务支持 2022-12-19 249浏览量回答数 1

Flink计算numeric的余弦值需使用COS函数，详情请参考官方文档。

阿里云服务支持赞 0 评论 0

1

回答

Flink双曲余弦值函数

已解决

阿里云服务支持 2022-12-19 214浏览量回答数 1

计算numeric的双曲余弦值（返回值为 DOUBLE 类型）需使用 COSH 函数，详情请参考官方文档。

阿里云服务支持赞 0 评论 0

1

回答

Flink余切值函数

已解决

阿里云服务支持 2022-12-19 215浏览量回答数 1

Flink计算numeric的余切值需使用COT函数，详情请参考官方文档。

阿里云服务支持赞 0 评论 0

1

回答

Flink反正弦值函数

已解决

阿里云服务支持 2022-12-19 291浏览量回答数 1

Flink计算numeric的反正弦值需使用ASIN函数，详情请参考官方文档。

阿里云服务支持赞 0 评论 0

1

回答

Flink反余弦值函数

已解决

阿里云服务支持 2022-12-19 216浏览量回答数 1

Flink计算numeric的反余弦值需使用ACOS函数，详情请参考官方文档。

阿里云服务支持赞 0 评论 0

1

回答

Flink反正切值函数

已解决

阿里云服务支持 2022-12-19 239浏览量回答数 1

Flink计算numeric的反正切值需使用ATAN函数，详情请参考官方文档。

阿里云服务支持赞 0 评论 0

1

回答

Flink四象限反正切值函数

已解决

阿里云服务支持 2022-12-19 286浏览量回答数 1

Flink计算 (numeric1、numeric2) 坐标点的四象限反正切值需使用ATAN2函数，详情请参考官方文档。

阿里云服务支持赞 0 评论 0

1

回答

Flink弧度转为角度函数

已解决

阿里云服务支持 2022-12-19 201浏览量回答数 1

Flink将numeric从弧度转为角度需使用DEGREES函数，详情请参考官方文档。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink角度转为弧度函数

已解决

阿里云服务支持 2022-12-19 219浏览量回答数 1

Flink将numeric从角度转为弧度需使用RADIANS函数，详情可点击“官方文档”进行参考。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink判断数据正负函数

已解决

阿里云服务支持 2022-12-19 262浏览量回答数 1

Flink计算numeric 的符号，负数是-1，0返回0，正数是1，需使用 SIGN函数，详情请参考官方文档。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink PI函数

已解决

阿里云服务支持 2022-12-19 344浏览量回答数 1

Flink返回一个可以代表 π 的值需使用PI函数，详情可参考官方文档。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink BIN函数

已解决

阿里云服务支持 2022-12-19 226浏览量回答数 1

Flink获取numeric的二进制表示的字符串，例如输入10，则返回"0b1010"，需使用 BIN 函数，详情请参考官方文档。

阿里云服务支持赞 0 评论 0

1

回答

Flink按位取异或函数

已解决

阿里云服务支持 2022-12-19 255浏览量回答数 1

Flink按位取异或需使用BITXOR函数，详情请参考 BITXOR。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink对数值进行进制转换函数

已解决

阿里云服务支持 2022-12-19 496浏览量回答数 1

Flink对数字或字符类型的数值进行进制转换需使用CONV函数，详情请点击“CONV”进行参考。

阿里云服务支持赞 0 评论 0

2

回答

Flink计算两个日期之间的天数差值函数

已解决

阿里云服务支持 2022-12-19 951浏览量回答数 2

Flink计算两个日期之间的天数差值需使用DATEDIFF函数，详情请参考 DATEDIFF。

阿里云服务支持赞 0 评论 0

1

回答

Flink日期格式转换函数

已解决

阿里云服务支持 2022-12-19 372浏览量回答数 1

Flink将字符串类型的日期从原格式转换至目标格式需使用DATE_FORMAT函数，详情请参考 DATE_FORMAT。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink时间戳格式转换函数

已解决

阿里云服务支持 2022-12-19 246浏览量回答数 1

Flink将时间戳类型的数据根据指定的时区转成指定格式的字符串，需使用DATE_FORMAT_TZ函数，详情请参考 DATE_FORMAT_TZ。

阿里云服务支持赞 0 评论 0

1

回答

Flink拆分key-value函数

已解决

阿里云服务支持 2022-12-19 192浏览量回答数 1

Flink将目标字符串按照split1分隔符拆分成Key-Value（KV）对，然后按照split2分隔符将Key-Value对分开，返回Key对应的Value。需使用KEYVALUE函数，详情请参考 KEYVALUE。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink如何将INT类型或者VARCHAR类型的日期转换成DATE函数

已解决

阿里云服务支持 2022-12-19 383浏览量回答数 1

Flink将INT类型或者VARCHAR类型的日期转换成DATE类型，需使用 TO_DATE 函数，详情请参考 TO_DATE。

阿里云服务支持赞 0 评论 0

2

回答

Flink高性能DISTINCT函数

已解决

阿里云服务支持 2022-12-19 286浏览量回答数 2

Flink支持MiniBatch或Local-Global等优化，需使用APPROX_COUNT_DISTINCT函数，详情请参考 APPROX_COUNT_DISTINCT。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink如何使用FIRST_VALUE函数

已解决

阿里云服务支持 2022-12-19 255浏览量回答数 1

可参考文档：FIRST_VALUE

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink如何从JSON字符串中取出各路径字符串所表示的值函数

已解决

阿里云服务支持 2022-12-19 344浏览量回答数 1

Flink从JSON字符串中取出各路径字符串所表示的值，需使用JSON_TUPLE函数，详情请参考 JSON_TUPLE。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink报错The difference between the request time

已解决

阿里云服务支持 2022-12-19 414浏览量回答数 1

可参考QA：报错：The difference between the request time and the current time is too large

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink报错java.lang.IllegalArgumentException

已解决

阿里云服务支持 2022-12-19 471浏览量回答数 1

可参考QA：报错：java.util.concurrent.CompletionException: java.lang.IllegalArgumentException

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink报错Object '****' not found

已解决

阿里云服务支持 2022-12-19 351浏览量回答数 1

可参考QA：报错：Object '****' not found

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink报错Exceeded checkpoint tolerable failure t

已解决

阿里云服务支持 2022-12-19 610浏览量回答数 1

可参考QA：报错：Exceeded checkpoint tolerable failure threshold

阿里云服务支持赞 0 评论 0

1

回答

E-MapReduce如何使用Flume进行数据迁移

已解决

阿里云服务支持 2022-12-19 290浏览量回答数 1

需要在新集群上也开启flume服务，并且将数据按照和老集群完全一致的规则写入到新集群中。Flume分区表写入 Flume数据双写，双写时需控制开始的时机，要保证flume在开始一个新的时间分区的时候来进行新集群的同步。如flume每小时整点会同步所有的表，那就要整点之前，开启flume同步服务，这样flume在一个新的小时内写入的数据，在旧集群和新集群上是完全一致的。而不完整的旧数据在distcp的时候，全量的同步会覆盖它。而开启双写时间点后的新数据，在数据同步的时候不进行同步。这个新的写入的数据，在划分数据阶段不要放到数据同步的目录里。详情请参见：E-MapReduce数据迁移方案。

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink报错The primary key is necessary when enabl

已解决

阿里云服务支持 2022-12-19 1002浏览量回答数 1

可参考QA：报错：The primary key is necessary when enable 'Key: 'scan.incremental.snapshot.enabled' , default: true (fallback keys: [])' to 'true'

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink报错Only a single 'INSERT INTO' is

已解决

阿里云服务支持 2022-12-19 416浏览量回答数 1

可参考QA：报错：Only a single 'INSERT INTO' is supported

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink报错undefined

已解决

阿里云服务支持 2022-12-19 394浏览量回答数 1

可参考QA：报错：undefined

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink版的ververica-connector-mq如何从指定位点读取数据

已解决

阿里云服务支持 2022-12-19 335浏览量回答数 1

MQ开发可以参考 RocketMQ DataStream Connector，相关的with参数设置可以参考sql的消息队列RocketMQ版源表。

RocketMQ的连接配置信息，与对应SQL配置完全相同的。

阿里云服务支持赞 0 评论 0

1

回答

Flink SQL的connector表中with必填参数

已解决

阿里云服务支持 2022-12-19 316浏览量回答数 1

可以参考一下文档对应的with参数部分，从而判断是否必填列：

阿里云服务支持赞 0 评论 0

1

回答

Flink提示集群资源超用是什么原因

已解决

阿里云服务支持 2022-12-19 304浏览量回答数 1

这是因为Flink集群资源不足，导致作业无法正常running，请调整资源后重试。

阿里云服务支持赞 0 评论 0

1

回答

Flink的Queries语句使用介绍

已解决

阿里云服务支持 2022-12-19 218浏览量回答数 1

可参考文档：Queries语句

阿里云服务支持赞 0 评论 0

1

回答

Flink是否有作业数的限制

已解决

阿里云服务支持 2022-12-19 257浏览量回答数 1

Flink没有作业数的限制。

阿里云服务支持赞 0 评论 0

1

回答

Flink如何申请退款

已解决

阿里云服务支持 2022-12-19 284浏览量回答数 1

可参考文档：当不再需要使用集群时，如何申请退款？

阿里云服务支持赞 0 评论 0

1

回答

实时计算Flink报错The connector is trying to read binlog

已解决

阿里云服务支持 2022-12-19 444浏览量回答数 1

该报错的原因是作业处理的速度追不上binlog产生的速度，导致正在读的位点被清理了。目前只能清理状态重启。

● 场景1: rds做了内部迁移操作，flink jar作业使用mysql cdc消费mysql数据。

报错原因：是作业处理的速度追不上mysql binlog 产生的速度，导致正在读的位点被清理了。

排查思路：

先确认rds的地址和binlog文件位点和迁移前是否一致：

（1）rds 地址不会变化

（2）如果节点有变化，binlog文件位点会变化。如果是从远程拉取的oss中的binlog，binlog是固定的。

解决方案：

（1）重新读取：flink cdc不会到oss上拉文件，是直链mysql服务器（无状态重启）。

（2）绕行方案：从只读库拉取数据。 

注意事项：

（1）从库读是支持的，从库延时比主库大点。注意RDS MySQL 5.6不支持，5.7之后的版本都支持，因为RDS MySQL 5.6 只读实例的binlog文件是简化过的，没有数据。

（2）主库风险也还好，flink cdc 只有读的权限，不会加锁和写的权限。如果rds配置了HA，即多主实例，用户同时开启了GTID，然后通过VIP/DNS下挂rds的几个多主实例地址，这样flink cdc /canal 这些同步工具通过访问 VIP/DNS 链接rds时才能实现不中断。

● 场景2：RDS有日志保留策略，最长18个小时，最大占用30%存储空间，两个条件谁先满足都会触发删除，如果写入特别多，超过30%的存储空间，可能binlog日志1小时就删除了。注意：rds页面上还有一个7天的binlog文件保存，这个是rds后台转存到oss上的，flink cdc目前是没有去转存后oss上去读取这些文件的。

● 场景3：volvo通过只读实例消费CDC数据，RDS的只读实例不保证binlog（本地只保留10s，上传oss），所以flink cdc侧不建议连接 RDS 的只读实例。只读实例一旦作业 Failover 10s 内恢复不过来，就会有这个异常只读实例判定，rr开头的就是只读实例rm开头的就是正常的实例。

阿里云服务支持赞 0 评论 0

1

回答