问题一：Flink CDC物化视图能不能做聚合？
Flink CDC物化视图能不能做聚合？
参考回答：
Flink CDC支持实时数据流的捕获和变更数据的同步，可以进行INSERT, DELETE, UPDATE等操作。然而，对于物化视图是否能进行聚合的问题，目前存在一些不同的观点。一种观点认为，Flink SQL不支持对由插入、更新、删除的流进行分组聚合。这可能对某些需要进行复杂数据计算的业务场景带来一定的限制。另一种观点认为，Flink CDC的物化视图是可以进行聚合操作的，但具体实现方式可能需要根据实际业务需求和系统环境进行调整。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/574190
问题二：Flink CDC支持1.18了吗？
Flink CDC支持1.18了吗？
参考回答：
是的，Flink CDC是支持Apache Flink 1.18版本的。Apache Flink 1.18.0版本已经在2021年10月底正式发布，这个版本在流处理场景下做了很多优化，并且增加了许多新的特性和功能。Flink CDC作为一个开源的数据集成框架，具有全增量一体化、无锁读取、并发读取、表结构变更自动同步、分布式架构等技术优势，因此在开源社区中非常受欢迎。值得一提的是，Flink CDC的2.2版本也在近期发布，这个版本共有34位社区贡献者参与贡献，累计贡献了110+ commits。这些更新和改进都极大地丰富了Flink CDC的功能和性能，使其能够更好地满足用户的需求。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/574189
问题三：Flink CDC中doris和sr选择哪个，主键模型用的多？
Flink CDC中doris和sr选择哪个，主键模型用的多？
参考回答：
在Flink CDC中，Doris和SR都是可选的选项，具体选择哪个取决于你的需求和环境。Doris是一个高性能的MPP数据库，适用于实时分析型和大规模数据处理场景。而SR（Stream Processing Runtime）是Flink的一个流处理运行时，适用于实时计算和流处理场景。
关于主键模型，在实际应用中，多表关联（JOIN）和分组（GROUP BY）等操作通常需要用到主键。因此，在设计主键模型时，需要考虑到这些因素。一般来说，主键应该具有唯一性、稳定性和易于生成等特点。在实际应用中，常用的主键模型有自增ID、UUID、雪花算法等。具体选择哪种主键模型，需要根据业务需求和数据特性来决定。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/574186
问题四：Flink CDC胖包瘦包，指的是flink运行环境里面的依赖使用的吗？
Flink CDC胖包瘦包，指的是flink运行环境里面的依赖使用的吗？
参考回答：
Flink CDC的"胖包"和"瘦包"指的是应用程序打包的方式，这与Flink运行环境的依赖有关。具体来说，“胖包”是将应用程序的所有依赖项都打包到单个JAR文件中，这样在本地运行时可以通过命令行直接运行。同时，这种打包方式也支持在集群环境下使用standalone模式运行。这主要是因为设定了classloader.resolve-order: parent-first，Flink框架本身的jar包由application classload加载，而我上传的jar包中的类，由custom classload加载。这三个jar包，跟flink核心类都不冲突。
另一方面，“瘦包”则是指只包含应用程序本身及其依赖项的JAR文件，这种方式可以使得应用程序更加轻量化，但需要确保所有依赖项都能在运行时找到。打瘦包采用的是spring boot提供的打包插件，启动采用的是java的cp命令来加载classpath。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/574185
问题五：Flink CDC中mysql客户端怎么配置？
Flink CDC中mysql客户端怎么配置？应该Mysql比较老
参考回答：
在Flink CDC中配置MySQL客户端，你需要提供以下信息：
- 数据库的URL。格式为
jdbc:mysql://<hostname>:<port>/<database>，其中<hostname>是MySQL服务器的主机名或IP地址，<port>是MySQL服务器的端口号（默认为3306），<database>是要同步的数据库名称。 - 数据库的用户名和密码。用于连接到MySQL服务器。
- 要同步的表的名称。如果你想要同步多个表，可以用逗号分隔。
- 可选的，你可以设置一些其他的参数，如
username,password,serverTimezone等。
以下是一个示例的配置：
SinkFunction<String> sinkFunction = JdbcOutput.sink( "INSERT INTO my_table (column1, column2) VALUES (?, ?)", (ps, record) -> { ps.setString(1, record.f0); ps.setString(2, record.f1); }, new JdbcConnectionOptions.JdbcConnectionOptionsBuilder() .withUrl("jdbc:mysql://localhost:3306/my_database") .withDriverName("com.mysql.jdbc.Driver") .withUsername("username") .withPassword("password") .build() );
在这个示例中，我们创建了一个将数据插入到MySQL表中的SinkFunction。我们使用了JdbcOutput.sink方法来创建一个SinkFunction，该方法接受一个SQL语句和一个PreparedStatement回调函数作为参数。我们还提供了一个JdbcConnectionOptions对象，用于配置JDBC连接参数。
关于本问题的更多回答可点击原文查看：
