Flink Async io problem

[venn]

Hi Flink experts,

            I’m working flink async io program for stream join outer
database(mysql)，but found sync，please give some advice, or provide some
async demo. thanks 

 

asyncInvoke method are as follow:


@Override
public void asyncInvoke(AsyncUser asyncUser, ResultFuture<AsyncUser>
resultFuture) throws Exception {
    // 使用 asyncUser id 查询
    ps.setString(1, asyncUser.getId());
    ResultSet rs = ps.executeQuery();

    CompletableFuture.supplyAsync(new Supplier<AsyncUser>() {
        @Override
        public AsyncUser get() {
            try {
                if (!rs.isClosed() && rs.next()) {
                    asyncUser.setPhone(rs.getString(1));
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
            return asyncUser;
        }
    }).thenAccept((AsyncUser tmp) -> {
        List<AsyncUser> list = new ArrayList();
        list.add(tmp);
        resultFuture.complete(list);
    });
}

 

 

 

Best, Venn