You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tubemq.apache.org by yu...@apache.org on 2021/01/29 10:07:05 UTC
[incubator-tubemq] 07/49: [TUBEMQ-437] Fix tubemq table source sink
factory instance creating problem (#342)
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 <55...@qq.com>
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 <he...@tencent.com>
---
.../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