[
https://issues.apache.org/jira/browse/TUBEMQ-437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guocheng Zhang updated TUBEMQ-437:
----------------------------------
Summary: When using flink connector tubemq to create a table environment
error (was: 使用flink connector tubemq的时候创建表环境报错)
> When using flink connector tubemq to create a table environment error
> ---------------------------------------------------------------------
>
> Key: TUBEMQ-437
> URL: https://issues.apache.org/jira/browse/TUBEMQ-437
> Project: Apache TubeMQ
> Issue Type: Bug
> Reporter: xianle cao
> Assignee: duli
> Priority: Major
>
> 代码：
> StreamExecutionEnvironment bsEnv =
> StreamExecutionEnvironment.getExecutionEnvironment();
> EnvironmentSettings bsSettings =
> EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build();
> StreamTableEnvironment bsTableEnv = StreamTableEnvironment.create(bsEnv,
> bsSettings);
> 错误信息：
> java.lang.IllegalAccessException: Class java.util.ServiceLoader$LazyIterator
> can not access a member of class
> org.apache.flink.connectors.tubemq.TubemqTableSourceSinkFactory with
> modifiers "private"
> 解决方案：
> 修改TubemqTableSourceSinkFactory类的构造函数为public。
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
