[jira] [Updated] (FLINK-12633) flink sql-client throw No context matches

["Robert Metzger (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-12633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Robert Metzger updated FLINK-12633:
-----------------------------------
    Component/s: Table SQL / Client

> flink sql-client throw No context matches
> -----------------------------------------
>
>                 Key: FLINK-12633
>                 URL: https://issues.apache.org/jira/browse/FLINK-12633
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Client
>    Affects Versions: 1.7.2
>            Reporter: xiezhiqiang
>            Priority: Major
>
> test.yarml
> {code:java}
> tables:
> - name: Test
> type: source-table
> schema:
> - name: id
> type: INT
> - name: cnt
> type: INT
> connector:
> type: filesystem
> path: "/data/demo/test.csv"
> format:
> type: csv
> fields:
> - name: id
> type: INT
> - name: cnt
> type: INT
> line-delimiter: "\n"
> comment-prefix: "#"
> field-delimiter: ","
> # # Define user-defined functions here.
> # # functions:
> # # - name: myUDF
> # # from: class
> # # class: foo.bar.AggregateUDF
> # # constructor:
> # # - 7.6
> # # - false
> # # Execution properties allow for changing the behavior of a table program.
> execution:
> type: streaming # required: execution mode either 'batch' or 'streaming'
> result-mode: table # required: either 'table' or 'changelog'
> time-characteristic: event-time # optional: 'processing-time' or 'event-time' (default)
> parallelism: 1 # optional: Flink's parallelism (1 by default)
> periodic-watermarks-interval: 200 # optional: interval for periodic watermarks (200 ms by default)
> max-parallelism: 16 # optional: Flink's maximum parallelism (128 by default)
> min-idle-state-retention: 0 # optional: table program's minimum idle state time
> max-idle-state-retention: 0 # optional: table program's maximum idle state time
> # Deployment properties allow for describing the cluster to which table programs are submitted to.
> deployment:
> response-timeout: 5000
> {code}
> test.csv
> {code:java}
> id,cnt
> 1,2
> 2,3{code}
> {code:java}
> throws
> Searching for '/usr/local/Cellar/apache-flink/1.7.2/libexec/conf/sql-client-defaults.yaml'...found. Reading default environment from: file:/usr/local/Cellar/apache-flink/1.7.2/libexec/conf/sql-client-defaults.yaml Reading session environment from: file:/data/demo/test.yaml Validating current environment... Exception in thread "main" org.apache.flink.table.client.SqlClientException: The configured environment is invalid. Please check your environment files again. at org.apache.flink.table.client.SqlClient.validateEnvironment(SqlClient.java:140) at org.apache.flink.table.client.SqlClient.start(SqlClient.java:99) at org.apache.flink.table.client.SqlClient.main(SqlClient.java:187) Caused by: org.apache.flink.table.client.gateway.SqlExecutionException: Could not create execution context. at org.apache.flink.table.client.gateway.local.LocalExecutor.getOrCreateExecutionContext(LocalExecutor.java:488) at org.apache.flink.table.client.gateway.local.LocalExecutor.validateSession(LocalExecutor.java:316) at org.apache.flink.table.client.SqlClient.validateEnvironment(SqlClient.java:137) ... 2 more Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.StreamTableSourceFactory' in the classpath. Reason: No context matches. The following properties are requested: connector.path=/data/demo/test.csv connector.type=filesystem format.comment-prefix=# format.field-delimiter=, format.fields.0.name=id format.fields.0.type=INT format.fields.1.name=cnt format.fields.1.type=INT format.line-delimiter=\n format.type=csv schema.0.name=id schema.0.type=INT schema.1.name=cnt schema.1.type=INT The following factories have been considered: org.apache.flink.formats.json.JsonRowFormatFactory org.apache.flink.table.sources.CsvBatchTableSourceFactory org.apache.flink.table.sources.CsvAppendTableSourceFactory org.apache.flink.table.sinks.CsvBatchTableSinkFactory org.apache.flink.table.sinks.CsvAppendTableSinkFactory at org.apache.flink.table.factories.TableFactoryService$.filterByContext(TableFactoryService.scala:214) at org.apache.flink.table.factories.TableFactoryService$.findInternal(TableFactoryService.scala:130) at org.apache.flink.table.factories.TableFactoryService$.find(TableFactoryService.scala:100) at org.apache.flink.table.factories.TableFactoryService.find(TableFactoryService.scala) at org.apache.flink.table.client.gateway.local.ExecutionContext.createTableSource(ExecutionContext.java:236) at org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$new$0(ExecutionContext.java:121) at java.util.LinkedHashMap.forEach(LinkedHashMap.java:684) at org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:119) at org.apache.flink.table.client.gateway.local.LocalExecutor.getOrCreateExecutionContext(LocalExecutor.java:484) ... 4 more
>  
> {code}
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)