[jira] [Updated] (TUBEMQ-437) When using flink connector tubemq to create a table environment error
[ https://issues.apache.org/jira/browse/TUBEMQ-437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated TUBEMQ-437: -- Labels: pull-request-available (was: ) > 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 > Labels: pull-request-available > Time Spent: 10m > Remaining Estimate: 0h > > 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: > step1: Modify the constructor of the TubemqTableSourceSinkFactory class to > public. > step2: Modify the content of the > META-INF/services/org.apache.flink.table.factories.TableFactory file: > org.apache.flink.connectors.tubemq.TubemqTableSourceSinkFactory. > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (TUBEMQ-437) When using flink connector tubemq to create a table environment error
[ 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)
[jira] [Updated] (TUBEMQ-437) When using flink connector tubemq to create a table environment error
[ 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)
