问题一：Flink1.18.0版本连接外部mysql本地执行测试代码报错
版本：Flink1.18.0
代码：```
public static void main(String[] args) {
//1、创建TableEnvironment EnvironmentSettings settings = EnvironmentSettings.newInstance().build(); TableEnvironment tEnv = TableEnvironment.create(settings); //2、创建source table Schema schema = Schema.newBuilder() .column("user",DataTypes.STRING()) .column("url",DataTypes.STRING()) .column("cTime", DataTypes.STRING()) .build(); tEnv.createTemporaryTable( "sourceTable", TableDescriptor.forConnector("jdbc") .schema(schema) .option("url","jdbc:mysql://xxxxxx:3306/flink") .option("driver","com.mysql.jdbc.Driver") .option("table-name","clicklog") .option("username","xxx") .option("password","xxxx") .build() ); //3、创建sink table tEnv.createTemporaryTable("sinkTable", TableDescriptor.forConnector("print").schema(schema).build()); //4、执行sql查询 Table resultTable = tEnv.sqlQuery(" select user,url,cTime from sourceTable "); //5、输出 resultTable.executeInsert("sinkTable"); }
```
自己的做法：已经将jdbc和mysql连接器对应的jar包传到flink集群下的lib目录，且重启了集群服务，pom文件也引入了依赖，然后运行以上代码报错，错误信息如下：
网上有说是缺少flink-shaded-guava依赖，pom文件尝试添加后又报guava31的类找不到错误，以下是我的尝试： 
个人感觉跟pom依赖关系不大，因为我不运行代码而是直接在flink的sql 客户端建立外部连接后执行一个简单的查询也是报类似错误，请问是什么原因呢，请大佬指点指定
参考回答：
jdbc的依赖包问题，参考官方文档或者一些技术网站时，引入的jdbc依赖是
解决方法：将以上jdbc依赖删除，换成如下依赖，并将下载后的依赖传到flink集群的各个节点的lib目录下并重启集群服务 
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/584160
问题二：试了一下Flink CDC 3.0 遇到点问题。怎么解决 ？
试了一下Flink CDC 3.0 遇到点问题。怎么解决？表能自动建，但是数据导不进，连接Starrocks 的be时候，报错了。
参考回答：
根据您提供的信息，Flink CDC 3.0在连接Starrocks时遇到了问题。为了解决这个问题，请按照以下步骤操作：
- 确保您的Flink和Starrocks版本兼容。您可以查看官方文档或联系技术支持以获取更多信息。
- 检查您的Flink配置文件（flink-conf.yaml），确保已正确配置Starrocks的连接信息，例如JDBC URL、用户名和密码等。
- 检查您的Flink SQL语句，确保已正确指定要同步的表名和分区键。例如：
CREATE TABLE source_table ( id INT, name STRING, age INT ) WITH ( 'connector' = 'kafka', 'topic' = 'source_topic', ... ); CREATE TABLE sink_table ( id INT, name STRING, age INT ) WITH ( 'connector' = 'jdbc', 'url' = 'jdbc:mysql://your_starrocks_host:port/database', 'username' = 'your_username', 'password' = 'your_password', ... ); INSERT INTO sink_table SELECT id, name, age FROM source_table;
- 如果仍然遇到问题，请查看Flink和Starrocks的日志文件，以获取更多关于错误的详细信息。这可以帮助您更好地诊断问题并找到解决方案。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/583968
问题三：采集flink指标写入influxdb有遇到这个问题吗？
采集flink指标写入influxdb有遇到这个问题吗？账号密码怎么也配不对. 
参考回答：
确保阿里云账号具有访问InfluxDB的权限。您可以在阿里云控制台中查看账号权限设置，确保您具有写入InfluxDB的权限。确认Flink应用程序与InfluxDB的连接信息是否正确。您可以在Flink控制台中查看应用程序的连接信息，包括连接地址、端口号、用户名和密码等。请确保这些信息正确无误。确认InfluxDB账号和密码是否正确。如果您使用的是阿里云InfluxDB实例，您可以在阿里云控制台中查看实例详情页，找到实例账号和密码，确保这些信息正确无误。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/583967
问题四：Flink写入oss为什么会报以下错误？
Flink写入oss为什么会报以下错误？ 
参考回答：
可能是由于在Flink中写入OSS时出现了路径重名的问题。当Flink写入OSS时，如果您指定的路径与阿里云OSS中的路径相同，Flink会报出该错误。解决这个问题的方法是在指定路径时使用一个唯一的名称，例如在oss://hddisk1/path/to/data.txt这个路径中使用/data.txt。这样，Flink就不会与OSS中的路径重名，并且不会报出这个错误。可以看看这个文档https://help.aliyun.com/zh/oss/use-cases/use-jindosdk-with-apache-flink-to-process-data-stored-in-oss-hdfs
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/583833
问题五：Flink这个问题有人能帮忙瞧瞧吗？
Flink这个问题有人能帮忙瞧瞧吗？ 
参考回答：
字段数量不对，select出来的少一个多个kc字段，在sink表里加个字段kc就行了。
关于本问题的更多回答可点击原文查看：
