This is an automated email from the ASF dual-hosted git repository. yuanbo pushed a commit to branch TUBEMQ-421 in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git
commit 86ccc70a0251112f108b45a181cf2255d7929ac9 Author: duli559 <[email protected]> AuthorDate: Fri Dec 4 19:53:16 2020 +0800 [TUBEMQ-437] Fix tubemq table source sink factory instance creating problem (#342) Co-authored-by: herodu <[email protected]> --- .../apache/flink/connectors/tubemq/TubemqTableSourceSinkFactory.java | 2 +- .../META-INF/services/org.apache.flink.table.factories.TableFactory | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/tubemq-connectors/tubemq-connector-flink/src/main/java/org/apache/flink/connectors/tubemq/TubemqTableSourceSinkFactory.java b/tubemq-connectors/tubemq-connector-flink/src/main/java/org/apache/flink/connectors/tubemq/TubemqTableSourceSinkFactory.java index fa006ad..4b581d6 100644 --- a/tubemq-connectors/tubemq-connector-flink/src/main/java/org/apache/flink/connectors/tubemq/TubemqTableSourceSinkFactory.java +++ b/tubemq-connectors/tubemq-connector-flink/src/main/java/org/apache/flink/connectors/tubemq/TubemqTableSourceSinkFactory.java @@ -69,7 +69,7 @@ public class TubemqTableSourceSinkFactory implements StreamTableSourceFactory<Ro private static final String SPLIT_COMMA = ","; - private TubemqTableSourceSinkFactory() { + public TubemqTableSourceSinkFactory() { } @Override diff --git a/tubemq-connectors/tubemq-connector-flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory b/tubemq-connectors/tubemq-connector-flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory index 61b040d..3083174 100644 --- a/tubemq-connectors/tubemq-connector-flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory +++ b/tubemq-connectors/tubemq-connector-flink/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory @@ -13,4 +13,4 @@ # See the License for the specific language governing permissions and # limitations under the License. -org.apache.flink.connectors.tubemq.TubemqTableSourceFactory +org.apache.flink.connectors.tubemq.TubemqTableSourceSinkFactory
