[
https://issues.apache.org/jira/browse/TUBEMQ-437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243960#comment-17243960
]
ASF subversion and git services commented on TUBEMQ-437:
--------------------------------------------------------
Commit 66f5438d0726b9901f45250817834fadf0acc202 in incubator-tubemq's branch
refs/heads/master from duli559
[ https://gitbox.apache.org/repos/asf?p=incubator-tubemq.git;h=66f5438 ]
[TUBEMQ-437] Fix tubemq table source sink factory instance creating problem
(#342)
Co-authored-by: herodu <[email protected]>
> 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: 50m
> 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)
