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%)