You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2020/05/31 09:15:54 UTC
[flink] branch master updated (d854b5f -> eab5168)

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

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


    from d854b5f  [hotfix][coordination] Remove unused (and unimplemented) method 'failTask(...)' from OperatorCoordinator Context
     add 11d588c  [hotfix][table-common] Accept AbstractDataType for fields
     add 2724942  [hotfix][table] Use AbstractDataType in fromValues()
     add 7ea887f  [hotfix][tests] Move containsCause to FlinkMatchers
     add eab5168  [FLINK-18001][table-planner] Add a new test base for evaluating expressions

No new revisions were added by this update.

Summary of changes:
 flink-connectors/flink-connector-hbase/pom.xml     |   8 -
 .../flink/connector/hbase/HBaseTablePlanTest.java  |   2 +-
 .../table/KafkaDynamicTableFactoryTestBase.java    |   2 +-
 .../java/org/apache/flink/util/CoreMatchers.java   |  76 -----
 flink-formats/flink-csv/pom.xml                    |   9 -
 .../flink/formats/csv/CsvFormatFactoryTest.java    |   2 +-
 flink-formats/flink-json/pom.xml                   |   9 -
 .../flink/formats/json/JsonFormatFactoryTest.java  |   2 +-
 .../json/canal/CanalJsonFormatFactoryTest.java     |   2 +-
 .../debezium/DebeziumJsonFormatFactoryTest.java    |   2 +-
 .../slotmanager/SlotManagerImplTest.java           |   4 +-
 .../apache/flink/table/api/TableEnvironment.java   |  13 +-
 .../table/api/internal/TableEnvironmentImpl.java   |  10 +-
 flink-table/flink-table-api-scala/pom.xml          |   5 +-
 .../java/org/apache/flink/table/api/DataTypes.java |  94 ++++---
 .../apache/flink/table/types/AbstractDataType.java |   3 +
 .../flink/table/factories/FactoryUtilTest.java     |   2 +-
 .../types/extraction/DataTypeExtractorTest.java    |   2 +-
 .../extraction/TypeInferenceExtractorTest.java     |   2 +-
 .../inference/InputTypeStrategiesTestBase.java     |   2 +-
 .../table/types/inference/TypeStrategiesTest.java  |   2 +-
 .../expressions/BuiltInFunctionTestBase.java       | 309 +++++++++++++++++++++
 .../planner/expressions/MathFunctionsITCase.java   |  54 ++++
 .../planner/runtime/stream/table/ValuesITCase.java |   6 +-
 .../flink/table/api/internal/TableEnvImpl.scala    |  12 +-
 .../flink/table/utils/MockTableEnvironment.scala   |  14 +-
 .../apache/flink/core/testutils/FlinkMatchers.java |  66 +++++
 27 files changed, 529 insertions(+), 185 deletions(-)
 delete mode 100644 flink-core/src/test/java/org/apache/flink/util/CoreMatchers.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/expressions/BuiltInFunctionTestBase.java
 create mode 100644 flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/expressions/MathFunctionsITCase.java