[jira] [Updated] (TUBEMQ-441) An error occurred when using the Tubemq class to create a sink table

[ASF GitHub Bot (Jira)]

 [ 
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)

[jira] [Updated] (TUBEMQ-441) An error occurred when using the Tubemq class to create a sink table

[xianle cao (Jira)]

 [ 
https://issues.apache.org/jira/browse/TUBEMQ-441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

xianle cao updated TUBEMQ-441:
--
Description: 
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.

  was:
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'.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.


> 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
>
> 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)