This is an automated email from the ASF dual-hosted git repository. eskabetxe pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/bahir-flink.git
commit d28d71f930021db11aff4c704849d044e2fc3b82 Author: min <[email protected]> AuthorDate: Thu May 19 17:13:25 2022 +0800 fix: update KuduDynamicSinkTest --- .../kudu/table/dynamic/KuduDynamicSinkTest.java | 50 +++++++++++----------- 1 file changed, 24 insertions(+), 26 deletions(-) diff --git a/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java b/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java index a024b4d..f889c7a 100644 --- a/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java +++ b/flink-connector-kudu/src/test/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicSinkTest.java @@ -59,32 +59,30 @@ public class KuduDynamicSinkTest extends KuduTestBase { } @Test - public void testKuduSSink() throws Exception { - // "id", "title", "author", "price", "quantity" - tEnv.executeSql( - "CREATE TABLE " - + INPUT_TABLE - + "(" - + "id int," - + "title string," - + "author string," - + "price double," - + "quantity int" - + ") WITH (" - + " 'connector'='kudu'," - + " 'kudu.masters'='" - + getMasterAddress() - + "'," - + " 'kudu.table'='" - + INPUT_TABLE - + "','kudu.primary-key-columns'='id'" - + "','kudu.max-buffer-size'='1024'" - + "','kudu.flush-interval'='1000'" - + "','kudu.operation-timeout'='500'" - + "','kudu.ignore-not-found'='true'" - + "','kudu.ignore-not-found'='true'" - + ")"); - + public void testKuduSink() throws Exception { + String createSql="CREATE TABLE " + + INPUT_TABLE + + "(" + + "id int," + + "title string," + + "author string," + + "price double," + + "quantity int" + + ") WITH (" + + " 'connector'='kudu'," + + " 'kudu.masters'='" + + 123245 + + "'," + + " 'kudu.table'='" + + INPUT_TABLE + + "','kudu.primary-key-columns'='id" + + "','kudu.max-buffer-size'='1024" + + "','kudu.flush-interval'='1000" + + "','kudu.operation-timeout'='500" + + "','kudu.ignore-not-found'='true" + + "','kudu.ignore-not-found'='true" + + ")"; + tEnv.executeSql(createSql); tEnv.executeSql("insert into " + INPUT_TABLE + " values(1006,'test title','test author',10.1,10)"); CloseableIterator<Row> collected = tEnv.executeSql("select * from " + INPUT_TABLE + " where id =1006").collect(); assertNotNull(collected);
