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 967b89c [FLINK-17092][python] Add retry when pip install dependencies (#12024) add 1de54fe [FLINK-17251] [table] Introduce Table#executeInsert & add insert statement support to TableEnvironment#executeSql No new revisions were added by this update. Summary of changes: flink-python/pyflink/table/table.py | 21 ++ .../java/org/apache/flink/table/api/Table.java | 57 +++++ .../table/api/internal/TableEnvironmentImpl.java | 52 ++++- .../api/internal/TableEnvironmentInternal.java | 59 ++++++ .../apache/flink/table/api/internal/TableImpl.java | 32 ++- .../flink/table/api/internal/TableResultImpl.java | 2 +- .../apache/flink/table/delegation/Executor.java | 10 + .../org/apache/flink/table/utils/ExecutorMock.java | 6 + .../table/planner/delegation/ExecutorBase.java | 6 + .../flink/table/api/TableEnvironmentITCase.scala | 202 +++++++++++++++++- .../flink/table/executor/StreamExecutor.java | 6 + .../table/api/internal/BatchTableEnvImpl.scala | 108 ++++++---- .../flink/table/api/internal/TableEnvImpl.scala | 168 ++++++++++----- .../flink/table/api/TableEnvironmentITCase.scala | 152 ++++++++++++++ .../runtime/batch/sql/TableEnvironmentITCase.scala | 231 ++++++++++++++++++++- .../apache/flink/table/utils/testTableSinks.scala | 87 ++++++++ 16 files changed, 1097 insertions(+), 102 deletions(-) create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentInternal.java create mode 100644 flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/utils/testTableSinks.scala