|
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
|