You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ku...@apache.org on 2020/05/07 13:02:17 UTC
[flink] branch master updated (a7b2b5a -> ee9bb64)
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 a7b2b5a [FLINK-16782][state] Avoid unnecessary check on expired entry when ReturnExpiredIfNotCleanedUp
add fcce072 [FLINK-16029][table] Port CustomConnectorDescriptor to flink-table-common module
add 5511009 [FLINK-16029][table] Refactor CsvTableSink to support numFiles and writeMode
add ee9bb64 [FLINK-16029][table-planner-blink] Remove registerTableSource/registerTableSink in test cases of blink planner (use tableEnv.connect() instead).
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/table/descriptors/OldCsv.java | 25 +
.../flink/table/descriptors/OldCsvValidator.java | 4 +
.../flink/table/sinks/CsvTableSinkFactoryBase.java | 15 +-
.../descriptors}/CustomConnectorDescriptor.java | 4 +-
.../planner/catalog/CatalogStatisticsTest.java | 8 +-
.../org.apache.flink.table.factories.TableFactory | 15 +
.../flink/table/api/TableEnvironmentITCase.scala | 71 +--
.../flink/table/api/TableEnvironmentTest.scala | 14 +-
.../table/planner/plan/batch/sql/LimitTest.scala | 14 +-
.../planner/plan/batch/sql/TableSourceTest.scala | 64 +-
.../plan/batch/sql/join/LookupJoinTest.scala | 4 +-
.../PushFilterIntoTableSourceScanRuleTest.scala | 37 +-
.../PushPartitionIntoTableSourceScanRuleTest.scala | 8 +-
.../planner/plan/stream/sql/TableSourceTest.scala | 61 +-
.../plan/stream/sql/join/LookupJoinTest.scala | 245 ++++++--
.../table/validation/TableSinkValidationTest.scala | 9 +-
.../planner/runtime/batch/sql/LimitITCase.scala | 6 +-
.../runtime/batch/sql/TableScanITCase.scala | 34 +-
.../runtime/batch/sql/TableSourceITCase.scala | 68 +--
.../runtime/batch/sql/TimestampITCase.scala | 38 +-
.../runtime/batch/sql/join/LookupJoinITCase.scala | 56 +-
.../runtime/batch/table/TableSinkITCase.scala | 18 +-
.../runtime/stream/sql/AsyncLookupJoinITCase.scala | 49 +-
.../runtime/stream/sql/LookupJoinITCase.scala | 103 ++--
.../runtime/stream/sql/TableScanITCase.scala | 28 +-
.../runtime/stream/sql/TableSourceITCase.scala | 54 +-
.../runtime/stream/sql/TimestampITCase.scala | 30 +-
.../runtime/stream/table/TableSinkITCase.scala | 40 +-
.../utils/InMemoryLookupableTableSource.scala | 177 +++---
.../planner/utils/MemoryTableSourceSinkUtil.scala | 156 +++--
.../flink/table/planner/utils/TableTestBase.scala | 45 +-
.../planner/utils/TestLimitableTableSource.scala | 60 +-
.../table/planner/utils/testTableSourceSinks.scala | 666 ++++++++++++++++-----
33 files changed, 1320 insertions(+), 906 deletions(-)
rename {flink-python/src/main/java/org/apache/flink/table/descriptors/python => flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors}/CustomConnectorDescriptor.java (92%)