[
https://issues.apache.org/jira/browse/FLINK-12633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328411#comment-17328411
]
Flink Jira Bot commented on FLINK-12633:
----------------------------------------
This major issue is unassigned and itself and all of its Sub-Tasks have not
been updated for 30 days. So, it has been labeled "stale-major". If this ticket
is indeed "major", please either assign yourself or give an update. Afterwards,
please remove the label. In 7 days the issue will be deprioritized.
> 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
> Labels: stale-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
(v8.3.4#803005)
