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

Posted to dev@inlong.apache.org by GitBox <gi...@apache.org> on 2021/07/28 11:58:23 UTC

[GitHub] [incubator-inlong] dockerzhang opened a new issue #1026: [INLONG-437] When using flink connector tubemq to create a table environment error

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: dev-unsubscribe@inlong.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [incubator-inlong] dockerzhang closed issue #1026: [INLONG-437] When using flink connector tubemq to create a table environment error

Posted by GitBox <gi...@apache.org>.

dockerzhang closed issue #1026:
URL: https://github.com/apache/incubator-inlong/issues/1026


   


-- 
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: dev-unsubscribe@inlong.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org