You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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.
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.
The text was updated successfully, but these errors were encountered: