Zhumengze commented on PR #512: URL: https://github.com/apache/doris-flink-connector/pull/512#issuecomment-2481861800
This test case is mainly to verify the usability of the syntax of lookup join. I use the datagen connector to generate random data, which is mainly to verify whether the data can be correctly joined and output the result. If the previous code is used, the program will report the following exception when performing lookup join King哥 ***@***.*** ------------------ 原始邮件 ------------------ 发件人: "apache/doris-flink-connector" ***@***.***>; 发送时间: 2024年11月18日(星期一) 上午10:13 ***@***.***>; ***@***.******@***.***>; 主题: Re: [apache/doris-flink-connector] [bugfix]Fix a mismatch between the type of jdbc query result and the datatype (PR #512) @JNSimba commented on this pull request. In flink-doris-connector/src/test/java/org/apache/doris/flink/lookup/DorisLookupTableITCase.java: > + "'password' = '%s'," + + "'lookup.cache.max-rows' = '100'" + + ")", + getFenodes(), + getDorisQueryUrl(), + DATABASE + "." + TABLE_READ_TBL, + getDorisUsername(), + getDorisPassword()); + tEnv.executeSql(lookupDDL); + tEnv.executeSql("select datagen.id," + + "tinyintColumn," + + "smallintColumn," + + "bigintColumn" + + " from `datagen`" + + " inner join `doris_lookup` FOR SYSTEM_TIME AS OF datagen.proctime on datagen.id = doris_lookup.id").print(); + env.execute("Flink doris lookup test"); Is it necessary to determine whether the output of select is the same as expected? — Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you authored the thread.Message ID: ***@***.***> -- 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: commits-unsubscr...@doris.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org