问题一:PolarDB Serverless可以用Flink CDC同步数据到Elasticsearch吗?
PolarDB Serverless(MySQL 8.0.1引擎)可以用Flink CDC同步数据到Elasticsearch吗?
参考答案:
可以,用mysql connector
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/620509
问题二:MSE微服务引擎点升级有半个小时了,还没恢复健康,这正常吗?
MSE微服务引擎点升级有半个小时了,还没恢复健康,这正常吗?
参考答案:
如果还没恢复,提个工单
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/621333
问题三:k8snativesession模式下flink run指定的classpath好像没有生效怎么办?
k8s native session模式下,flink run指定的classpath好像没有生效,哪位大神了解么?
参考答案:
尝试配置如下操作:
# 编辑配置文件 vim /etc/profile # 在末尾追加 export JAVA_HOME=/app/jdk1.8.0_202 export JRE_HOME=/app/jdk1.8.0_202/jre export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib:$CLASSPATH export PATH=$JAVA_HOME/bin:$PATH # 使配置文件生效 source /etc/profile
——参考链接。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/646571
问题四:hologres支持冷数据下沉到paimon不?
hologres支持冷数据下沉到paimon不?
参考答案:
现在还在读的能力上,写后面出。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/649390
问题五:Hologres 做维表,flink 读取不到hologres 新写入的数据吗?
Hologres 做维表,flink 读取不到hologres 新写入的数据吗?
参考答案:
开启binlog,是可以读取到新数据的。如果Flink在连续不断地读取Hologres中的维表数据,那么只要Hologres已经成功写入了新的数据(无论使用哪一种模式),理论上Flink应当能够读取到这些新写入的数据。
然而,实际效果取决于您的Flink作业是如何配置和运行的。例如,Flink作业需确保其读取任务具有适当的并行度和 watermark 策略以捕获实时变化的数据。还需注意,如果Hologres的新写入操作与Flink的读取逻辑之间存在时间延迟或者依赖于特定的通知机制,则可能会出现Flink无法立即读取到新写入数据的情况。
关于本问题的更多回答可点击进行查看: