dockerzhang opened a new issue #1030:
URL: https://github.com/apache/incubator-inlong/issues/1030
<p>model：</p>
<p>tubemq-connector-flink</p>
<p>code：</p>
<p>Tubemq tubemq = new
Tubemq().master(masterAddress).topic(topic).property("some key", "some
value");<br/>
ConnectTableDescriptor ctd =
tabEnv.connect(tubemq).inAppendMode().withFormat(format).withSchema(schema);</p>
<p>TableSink tableSink = TableFactoryService.find(TableSinkFactory.class,
ctd.toProperties()).createTableSink(ctd.toProperties());</p>
<p>error message：</p>
<p>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)</p>
<p>cause analysis:</p>
<p>due to parameter verification.</p>
<i>JIRA link - <a
href="https://issues.apache.org/jira/browse/INLONG-441";>[INLONG-441]</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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
