问题一:突然发现你们都不要开发oceanbase cdc, Flink 这个竟然兼容mysql-cdc?
突然发现你们都不要开发oceanbase cdc, Flink 这个竟然兼容mysql-cdc?
参考答案:
还没支持,在做了,3月底最快。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/589591
问题二:Flink这个catalog里边不支持oracle吗?
Flink这个catalog里边不支持oracle吗?
参考答案:
Flink在较早的版本中并未提供对Oracle的直接支持,然而在2021年11月15日发布的Flink CDC 2.1版本中,官方通过引入内置Debezium组件,增加了对Oracle数据库的支持。因此,您可以通过使用这个版本的Flink并配合Debezium组件连接到Oracle数据库。
需要注意的是,连接Oracle 19c可能会遇到ORA-44609错误,这可能是因为Oracle 19c不再支持使用LogMiner进行数据捕获。此外,对于Oracle 11g,Flink也并未提供支持。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/589590
问题三:Flink能消费 Streaming interface ("firehose") 吗?这样格式的
Flink能消费 Streaming interface ("firehose") 吗?这样格式的
https://ris-live.ripe.net/manual/
参考答案:
Flink本身不支持直接消费Streaming interface("firehose")格式的数据。但是,您可以通过自定义开发连接器或者使用第三方工具来实现将Streaming interface数据集成到Flink中。
例如,您可以使用Apache NiFi等工具来将Streaming interface数据转换为Flink支持的格式,然后通过Flink的DataStream API或者Table API进行消费和处理。另外,您也可以使用Flink的UDF(User-Defined Function)功能来编写自定义函数,以实现对Streaming interface数据的定制化处理。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/589589
问题四:Flink 在BEGIN STATEMENT SET;END;语句中同时写三个CDAS语句可以吗?
Flink中,是否可以在BEGIN STATEMENT SET;END;中同时编写三个CDAS相关的语句?另外为何尝试部署这样的作业时一直失败且无错误提示,页面等待许久后显示失败?
参考答案:
在Flink的BEGIN STATEMENT SET;END;语句中,可以同时写三个CDAS语句。但是,如果部署一直失败,可能是因为以下原因:
- 语法错误:请检查您的CDAS语句是否正确,确保它们符合Flink的语法规则。
- 网络问题:如果您的Flink集群和MongoDB数据库之间的网络连接存在问题,可能会导致部署失败。请检查网络设置并确保它们正确无误。
- Flink版本不兼容:请确保您使用的Flink版本与CDAS连接器的版本兼容。如果不兼容,可能会导致部署失败。
- 资源不足:如果您的Flink集群或MongoDB数据库资源不足,可能会导致部署失败。请检查资源使用情况并确保它们足够。
- 其他配置问题:请检查您的Flink和MongoDB配置文件,确保它们正确无误。
如果以上方法都无法解决问题,建议您查看Flink和MongoDB的日志文件,以获取更多关于部署失败的详细信息。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/589588
问题五:Flink中,2023-12-07发布的相关版本是否已完成灰度测试?
Flink中,2023-12-07发布的相关版本是否已完成灰度测试?
参考答案:
还没有,正在发。
关于本问题的更多回答可点击进行查看: