[
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)
