使用sql-client中遇到的一点问题

[李轲]

在服务器上试用sql-client时，启动指令如下：

./sql-client.sh embedded -d /root/flink-sql-client/sql-client-demo.yml

配置见附件，读取的文件也在附件中

遇到了如下报错：

Reading default environment from: file:/root/flink-sql-client/sql-client-demo.yml

No session environment specified.

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:213)

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:870)

at org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:227)

at org.apache.flink.table.client.SqlClient.start(SqlClient.java:108)

at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)

Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' in

the classpath.

Reason: Required context properties mismatch.

The matching candidates:

org.apache.flink.table.sources.CsvAppendTableSourceFactory

Mismatched properties:

'format.type' expects 'csv', but is 'json'

The following properties are requested:

connector.path=/root/flink-sql-client

connector.type=filesystem

format.schema=ROW(name STRING, count INT)

format.type=json

schema.0.data-type=STRING

schema.0.name=name

schema.1.data-type=INT

schema.1.name=count

update-mode=append

The following factories have been considered:

org.apache.flink.table.sources.CsvBatchTableSourceFactory

org.apache.flink.table.sources.CsvAppendTableSourceFactory

org.apache.flink.table.filesystem.FileSystemTableFactory

at org.apache.flink.table.factories.TableFactoryService.filterByContext(TableFactoryService.java:322)

at org.apache.flink.table.factories.TableFactoryService.filter(TableFactoryService.java:190)

at org.apache.flink.table.factories.TableFactoryService.findSingleInternal(TableFactoryService.java:143)

at org.apache.flink.table.factories.TableFactoryService.find(TableFactoryService.java:113)

at org.apache.flink.table.client.gateway.local.ExecutionContext.createTableSource(ExecutionContext.java:384)

at org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$initializeCatalogs$7(ExecutionContext.java:638)

at java.util.LinkedHashMap.forEach(LinkedHashMap.java:684)

at org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:636)

at org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:523)

at org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:183)

at org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:136)

at org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:859)

... 3 more

看描述是有包找不到，到我看官网上说 json 的解析 jar 在 sql-client 中包含啊，试用 sql-client 也需要自己导包的么？哪里有更详细的资料，求指点，谢谢