proctime in yaml ,sql-cli start throws exception

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

proctime in yaml ,sql-cli start throws exception

su_jun@cjspd.com
 Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exception. This is a bug. Please consider filing an issue.Exception in thread "main" org.apache.flink.table.client.SqlClientException: Unexpected exception. This is a bug. Please consider filing an issue. at org.apache.flink.table.client.SqlClient.main(SqlClient.java:208)Caused by: org.apache.flink.table.client.gateway.SqlExecutionException: Could not create execution context. at org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:878) at org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:226) at org.apache.flink.table.client.SqlClient.start(SqlClient.java:108) at org.apache.flink.table.client.SqlClient.main(SqlClient.java:196)Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' inthe classpath.
Reason: No factory supports all properties.
The matching candidates:org.apache.flink.connector.jdbc.table.JdbcTableSourceSinkFactoryUnsupported property keys:schema.#.proctime




----in sql-cli use proctime() is ok ,but is the yaml config file ,start the sql client throws exception
schema:
name: id
data-type: VARCHAR
name: relation_id
data-type: VARCHAR
name: send_to
data-type: VARCHAR
name: status
data-type: VARCHAR
name: create_by
data-type: VARCHAR
name: send_to_name
data-type: VARCHAR
name: proc_time
data-type: TIMESTAMP(3)
proctime: true