dockerzhang opened a new issue #1026:
URL: https://github.com/apache/incubator-inlong/issues/1026
<p>Code:</p>
<p>StreamExecutionEnvironment bsEnv =
StreamExecutionEnvironment.getExecutionEnvironment();<br/>
EnvironmentSettings bsSettings =
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build();<br/>
StreamTableEnvironment bsTableEnv = StreamTableEnvironment.create(bsEnv,
bsSettings);</p>
<p>Error info:</p>
<p>java.lang.IllegalAccessException: Class
java.util.ServiceLoader$LazyIterator can not access a member of class
org.apache.flink.connectors.tubemq.TubemqTableSourceSinkFactory with modifiers
"private"</p>
<p> </p>
<p>Recommended solution:</p>
<p>step1: Modify the constructor of the TubemqTableSourceSinkFactory class
to public.</p>
<p>step2: Modify the content of the
META-INF/services/org.apache.flink.table.factories.TableFactory file:
org.apache.flink.connectors.tubemq.TubemqTableSourceSinkFactory.</p>
<p> </p>
<i>JIRA link - <a
href="https://issues.apache.org/jira/browse/INLONG-437";>[INLONG-437]</a>
created by leno</i>
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
