Flink Table API/SQL debugging, testability

[narasimha]

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. 

--

[Dawid Wysakowicz-2]

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. 

--