Page History

...

Let’s give an example to explain the buffering SQLs/Tables execution problem:

tEnv.sqlUpdate("CREATE TABLE test (...) with (path = '/tmp1')");

...

tEnv.sqlUpdate("INSERT INTO test SELECT ...");

...

tEnv.sqlUpdate("DROP TABLE test");

...

tEnv.sqlUpdate("CREATE TABLE test (...) with (path = '/tmp2')");

...

tEnv.execute()

1. Users are confused by what kinds of sql are executed at once and what are buffered and what kinds of sql are buffered until triggered by the execute method.
2. Buffering SQLs/Tables will cause behavior undefined. We may want to insert data into the `test` table with the `/tmp1` path but get the wrong result of `/tmp2`.

...