实时计算 Flink版操作报错之表可以自动建，但数据无法导入，连接Starrocks 的be时候，报错，是什么原因-阿里云开发者社区

实时计算 Flink版操作报错之表可以自动建，但数据无法导入，连接Starrocks 的be时候，报错，是什么原因

2024-05-23 189

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

实时计算 Flink 版，1000CU*H 3个月

简介： 在使用实时计算Flink版过程中，可能会遇到各种错误，了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题，查看Flink的日志是关键，它们通常会提供更详细的错误信息和堆栈跟踪，有助于定位问题。此外，Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。

问题一：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