[ https://issues.apache.org/jira/browse/TUBEMQ-437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Guocheng Zhang updated TUBEMQ-437: ---------------------------------- Description: Code: StreamExecutionEnvironment bsEnv = StreamExecutionEnvironment.getExecutionEnvironment(); EnvironmentSettings bsSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build(); StreamTableEnvironment bsTableEnv = StreamTableEnvironment.create(bsEnv, bsSettings); Error info: java.lang.IllegalAccessException: Class java.util.ServiceLoader$LazyIterator can not access a member of class org.apache.flink.connectors.tubemq.TubemqTableSourceSinkFactory with modifiers "private" Recommended solution: Modify the constructor of the TubemqTableSourceSinkFactory class to public. was: 代码: 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。 > 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 > > Code: > StreamExecutionEnvironment bsEnv = > StreamExecutionEnvironment.getExecutionEnvironment(); > EnvironmentSettings bsSettings = > EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build(); > StreamTableEnvironment bsTableEnv = StreamTableEnvironment.create(bsEnv, > bsSettings); > Error info: > java.lang.IllegalAccessException: Class java.util.ServiceLoader$LazyIterator > can not access a member of class > org.apache.flink.connectors.tubemq.TubemqTableSourceSinkFactory with > modifiers "private" > > Recommended solution: > Modify the constructor of the TubemqTableSourceSinkFactory class to public. -- This message was sent by Atlassian Jira (v8.3.4#803005)