[ https://issues.apache.org/jira/browse/TUBEMQ-437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241320#comment-17241320 ]
Guocheng Zhang commented on TUBEMQ-437: --------------------------------------- Thanks [~leno], we got it! > 使用flink connector tubemq的时候创建表环境报错 > ---------------------------------- > > Key: TUBEMQ-437 > URL: https://issues.apache.org/jira/browse/TUBEMQ-437 > Project: Apache TubeMQ > Issue Type: Bug > Reporter: xianle cao > 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)