问题一：Flink CDC有同时在flink集群里面，跑mysql+sqlserver的参考代码么？
Flink CDC有同时在flink集群里面，跑mysql+sqlserver的参考代码么？用的是flink-sql方式，但是很奇怪，
flink-connector-mysql-cdc-2.2.1.jar
debezium-connector-mysql-1.5.4.Final.jar
flink-sql-connector-mysql-cdc-2.2.1.jar
上面的包少了任何一个，都跑不起来。
参考回答：
Flink SQL对于不同的数据源有不同的Connector，包括MySQL和SQL Server。这些Connector通常以JAR包的形式提供，需要在FLink的classpath下。在你的例子中，flink-connector-mysql-cdc-2.2.1.jar、debezium-connector-mysql-1.5.4.Final.jar和flink-sql-connector-mysql-cdc-2.2.1.jar都是MySQL Connector的JAR包，它们分别来自Flink和Debezium项目。
flink-connector-mysql-cdc-2.2.1.jar是Flink提供的MySQL Connector，它包含了用于连接MySQL数据库的基础功能。
debezium-connector-mysql-1.5.4.Final.jar是Debezium提供的MySQL Connector，它包含了用于读取MySQL数据库的Change Data Capture（CDC）功能。
flink-sql-connector-mysql-cdc-2.2.1.jar是Flink提供的MySQL SQL Connector，它包含了用于在FLink SQL中使用MySQL Connector的功能。
这三个JAR包都需要在FLink的classpath下，否则FLink SQL无法识别和使用MySQL Connector。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/574202
问题二：Flink CDC在代码里面集成cdc的时候，是不是也要用上面这个胖包？
Flink CDC在代码里面集成cdc的时候，是不是也要用上面这个胖包flink-sql-connector-mysql-cdc，不要去用瘦包flink-connector-mysql-cdc？
com.ververica
flink-sql-connector-mysql-cdc
2.4.0
参考回答：
是的，如果你打算使用Flink SQL来处理CDC数据并利用Flink CDC的功能，那么你应该使用包含SQL支持的胖包，也就是flink-sql-connector-mysql-cdc。这个胖包包含了对SQL的支持，使得你可以使用Flink SQL来定义数据源、转换和接收器等组件。
瘦包flink-connector-mysql-cdc可能不包含SQL相关的功能，因此在集成到代码中时可能会缺失一些必要的依赖或功能。通常，对于基于Flink SQL的应用场景，推荐使用胖包以确保所有的功能都可以正常工作。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/574201
问题三：Flink CDC可以sink到hbase吗？
Flink CDC可以sink到hbase吗？
参考回答：
是的，Flink CDC可以sink到HBase。您可以使用Flink的DataStream API创建数据流并进行处理，然后将数据写入HBase。具体来说，你需要创建一个继承自RichSinkFunction的自定义Sink，实现其中的open、invoke和close方法，以创建连接对象，批次写入数据到Hbase，以及关闭连接。同时，您需要引入HBase的依赖，然后创建HBase连接和表描述符，接着创建HBase表。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/574198
问题四：Flink CDC给他设置了，还是没有数据出来？
Flink CDC给他设置了，还是没有数据出来？ 
这里配置有什么问题吗？
参考回答：
根据你提供的信息，你在创建 Flink 环境时遇到了问题。这里是一个可能的解决方案：
首先，检查一下你的 StreamExecutionEnvironment 是否正确配置。你需要设置并行度、启用检查点并设置一些相关参数。你已经做了这些步骤，但是需要确保你的代码中没有其他的错误。
其次，检查一下你的 StreamTableEnvironment 是否正确创建。你需要使用 StreamExecutionEnvironment 和 TableEnvironment 来创建 StreamTableEnvironment。你已经做了这个步骤，但是需要确保你的代码中没有其他的错误。
最后，检查一下你的 Flink job 是否正确运行。你可以通过查看日志或者使用 Flink 的 Web UI 来监控你的 job。如果 job 没有正常运行，你可能需要调试你的代码或者检查你的资源使用情况。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/574195
问题五：Flink CDC这个参数无论配置什么，使用的加载类还是flink集群里面的咯？
Flink CDC集群flink-conf，这个参数，classloader.resolve-order如果使用RestClusterClient去提交任务的话，这个参数无论配置什么，使用的加载类还是flink集群里面的咯？ 
下面三个参数1.17中还支持么 ？
参考回答：
是的，无论您如何配置classloader.resolve-order参数，使用RestClusterClient提交任务时，Flink CDC集群使用的加载类仍然是Flink集群中的。这是因为RestClusterClient会与Flink集群进行通信，并使用Flink集群中的类加载器来加载和执行任务。因此，classloader.resolve-order参数的配置不会影响RestClusterClient的行为。
关于本问题的更多回答可点击原文查看：
