seatunnel-web使用SQL组件时候后台报错，无法找到表格

Question

seatunnel-web开源ETL使用SQL组件时候后台报错，无法找到表格
报错内容如下：

2024-03-29 16:41:34.979 seatunnel bogon ERROR [qtp902064508-24] [GlobalExceptionHandler.logError():83] - ErrorCode:[COMMON-05], ErrorDescription:[Unsupported operation] - SQL validate failed: SELECT id,type FROM test001 where type = 1, cause: Table name: test001 not found
org.apache.seatunnel.transform.exception.TransformException: ErrorCode:[COMMON-05], ErrorDescription:[Unsupported operation] - SQL validate failed: SELECT id,type FROM test001 where type = 1, cause: Table name: test001 not found
    at org.apache.seatunnel.transform.sql.zeta.ZetaSQLEngine.validateSQL(ZetaSQLEngine.java:153)
    at org.apache.seatunnel.transform.sql.zeta.ZetaSQLEngine.parseSQL(ZetaSQLEngine.java:90)
    at org.apache.seatunnel.transform.sql.zeta.ZetaSQLEngine.init(ZetaSQLEngine.java:83)
    at org.apache.seatunnel.transform.sql.SQLTransform.open(SQLTransform.java:118)
    at org.apache.seatunnel.transform.sql.SQLTransform.tryOpen(SQLTransform.java:127)
    at org.apache.seatunnel.transform.sql.SQLTransform.transformTableSchema(SQLTransform.java:145)
    at org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform.transformCatalogTable(AbstractCatalogSupportTransform.java:56)
    at org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform.getProducedCatalogTable(AbstractCatalogSupportTransform.java:46)
    at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseTransform(MultipleTableJobConfigParser.java:463)
    at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseTransforms(MultipleTableJobConfigParser.java:374)
    at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:184)
    at org.apache.seatunnel.engine.core.job.AbstractJobEnvironment.getLogicalDag(AbstractJobEnvironment.java:109)
    at org.apache.seatunnel.engine.client.job.JobExecutionEnvironment.execute(JobExecutionEnvironment.java:73)
    at org.apache.seatunnel.app.service.impl.JobExecutorServiceImpl.executeJobBySeaTunnel(JobExecutorServiceImpl.java:107)
    at org.apache.seatunnel.app.service.impl.JobExecutorServiceImpl.jobExecute(JobExecutorServiceImpl.java:73)
    at org.apache.seatunnel.app.controller.JobExecutorController.jobExecutor(JobExecutorController.java:55)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

Answer 1

引自免费微信小程序：皆我百晓生

在 Apache Seatunnel (现已更名为 Apache DolphinScheduler ETL) 中遇到“Table name: test001 not found”错误，这意味着 SQL 查询尝试访问的数据表（test001）在当前数据源中没有被正确识别或配置。以下是排查和解决这个问题的一些步骤：

1. 检查数据源配置：确保Seatunnel-web连接到的数据源中包含了包含表test001的数据库。您需要检查相关的数据源配置文件，例如 job/source/*/*.json 或在web界面中配置的数据源信息。

   确保配置中的URL、数据库名、用户名和密码都是正确的，并且这个数据库中确实存在名为 test001 的表。

2. 确认SQL语句中的表名引用：

   • 检查SQL语句中是否正确指定了数据库名，例如：SELECT id,type FROM database_name.test001 WHERE type = 1，如果test001不是默认数据库下的表，则需要指定完整的表名。
   • 如果数据源支持模式(schema)，则可能还需要明确指定模式，如：SELECT id,type FROM schema_name.database_name.test001 WHERE type = 1。

3. 查看Seatunnel任务配置：

   • 在Seatunnel任务配置文件中，对应于SQLTransform的配置部分应准确地指定了要使用的数据源。例如：

   {
       "name": "sql_transform",
       "type": "sql",
       "config": {
           "sql": "SELECT id,type FROM test001 WHERE type = 1",
           "output_table": "output_table_name",
           "datasource": {
               "type": "jdbc", // 数据源类型，这里假设是JDBC数据源
               "url": "jdbc:mysql://localhost:3306/your_database_name",
               "table": ["test001"],
               "username": "your_username",
               "password": "your_password"
           }
       }
   }
   

   确保这里的url参数指向包含test001表的数据库实例。

4. 重启并重新执行任务：在完成上述检查和修改后，重新启动Seatunnel任务并再次尝试执行。

通过以上步骤，通常可以解决找不到表的问题。如果问题仍然存在，请进一步查阅Seatunnel或Apache DolphinScheduler ETL的相关文档以获取更详细的指导。