You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2019/11/22 09:21:32 UTC
[flink] branch master updated (65a472f -> f01cdd1)

This is an automated email from the ASF dual-hosted git repository.

jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 65a472f  [FLINK-14788][documentation] Generated documentation for ExecutionCheckpointingOptions
     add 23c9b5a  [FLINK-13708][table-planner-blink] Transformations should be cleared after execution in blink planner
     add f01cdd1  [FLINK-13708][table-planner-blink] Revert changes in fb7beb88 which is a temporary fix

No new revisions were added by this update.

Summary of changes:
 .../table/tests/test_table_environment_api.py      |  29 +-
 .../client/gateway/local/ExecutionContext.java     |   2 +-
 .../java/internal/StreamTableEnvironmentImpl.java  |   6 +
 .../internal/StreamTableEnvironmentImpl.scala      |   6 +
 .../table/planner/delegation/BatchExecutor.java    |  68 +----
 .../table/planner/delegation/ExecutorBase.java     |  19 +-
 .../table/planner/delegation/StreamExecutor.java   |  14 +-
 .../utils/DummyStreamExecutionEnvironment.java     | 295 +++++++++++++++++++++
 .../ExecutorUtils.java}                            |  63 +++--
 .../table/planner/delegation/BatchPlanner.scala    |  23 +-
 .../table/planner/delegation/PlannerBase.scala     |   5 +-
 .../table/planner/delegation/StreamPlanner.scala   |  18 +-
 .../planner/delegation/BatchExecutorTest.java      |   4 +-
 .../runtime/utils/BatchAbstractTestBase.java       |   2 +-
 .../flink/table/api/TableEnvironmentITCase.scala   | 179 +++++++++++++
 .../flink/table/api/TableEnvironmentTest.scala     |  25 +-
 .../batch/sql/agg/AggregateITCaseBase.scala        |   4 -
 17 files changed, 621 insertions(+), 141 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/DummyStreamExecutionEnvironment.java
 copy flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/{delegation/BatchExecutor.java => utils/ExecutorUtils.java} (66%)
 create mode 100644 flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala