mengqiang
mengqiang
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-streampark/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### Java Version java 8 ### Scala Version 2.12.x ### StreamPark Version 2.1.4...
### What happened? ``` CREATE CATALOG amoro_catalog WITH ( 'type' = 'arctic', 'metastore.url' = 'thrift://ip:1260/amoro_catalog' ); CREATE TABLE ODS_TB_A ( PK_ID VARCHAR, XMMC VARCHAR, DWDM VARCHAR, XSSX INTEGER, FLAG VARCHAR,...
### What happened? Problems encountered when submitting amoro tasks using Streamark ``` java.util.concurrent.CompletionException: java.lang.reflect.InvocationTargetException at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1592) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.reflect.InvocationTargetException at...
当前逻辑中,如果返回结果集为空会返回Collections.emptyList(),建议返回new ArrayList(); ```java /** * 根据查询条件查询数据列表。 * * @param queryWrapper 条件 * @param consumers 字段查询 * @return 数据列表 */ default List selectListByQuery(QueryWrapper queryWrapper, Consumer... consumers) { List list = selectListByQuery(queryWrapper);...