flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dawid Wysakowicz <dwysakow...@apache.org>
Subject Re: Flink Table API/SQL debugging, testability
Date Tue, 25 Aug 2020 16:32:17 GMT
Hi,

What exactly are you looking for?

I think the simplest stub for a test could be sth like:

            final TableEnvironment env = TableEnvironment.create(...);

            TableResult result = env.fromValues(...)
                .select(...)
                .execute();
            try (CloseableIterator<Row> it = result.collect()) {
                assertThat(...);
            }

You can also check some of the *ITCase tests in
flink-table-planner-blink module.

Best,

Dawid

On 25/08/2020 09:19, narasimha wrote:
> I was looking for testability, debugging practices on Flink Table
> API/SQL.
> Really difficult to find them when compared to Streaming API. 
>
> Can someone please share their experiences on debugging, testability. 
>
> -- 
> A.Narasimha Swamy
Mime
View raw message