FlinkArray2ArrayCastIssue.java

package com.soin.demo.flink.sqlrunner;

import org.apache.flink.table.api.EnvironmentSettings;
import org.apache.flink.table.api.TableEnvironment;


public class TestRunner {
    public static void main(String[] args) {
        EnvironmentSettings settings = EnvironmentSettings
            .newInstance()
            .inStreamingMode()
            .build();
        TableEnvironment tEnv = TableEnvironment.create(settings);

        var sql2 = "select CAST(commissions AS ARRAY<ROW<amount DOUBLE>>) as commissions " +
            "         from (select ARRAY[ROW(123), ROW(234)] commissions);";

        tEnv.sqlQuery(sql2).execute().print();
    }
}