[
https://issues.apache.org/jira/browse/FLINK-20755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yunsky updated FLINK-20755:
---------------------------
Description:
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
was:
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
----在sql create语句中可以使用,在yaml报错
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
Summary: proctime in yaml ,sql-cli start throws exception (was:
proctime 在yaml配置中启动sql-clinet报错)
> proctime in yaml ,sql-cli start throws exception
> -------------------------------------------------
>
> Key: FLINK-20755
> URL: https://issues.apache.org/jira/browse/FLINK-20755
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Client
> Affects Versions: 1.12.0
> Reporter: yunsky
> Priority: Major
>
> 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
>
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)