实时计算 Flink版产品使用问题之作业的检查点失败一般是什么导致的

问题一：Flink的作业为啥kafka的消息没有sink到ADB？

Flink的作业为啥kafka的消息没有sink到ADB？

参考答案：

countWindowAll设置有问题

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/660417

问题二：Flink的这个job 一直CP失败，什么原因？

Flink的这个job 一直CP失败，什么原因？

参考答案：

有可能是当Flink Job处理的数据量很大时，可能会导致内存溢出。解决方式是增加TaskManager的内存配置，或者使用RocksDB状态后端来减少内存占用，还有 CPU资源不足可能导致Checkpoint过程中的计算密集型操作变慢。解决方式是增加CPU资源或优化计算逻辑以减少CPU使用，另外 如果Checkpoint超时设置得不合理，可能会导致Checkpoint失败。解决方式是根据实际数据处理速度调整Checkpoint超时时间

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/624520

问题三：Flink按量付费方式，如果我申请的是10CU，但实际使用了6CU，那计费是按10CU还是6CU算？

Flink按量付费方式，如果我申请的是10CU，但实际使用了6CU，那计费是按10CU还是6CU算？

参考答案：

参考https://help.aliyun.com/zh/flink/product-overview/pay-as-you-go?spm=a2c4g.11186623.0.0.316f62c8FqmZJH

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/654884

问题四：Flink按分钟统计后写入结果表，这样的SQL怎么写呀？

Flink按分钟统计后写入结果表，这样的SQL怎么写呀？输入表：SLS，有毫秒时间戳字段

结果表：SLS

参考答案：

您好，使用窗口函数就可以

https://help.aliyun.com/zh/flink/developer-reference/tumble?spm=a2c4g.11186623.0.0.7fc11611jeAMFt 

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/627752