You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "yunsky (Jira)" <ji...@apache.org> on 2020/12/24 03:43:00 UTC
[jira] [Updated] (FLINK-20755) proctime in yaml ,sql-cli start
throws exception
[ 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)