问题一:Flink这个版本记录能显示年吗?
Flink这个版本记录能显示年吗?我们要项目审查发现提交记录这边只到月,跨年的整不清楚
参考答案:
我记录下这个需求。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/583829
问题二:Flink为什么最后程序用48.5c 151.44g呢?
我设置的最大并行度是48,每个tm的solt数据是24,每个tm用20c60g,jm用1c8g。这样的设置最后程序使用量应该是41c,128g,但Flink为什么最后程序用48.5c 151.44g呢?
参考答案:
Session最大并行度设置为48,每个TM的solt数据是24,每个TM用20c60g,JMS用1c8g。根据您的计算需求,最后程序使用量应该是41c,128g。但是,由于实时计算是按照函数注册的数量来计费的,而不是按照程序的计算量。因此,Flink会根据您注册的函数数量来计算您的费用,而不是程序的实际使用量。此外,实时计算的计费方式还与您的Session配置有关。如果您的Session配置较高,例如,您的Session配置了更高的并行度或者更多的TM,那么Flink将会为您计算更多的费用。https://help.aliyun.com/zh/flink/product-overview/billable-items
---实时计算 Flink版产品文档
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/583828
问题三:我flink-cdc接mysql/mongo 然后写入mq为什么经常日志会这样?
flink-cdc接mysql/mongo 然后写入mq(ververica-connector-mq),为什么经常日志会这样?info2023-12-21 01:01:44,599 [MQClientFactoryScheduledThread] INFO RocketmqClient [] - send heart beat to broker[mqtrace4hz-23 0 100.100.110.30:8080] failed
参考答案:
这是个 info日志,无需担心,主要关注 Flink 任务 Failover、rps 、checkpoint等是否有影响
您发的这段日志是来自RocketmqClient的信息,它表明心跳发送给[mqtrace4hz-23 0 100.100.110.30:8080]这个代理服务器失败了。通过发送心跳,客户端可以告知代理服务器它的状态和可用性。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/583827
问题四:Flink这个问题可以解决吗?
Flink这个问题可以解决吗?我像详细说明下我司目前情况,然后看怎么迁移到实时数仓,给一个大概的准确的稍微细一点(比如用什么主要产品、目前历史数据可以怎么做、批处理SQL大概怎么改成实时SQL之类的)然后我们再自己去一个个做下POC,做下验证和测试,主要是方向不要偏了。这样子我是提单可以有专人给我大概1v1的沟通下吗?
参考答案:
您这部分有解决方案架构师跟进最好,针对实时这块,实时数仓 Flink 官网文档有些 case
https://help.aliyun.com/zh/flink/use-cases/best-practices/?spm=a2c4g.11186623.0.i90
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/583826
问题五:Flink都3.0了,还不能支持一下MySQL到MySQL的Streaming ETL吗?
Flink都3.0了,还不能支持一下MySQL到MySQL的Streaming ETL吗?
参考答案:
内部已经提需求了。
关于本问题的更多回答可点击进行查看: