xianle cao created TUBEMQ-437:
---------------------------------
Summary: 使用flink connector tubemq的时候创建表环境报错
Key: TUBEMQ-437
URL: https://issues.apache.org/jira/browse/TUBEMQ-437
Project: Apache TubeMQ
Issue Type: Bug
Reporter: xianle cao
代码：
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)
