This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 74fd291 [FLINK-18075] Wrap the SerializationSchema in KafkaSerializationSchema in Kafka connector add 0e8a53b [FLINK-13782][table-api] Implement type strategies for IF ELSE expression No new revisions were added by this update. Summary of changes: .../functions/BuiltInFunctionDefinitions.java | 11 +- .../table/types/inference/InputTypeStrategies.java | 24 +- ...eStrategy.java => CommonInputTypeStrategy.java} | 73 ++++-- .../strategies/SubsequenceInputTypeStrategy.java | 256 +++++++++++++++++++++ .../types/inference/InputTypeStrategiesTest.java | 3 +- .../SubsequenceInputTypeStrategyTest.java | 143 ++++++++++++ .../expressions/PlannerExpressionConverter.scala | 4 - .../flink/table/planner/expressions/logic.scala | 51 ---- 8 files changed, 487 insertions(+), 78 deletions(-) rename flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/{ArrayInputTypeStrategy.java => CommonInputTypeStrategy.java} (52%) create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SubsequenceInputTypeStrategy.java create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/SubsequenceInputTypeStrategyTest.java delete mode 100644 flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/logic.scala