This is an automated email from the ASF dual-hosted git repository. kurt pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5bf121a [FLINK-17564][checkpointing] Fix buffer disorder issue of RemoteInputChannel for unaligned checkpoint add 55d04d5 [FLINK-16367][table] Introduce TableEnvironment#createStatementSet api No new revisions were added by this update. Summary of changes: flink-python/pyflink/table/__init__.py | 6 +- flink-python/pyflink/table/statement_set.py | 93 +++++++++++++++ flink-python/pyflink/table/table_environment.py | 13 +++ .../table/tests/test_table_environment_api.py | 40 +++++++ .../org/apache/flink/table/api/StatementSet.java | 65 +++++++++++ .../apache/flink/table/api/TableEnvironment.java | 7 ++ .../flink/table/api/internal/StatementSetImpl.java | 102 +++++++++++++++++ .../table/api/internal/TableEnvironmentImpl.java | 69 +++++++----- .../test/resources/explain/testStatementSet.out | 63 +++++++++++ .../flink/table/api/TableEnvironmentITCase.scala | 125 +++++++++++++++++++-- .../flink/table/api/internal/TableEnvImpl.scala | 66 +++++++---- .../flink/table/api/TableEnvironmentITCase.scala | 104 +++++++++++++++-- .../runtime/batch/sql/TableEnvironmentITCase.scala | 82 ++++++++++++-- .../flink/table/utils/MockTableEnvironment.scala | 4 +- ...treamAndSqlUpdate.out => testStatementSet0.out} | 30 +++++ .../src/test/scala/resources/testStatementSet1.out | 81 +++++++++++++ 16 files changed, 864 insertions(+), 86 deletions(-) create mode 100644 flink-python/pyflink/table/statement_set.py create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/StatementSet.java create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/StatementSetImpl.java create mode 100644 flink-table/flink-table-planner-blink/src/test/resources/explain/testStatementSet.out copy flink-table/flink-table-planner/src/test/scala/resources/{testFromToDataStreamAndSqlUpdate.out => testStatementSet0.out} (52%) create mode 100644 flink-table/flink-table-planner/src/test/scala/resources/testStatementSet1.out