[ https://issues.apache.org/jira/browse/TUBEMQ-441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated TUBEMQ-441: ---------------------------------- Labels: pull-request-available (was: ) > An error occurred when using the Tubemq class to create a sink table > -------------------------------------------------------------------- > > Key: TUBEMQ-441 > URL: https://issues.apache.org/jira/browse/TUBEMQ-441 > Project: Apache TubeMQ > Issue Type: Bug > Reporter: xianle cao > Assignee: Guocheng Zhang > Priority: Major > Labels: pull-request-available > Time Spent: 10m > Remaining Estimate: 0h > > model: > tubemq-connector-flink > code: > Tubemq tubemq = new > Tubemq().master(masterAddress).topic(topic).property("some key", "some > value"); > ConnectTableDescriptor ctd = > tabEnv.connect(tubemq).inAppendMode().withFormat(format).withSchema(schema); > TableSink tableSink = TableFactoryService.find(TableSinkFactory.class, > ctd.toProperties()).createTableSink(ctd.toProperties()); > error message: > Caused by: org.apache.flink.table.api.ValidationException: Could not find > required property 'connector.group'. at > org.apache.flink.table.descriptors.DescriptorProperties.validateOptional(DescriptorProperties.java:1353) > at > org.apache.flink.table.descriptors.DescriptorProperties.validateString(DescriptorProperties.java:780) > at > org.apache.flink.connectors.tubemq.TubemqValidator.validate(TubemqValidator.java:73) > at > org.apache.flink.connectors.tubemq.TubemqTableSourceSinkFactory.validateProperties(TubemqTableSourceSinkFactory.java:222) > at > org.apache.flink.connectors.tubemq.TubemqTableSourceSinkFactory.createStreamTableSink(TubemqTableSourceSinkFactory.java:185) > cause analysis: > due to parameter verification. -- This message was sent by Atlassian Jira (v8.3.4#803005)