首页 > 数据库 >FlinkSQL Unable to create a source for reading table 'default_catalog.default_database.xxx'

FlinkSQL Unable to create a source for reading table 'default_catalog.default_database.xxx'

时间:2024-04-03 17:24:47浏览次数:22  
标签:jdbc database default FlinkSQL dic Unable table create

问题描述

使用 FlinkSql 的 jdbc 连接器 读取 mysql 的一张表,总是提示 

Exception in thread "main" org.apache.flink.table.api.ValidationException: Unable to create a source for reading table 'default_catalog.default_database

程序代码

    public static void main(String[] args) {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.setParallelism(4);
        StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);
        tableEnv.executeSql("CREATE TABLE dim_dic (\n" +
                "  dic_id STRING,\n" +
                "  dic_desc STRING,\n" +
                "  update_time STRING,\n" +
                "  PRIMARY KEY (dic_id) NOT ENFORCED \n" +
                ") WITH (\n" +
                "   'connector' = 'jdbc',\n" +
                "   'url' = 'jdbc:mysql://hostname:3306/db',\n" +
                "   'table-name' = 'dim_dic',\n" +
                "   'username' = 'username',\n" +
                "   'password' = 'pwd----'\n" +
                ")");
        tableEnv.executeSql("select * from dim_dic ").print();
    }

解决方式

仔细看了下SQL无误,再次查看官网发现少了依赖

<!-- https://mvnrepository.com/artifact/org.apache.flink/flink-connector-jdbc -->
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-jdbc</artifactId>
    <version>3.1.1-1.17</version>
    <scope>provided</scope>
</dependency>

 

标签:jdbc,database,default,FlinkSQL,dic,Unable,table,create
From: https://www.cnblogs.com/wdh01/p/18113052

相关文章

  • MySQL数据库报错:ERROR 1364 (HY000): Field ‘authentication_string‘ doesn‘t have
    在MySQL安装和配置的过程中,遇到错误可能会让人感到困惑,尤其是当错误信息不够清晰时。本文将详细探讨一个在MySQL安装过程中较少见但可能会遇到的错误,提供一个全面的解决方案指南。错误描述在MySQL安装过程中,可能会遇到以下错误信息:ERROR1364(HY000):Field'authentica......
  • 【 Java系列】--基础篇-1、认识接口中的default关键字
    原创:朱老师缘神日记default关键字:是在Java8中引入的新概念,也可称为Virtualextensionmethods——虚拟扩展方法,它与public、private等都属于修饰符关键字,与其它两个关键字不同之处在于default关键字大部分都用于修饰接口。default修饰方法时只能在接口类中使用,在接口中......
  • 启用Flashback Database闪回数据库功能
     若想顺利的使用闪回数据库功能,需要先将数据库置于闪回数据库状态。此文记录开启闪回数据库功能的步骤,注意调整过程需要重启数据库并确保数据库处于归档模式。1.确认数据库是否开启FlashbackDatabase功能若未开启,则继续,若已经开启,请从此小文儿飘过~~SYS@ora11g>selectflashbac......
  • 浅谈C# Linq里的FirstOrDefault,First,Single,SingleOrDefault 方法
    FirstOrDefault:返回第一个元素,如果为空,则返回类型的默认值;数值类型默认值是0,引用类型默认值是NULL,布尔类型默认值是FalseFirst:也是返回第一个元素,但是如果为空的话,会抛出异常!!Single:返回唯一一个符合条件的元素,如若没有或者有多条,都会抛出异常!SingleOrDefault:返回唯一一个......
  • Flashback Database闪回数据库功能实践
    FlashbackDatabase闪回数据库功能极大地降低了由于用户错误导致的数据丢失的恢复成本。这是一种以空间换取缩短恢复时间的解决方案,这是值得的。这里给出闪回数据库的使用方法,体验一下这种恢复操作的便利性。1.使用FlashbackDatabase的前提条件1)启用了flashbackdatabase2)必须打......
  • Conceptual Database Design 2
    1. ConsideruseofenhancedmodellingconceptsObjectiveistoidentifysuperclassandsubclassentitytypes,whereappropriate.•Themodellingofsuperclassesandsubclassesaddsmoreinformationtothedatamodel,butalsoaddsmorecomplexityaswel......
  • default_statistics_target参数对PG和MogDB性能影响测试和分析
    default_statistics_target参数对PG和MogDB性能影响测试和分析本文出处:https://www.modb.pro/db/230160前段时间在某客户生产环境优化PG查询性能时发现一个很有意思的现象,一个统计信息相关参数可以很大程度上影响SQL的性能。近期在学习MogDB,就对比PG和MogDB做了个......
  • Mogdb - 安装报错Failed to encrypt the password for databaseError
    Mogdb-安装报错FailedtoencryptthepasswordfordatabaseError本文出处:https://www.modb.pro/db/418363版本MogdbV2.0.1红旗V6故障现象安装过程中出现报错[GAUSS-50322]:FailedtoencryptthepasswordfordatabaseError:/dbdata/app/mogdb/bin/gs_guc:error......
  • export default无法被解构
    最近在做项目过程中,遇到一个问题,对一个UI组件,解构出我们需要的组件,进行注册,但是运行的时候报错了,写了一个小例子//user.jsexportdefault{obj:{name:1111},obj2:{name:22222},}//index.jsimport{obj,obj2}from"./user.js"console.log(obj,obj2)代码运行编译时候报错了......
  • 为什么 export 导出一个字面量会报错,而使用 export default 就不会报错?
    核心其实总的来说就是export导出的是变量的句柄(或者说符号绑定、近似于C语言里面的指针,C++里面的变量别名),而exportdefault导出的是变量的值。需要注意的是:模块里面的内容只能在模块内部修改,模块外部只能使用。esModule在语法层面做了一层浅层的保护(即将import导入的变量......