Jingsong Lee created FLINK-14387: ------------------------------------ Summary: Insert into catalog table failed when catalog table not implement table source factory Key: FLINK-14387 URL: https://issues.apache.org/jira/browse/FLINK-14387 Project: Flink Issue Type: Bug Components: Table SQL / Planner Reporter: Jingsong Lee Fix For: 1.10.0
When a TableFactory just implement TableSinkFactory, we use create table DDL to register it into catalog and use tableEnv.sqlUpdate("insert into sinkTable ...."), there will be an exception: {code:java} TableException: findAndCreateTableSource failed. {code} blink-planner should not assume that all TableFactories are TableSourceFactory. -- This message was sent by Atlassian Jira (v8.3.4#803005)