Flink中这个是啥情况，jar包都放到lib下面，还是出这个问题？Flink SOL> INSERT INTO tenant_user
SELECT t.agent_id,
这个问题是由于Flink在执行SQL语句时，无法找到合适的表工厂来处理JOIN操作。你可以尝试以下方法解决这个问题：
确保你的Flink版本支持JOIN操作。如果不支持，你需要升级Flink版本或者使用其他方式实现JOIN操作。
检查你的表定义是否正确。在你的SQL语句中，JOIN操作的表名应该是
merchant_agent和merchant_role，而不是t和t1。请修改为正确的表名：
INSERT INTO tenant_user
SELECT t.agent_id,
t.login_name,
t.login_phone,
t.real_name,
t.merchant_no As tenant_no,
t1.role_name AS agent_type,
FROM merchant_agent t
LEFT JOIN merchant_role t1 ON t.agent_type = t1.role_code;
- 如果问题仍然存在，尝试检查你的Flink配置文件（如
flink-conf.yaml），确保已经正确配置了JDBC驱动和数据库连接信息。例如：
table.jdbc-catalog-name: my_catalog
table.jdbc-default-database: my_database
table.jdbc-default-table: my_table
table.jdbc-username: my_username
table.jdbc-password: my_password
table.jdbc-driver-class: com.mysql.jdbc.Driver
- 如果以上方法都无法解决问题，建议查看Flink的日志文件，以获取更详细的错误信息。
