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)