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