You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@tubemq.apache.org by "xianle cao (Jira)" <ji...@apache.org> on 2020/12/01 06:23:00 UTC

[jira] [Created] (TUBEMQ-437) 使用flink connector tubemq的时候创建表环境报错

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)