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