关于flink中unwrap()方法暂时不支持问题

Flink中将Statement类型转为CalciteServerStatement类型的unwrap()方法不支持

    @Override
    public <T> T unwrap(Class<T> iface) throws SQLException {
        throw new SQLFeatureNotSupportedException("FlinkStatement#executeLargeUpdate is not supported");
    }

Statement statement = connection.createStatement();
CalciteServerStatement calciteServerStatement = statement.unwrap(CalciteServerStatement.class);

哪位大佬已经写好了！

你好，我是问答小助手，本次您提出的有问必答问题，技术专家团超时未为您做出解答

本次提问扣除的有问必答次数，将会以问答VIP体验卡（1次有问必答机会、商城购买实体图书享受95折优惠）的形式为您补发到账户。

因为有问必答VIP体验卡有效期仅有1天，您在需要使用的时候【私信】联系我，我会为您补发。