问题一：Flink CDC里整库同步的时候，因为源表有写字段是大文本，怎么解决同步问题？
Flink CDC里整库同步的时候，因为源表有写字段是大文本：longblob、text等等，这时候CDC就无法同步数据了，如何解决这个问题吗？ 
参考答案：
改下StarRocksUtils这个类的createFieldGetter方法,使其支持下bytes格式。 
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/592296
问题二：Flink CDC里用maven shade在做relocation时，如何处理这个多语言的反应？
Flink CDC里用maven shade在做relocation时，只编译进来了Java，而Scala没有被编译进rename后的jar，你们是如何处理这个多语言的relocation呢 ？例如：本来a.jar=10k, rename 后只有8k了，少了2k的scala的代码。
参考答案：
在Apache Flink CDC项目中，如果你使用Maven Shade Plugin进行relocation并遇到只包含了Java代码而未包含Scala代码的问题，可能是shade plugin在处理混合Java和Scala项目的依赖时发生了问题。这是因为Scala编译后的字节码分布在多个地方，不仅仅是类路径下的.class文件，还可能涉及到元数据和其他scala专用的目录结构。
要确保在relocation过程中正确包含Scala部分，你需要确保Maven Shade Plugin的配置正确涵盖了Scala相关的资源。以下是一种可能的解决方案：
<build> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-shade-plugin</artifactId> <version>3.2.4</version> <!-- 使用适合你的版本 --> <executions> <execution> <phase>package</phase> <goals> <goal>shade</goal> </goals> <configuration> <transformers> <transformer implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/> <!-- 处理META-INF/services的合并 --> <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer"> <!-- 修改MANIFEST.MF文件 --> </transformer> <!-- 如果需要重定位，添加Relocator配置 --> <transformer implementation="org.apache.maven.plugins.shade.resource.ApacheNoticeResourceTransformer"/> <!-- 保持Apache许可证信息 --> <transformer implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer"> <resource>META-INF/spring.handlers</resource> </transformer> <transformer implementation="org.apache.maven.plugins.shade.resource.AppendingTransformer"> <resource>META-INF/spring.schemas</resource> </transformer> <!-- 举例：处理Spring框架相关的资源 --> </transformers> <relocations> <!-- 示例：重定位包 --> <relocation> <pattern>原包名</pattern> <shadedPattern>新包名</shadedPattern> </relocation> </relocations> <!-- 确保包含所有资源，特别是Scala相关的 --> <filters> <filter> <artifact>*:*</artifact> <excludes> <!-- 排除不希望shade的内容 --> <exclude>**/*.html</exclude> <exclude>**/*.txt</exclude> </excludes> </filter> <filter> <!-- 包含所有Scala相关资源 --> <artifact>**/*scala*</artifact> <includes> <include>**/*.class</include> <!-- 如果还有其他Scala相关的资源，比如*.sbt、*.scala等 --> </includes> </filter> </filters> </configuration> </execution> </executions> </plugin> </plugins> </build>
特别要注意的是，<filters> 部分需要确保不会意外排除掉Scala编译后的任何.class文件或者其他重要的Scala资源。此外，如果你使用了特殊的Scala插件进行构建，可能还需要额外配置确保它们在shade阶段也被正确处理。
在实践中，有时仅仅依靠Shade Plugin的标准配置可能不够，因为Scala编译后的某些资源可能隐藏在复杂的目录结构中，此时可能需要更精细的过滤和迁移策略。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/592292
问题三：Flink CDC里flink任务当前数据处理了多少条怎么获取啊？
Flink CDC里flink任务当前数据处理了多少条怎么获取啊？
参考答案：
你在web页面可以看到的。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/592291
问题四：Flink cdc 3.0整库同步是不是不支持ddl同步啊？
Flink cdc 3.0整库同步是不是不支持ddl同步啊？
参考答案：
sink库支持应该就支持ddl，3.0到starrocks支持加减字段，但是starrocks不支持修改字段名所以就不支持。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/592289
问题五：Flink CDC里Flink postgreSQL CDC 位置信息是什么？
Flink CDC里Flink postgreSQL CDC 位置信息是什么？ 后来看了一下源码发现offsetmap里面的数据都用到了，整体代表一种位置信息，现在不知道它的各个分片的offsetmap有何不同？
参考答案：
Lsn。这个得看整体设计，每个snapshot spits都会backfiill(读一段日志)，需要记录这个区间，后续流阶段跳过这些数据，保证exactly once。
关于本问题的更多回答可点击进行查看：
