You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by he...@apache.org on 2020/05/15 05:08:04 UTC
[flink] branch master updated (be9779d -> 70346b2)
This is an automated email from the ASF dual-hosted git repository.
hequn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from be9779d [FLINK-17710][python][hotfix] Fix unstable test for StreamSqlTests.test_execute_sql (#12160)
add 7982281 Revert "[FLINK-17710][python][hotfix] Fix unstable test for StreamSqlTests.test_execute_sql (#12160)"
add 70346b2 Revert "[FLINK-17303][python] Support Python TableResult"
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/common/__init__.py | 8 -
flink-python/pyflink/common/completable_future.py | 63 --------
flink-python/pyflink/common/execution_mode.py | 2 +-
flink-python/pyflink/common/job_client.py | 114 --------------
.../pyflink/common/job_execution_result.py | 3 +-
flink-python/pyflink/common/job_id.py | 35 -----
flink-python/pyflink/common/job_status.py | 167 ---------------------
flink-python/pyflink/table/__init__.py | 48 +++---
flink-python/pyflink/table/result_kind.py | 49 ------
flink-python/pyflink/table/table_environment.py | 4 +-
flink-python/pyflink/table/table_result.py | 69 ---------
flink-python/pyflink/table/tests/test_sql.py | 60 +-------
12 files changed, 29 insertions(+), 593 deletions(-)
delete mode 100644 flink-python/pyflink/common/completable_future.py
delete mode 100644 flink-python/pyflink/common/job_client.py
delete mode 100644 flink-python/pyflink/common/job_id.py
delete mode 100644 flink-python/pyflink/common/job_status.py
delete mode 100644 flink-python/pyflink/table/result_kind.py
delete mode 100644 flink-python/pyflink/table/table_result.py