谢谢，了解了 发自我的iPhone
> 在 2020年12月1日，23:31，Leonard Xu <xbjt...@gmail.com> 写道： > > Hi, 李轲 > > 这是因为yml只支持1.10之前老的connector，写法是connector.type=‘filesystem’, > 1.11之后的新connector都是 connetor=‘filesystem’, 除了简化了写法外，前者的工厂方法和后者的也不一样, > 所以通过yml定义的新的connector是不能被老的工厂 SPI > 发现的。而在yml中定义表从1.11开始就是不推荐了，因为已经支持了用DDL这种纯SQL的方式定义表。 > > 推荐你可以拉起sql-client后，用DDL的方式建表 > > 祝好 > Leonard > > > >> 在 2020年12月1日，21:43，李轲 <m15652768...@163.com> 写道： >> >> 在服务器上试用sql-client时，启动指令如下： >> >> ./sql-client.sh embedded -l /root/flink-sql-client/libs/ -d >> /data_gas/flink/flink-1.11.2/conf/sql-client-defaults.yaml -e >> /root/flink-sql-client/sql-client-demo.yml >> >> 配置如下： >> >> # 定义表 >> tables: >> - name: SourceTable >> type: source-table >> update-mode: append >> connector: >> type: datagen >> rows-per-second: 5 >> fields: >> f_sequence: >> kind: sequence >> start: 1 >> end: 1000 >> f_random: >> min: 1 >> max: 1000 >> f_random_str: >> length: 10 >> schema: >> - name: f_sequence >> data-type: INT >> - name: f_random >> data-type: INT >> - name: f_random_str >> data-type: STRING >> >> 遇到了如下报错： >> >> Reading default environment from: >> file:/data_gas/flink/flink-1.11.2/conf/sql-client-defaults.yaml >> Reading session environment from: >> file:/root/flink-sql-client/sql-client-demo.yml >> >> >> 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 >> Missing properties: >> format.type=csv >> Mismatched properties: >> 'connector.type' expects 'filesystem', but is 'datagen' >> >> The following properties are requested: >> connector.fields.f_random.max=1000 >> connector.fields.f_random.min=1 >> connector.fields.f_random_str.length=10 >> connector.fields.f_sequence.end=1000 >> connector.fields.f_sequence.kind=sequence >> connector.fields.f_sequence.start=1 >> connector.rows-per-second=5 >> connector.type=datagen >> schema.0.data-type=INT >> schema.0.name=f_sequence >> schema.1.data-type=INT >> schema.1.name=f_random >> schema.2.data-type=STRING >> schema.2.name=f_random_str >> update-mode=append >> >> The following factories have been considered: >> org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactory >> org.apache.flink.connector.jdbc.table.JdbcTableSourceSinkFactory >> 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 >> 也需要自己导包的么？哪里有更详细的资料，求指点，谢谢 >> >> >> >> >> >> > >
