You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tubemq.apache.org by "Guocheng Zhang (Jira)" <ji...@apache.org> on 2020/12/01 07:38:00 UTC
[jira] [Commented] (TUBEMQ-437) 使用flink connector tubemq的时候创建表环境报错
[ 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)